com.redhat.rhn.taskomatic

Class TaskoFactory

java.lang.Object

com.redhat.rhn.common.hibernate.HibernateFactory

com.redhat.rhn.taskomatic.TaskoFactory

public class TaskoFactory
extends HibernateFactory

TaskoFactory

Method Summary

Modifier and Type	Method and Description
static void	delete(TaskoBunch taskoBunch) hibernate delete bunch
static void	delete(TaskoRun taskoRun) hibernate delete run
static void	delete(TaskoSchedule taskoSchedule) hibernate delete schedule
static void	delete(TaskoTask taskoTask) hibernate delete task
static void	delete(TaskoTemplate taskoTemplate) hibernate delete template
static void	deleteLogFiles(TaskoRun run) delete log files associated with given run
static void	deleteRun(TaskoRun run) deletes specified tasko run
protected org.apache.log4j.Logger	getLogger() Get the Logger for the derived class so log messages show up on the correct class
static java.util.List<TaskoSchedule>	listActiveSchedulesByOrg(java.lang.Integer orgId) lists active schedules for a given org
static java.util.List<TaskoSchedule>	listActiveSchedulesByOrgAndBunch(java.lang.Integer orgId, java.lang.String bunchName) lists active schedule of the given bunch
static java.util.List<TaskoSchedule>	listActiveSchedulesByOrgAndLabel(java.lang.Integer orgId, java.lang.String jobLabel) lists active schedules of given name for a given org
static java.util.List<TaskoSchedule>	listFuture() list schedules, that shall be run sometime in the future
static java.util.List<TaskoRun>	listNewerRunsBySchedule(java.lang.Long scheduleId, java.util.Date limitTime) list all schedule runs with (future) timestamps newer than limitTime
static java.util.List<TaskoBunch>	listOrgBunches() list all available organizational bunches
static java.util.List<TaskoRun>	listRunsByBunch(java.lang.String bunchName) lists runs by bunch
static java.util.List<TaskoRun>	listRunsByOrgAndSchedule(java.lang.Integer orgId, java.lang.Integer scheduleId) lists organizational runs by schedule
static java.util.List<TaskoRun>	listRunsBySchedule(java.lang.Long scheduleId) list all runs associated with a schedule
static java.util.List<TaskoRun>	listRunsOlderThan(java.util.Date limitTime) lists runs older than given date
static java.util.List<TaskoBunch>	listSatBunches() list all available satellite bunches
static java.util.List<TaskoSchedule>	listSchedulesByOrg(java.lang.Integer orgId) lists all schedules for an org
static java.util.List<TaskoSchedule>	listSchedulesByOrgAndLabel(java.lang.Integer orgId, java.lang.String jobLabel) lists organizational schedules by name
static java.util.List<TaskoSchedule>	listSchedulesOlderThan(java.util.Date limitTime) list schedules older than given date
static java.util.List<TaskoTask>	listTasks() lists all available tasks
static java.util.List<TaskoRun>	listUnfinishedRuns() Lists taskomatic runs those endTime IS NULL (most probably were interrupted by taskomatic shutdown)
static TaskoBunch	lookupBunchByName(java.lang.String bunchName) lookup bunch by label
static TaskoBunch	lookupOrgBunchByName(java.lang.String bunchName) lookup a organization bunch by name
static TaskoRun	lookupRunById(java.lang.Long runId) lookup run by id
static TaskoRun	lookupRunByOrgAndId(java.lang.Integer orgId, java.lang.Integer runId) lookup organizational run by id
static TaskoBunch	lookupSatBunchByName(java.lang.String bunchName) lookup a satellite bunch by name
static TaskoSchedule	lookupScheduleById(java.lang.Long scheduleId) lookup schedule by id
static TaskoSchedule	lookupScheduleByLabel(java.lang.String jobLabel) lookup schedule by label
static TaskoSchedule	reinitializeScheduleFromNow(TaskoSchedule schedule, java.util.Date now) Reinitializes schedule used, when quartz needs to be updated according to our tasko table entries
static void	save(TaskoBunch taskoBunch) hibernate save bunch
static void	save(TaskoRun taskoRun) hibernate save run
static void	save(TaskoSchedule taskoSchedule) hibernate save schedule
static void	save(TaskoTask taskoTask) hibernate save task
static void	save(TaskoTemplate taskoTemplate) hibernate save template

Methods inherited from class com.redhat.rhn.common.hibernate.HibernateFactory

addConfigurator, blobToByteArray, byteArrayToBlob, closeSession, closeSessionFactory, commitTransaction, createSessionFactory, createSessionFactory, executeCallableMode, executeSelectMode, getBlobContents, getByteArrayContents, getObject, getSession, initialize, inTransaction, isClosed, isInitialized, listObjectsByNamedQuery, listObjectsByNamedQuery, listObjectsByNamedQuery, lockObject, lookupObjectByNamedQuery, lookupObjectByNamedQuery, reload, removeObject, rollbackTransaction, saveObject, saveObject, stringToByteArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getLogger

protected org.apache.log4j.Logger getLogger()

Description copied from class: HibernateFactory

Get the Logger for the derived class so log messages show up on the correct class

Specified by:

getLogger in class HibernateFactory

Returns:

Logger for this class.

lookupOrgBunchByName

public static TaskoBunch lookupOrgBunchByName(java.lang.String bunchName)

lookup a organization bunch by name

Parameters:

bunchName - bunch name

Returns:

bunch

lookupSatBunchByName

public static TaskoBunch lookupSatBunchByName(java.lang.String bunchName)

lookup a satellite bunch by name

Parameters:

bunchName - bunch name

Returns:

bunch

listOrgBunches

public static java.util.List<TaskoBunch> listOrgBunches()

list all available organizational bunches

Returns:

list of bunches

listSatBunches

public static java.util.List<TaskoBunch> listSatBunches()

list all available satellite bunches

Returns:

list of bunches

save

public static void save(TaskoRun taskoRun)

hibernate save run

Parameters:

taskoRun - run to save

delete

public static void delete(TaskoRun taskoRun)

hibernate delete run

Parameters:

taskoRun - run to delete

delete

public static void delete(TaskoSchedule taskoSchedule)

hibernate delete schedule

Parameters:

taskoSchedule - schedule to delete

save

public static void save(TaskoSchedule taskoSchedule)

hibernate save schedule

Parameters:

taskoSchedule - schedule to save

save

public static void save(TaskoTemplate taskoTemplate)

hibernate save template

Parameters:

taskoTemplate - run to save

delete

public static void delete(TaskoTemplate taskoTemplate)

hibernate delete template

Parameters:

taskoTemplate - run to delete

save

public static void save(TaskoBunch taskoBunch)

hibernate save bunch

Parameters:

taskoBunch - run to save

delete

public static void delete(TaskoBunch taskoBunch)

hibernate delete bunch

Parameters:

taskoBunch - run to delete

save

public static void save(TaskoTask taskoTask)

hibernate save task

Parameters:

taskoTask - run to save

delete

public static void delete(TaskoTask taskoTask)

hibernate delete task

Parameters:

taskoTask - run to delete

listTasks

public static java.util.List<TaskoTask> listTasks()

lists all available tasks

Returns:

list of tasks

listRunsOlderThan

public static java.util.List<TaskoRun> listRunsOlderThan(java.util.Date limitTime)

lists runs older than given date

Parameters:

limitTime - date of interest

Returns:

list of runs

deleteRun

public static void deleteRun(TaskoRun run)

deletes specified tasko run

Parameters:

run - run to delete

deleteLogFiles

public static void deleteLogFiles(TaskoRun run)

delete log files associated with given run

Parameters:

run - run to delete logs

listActiveSchedulesByOrg

public static java.util.List<TaskoSchedule> listActiveSchedulesByOrg(java.lang.Integer orgId)

lists active schedules for a given org

Parameters:

orgId - organization id

Returns:

list of active schedules

listActiveSchedulesByOrgAndLabel

public static java.util.List<TaskoSchedule> listActiveSchedulesByOrgAndLabel(java.lang.Integer orgId,
                                                                             java.lang.String jobLabel)

lists active schedules of given name for a given org

Parameters:

orgId - organization id

jobLabel - unique job name

Returns:

list of active schedules

listActiveSchedulesByOrgAndBunch

public static java.util.List<TaskoSchedule> listActiveSchedulesByOrgAndBunch(java.lang.Integer orgId,
                                                                             java.lang.String bunchName)
                                                                      throws NoSuchBunchTaskException

lists active schedule of the given bunch

Parameters:

orgId - organization id

bunchName - bunch name

Returns:

list of schedules

Throws:

NoSuchBunchTaskException - in case of unknown bunch name

listFuture

public static java.util.List<TaskoSchedule> listFuture()

list schedules, that shall be run sometime in the future

Returns:

list of schedules to be run at least once

listNewerRunsBySchedule

public static java.util.List<TaskoRun> listNewerRunsBySchedule(java.lang.Long scheduleId,
                                                               java.util.Date limitTime)

list all schedule runs with (future) timestamps newer than limitTime

Parameters:

scheduleId - schedule id

limitTime - limit time

Returns:

list of runs

lookupScheduleById

public static TaskoSchedule lookupScheduleById(java.lang.Long scheduleId)

lookup schedule by id

Parameters:

scheduleId - schedule id

Returns:

schedule

lookupScheduleByLabel

public static TaskoSchedule lookupScheduleByLabel(java.lang.String jobLabel)

lookup schedule by label

Parameters:

jobLabel - schedule label

Returns:

schedule

lookupBunchByName

public static TaskoBunch lookupBunchByName(java.lang.String bunchName)

lookup bunch by label

Parameters:

bunchName - bunch label

Returns:

bunch

listSchedulesByOrg

public static java.util.List<TaskoSchedule> listSchedulesByOrg(java.lang.Integer orgId)

lists all schedules for an org

Parameters:

orgId - organizational id

Returns:

list of all schedules

listRunsBySchedule

public static java.util.List<TaskoRun> listRunsBySchedule(java.lang.Long scheduleId)

list all runs associated with a schedule

Parameters:

scheduleId - schedule id

Returns:

list of runs

listSchedulesOlderThan

public static java.util.List<TaskoSchedule> listSchedulesOlderThan(java.util.Date limitTime)

list schedules older than given date

Parameters:

limitTime - time of interest

Returns:

list of schedules

listSchedulesByOrgAndLabel

public static java.util.List<TaskoSchedule> listSchedulesByOrgAndLabel(java.lang.Integer orgId,
                                                                       java.lang.String jobLabel)

lists organizational schedules by name

Parameters:

orgId - organization id

jobLabel - unique job name

Returns:

list of schedules

lookupRunById

public static TaskoRun lookupRunById(java.lang.Long runId)

lookup run by id

Parameters:

runId - run id

Returns:

run

lookupRunByOrgAndId

public static TaskoRun lookupRunByOrgAndId(java.lang.Integer orgId,
                                           java.lang.Integer runId)
                                    throws InvalidParamException

lookup organizational run by id

Parameters:

orgId - organizational id

runId - run id

Returns:

run

Throws:

InvalidParamException - thrown in case of wrong runId

listRunsByOrgAndSchedule

public static java.util.List<TaskoRun> listRunsByOrgAndSchedule(java.lang.Integer orgId,
                                                                java.lang.Integer scheduleId)

lists organizational runs by schedule

Parameters:

orgId - organization id

scheduleId - schedule id

Returns:

list of runs

listRunsByBunch

public static java.util.List<TaskoRun> listRunsByBunch(java.lang.String bunchName)

lists runs by bunch

Parameters:

bunchName - bunch name

Returns:

list of runs

reinitializeScheduleFromNow

public static TaskoSchedule reinitializeScheduleFromNow(TaskoSchedule schedule,
                                                        java.util.Date now)

Reinitializes schedule used, when quartz needs to be updated according to our tasko table entries

Parameters:

schedule - schedule to reinit

now - time to set

Returns:

schedule

listUnfinishedRuns

public static java.util.List<TaskoRun> listUnfinishedRuns()

Lists taskomatic runs those endTime IS NULL (most probably were interrupted by taskomatic shutdown)

Returns:

list of unfinished runs