Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobDb ¶
type JobDb struct {
Database string
}
func (*JobDb) GetJobRunLogRepository ¶
func (j *JobDb) GetJobRunLogRepository() *JobRunLogRepository
type JobManager ¶
type JobManager struct { // Job db JobDb JobDb // Job Details JobDetails []jobDetail // contains filtered or unexported fields }
Job Manager
func (*JobManager) RegisterJob ¶
func (j *JobManager) RegisterJob(name string, duration time.Duration, job Job)
Add job
func (*JobManager) Stop ¶
func (j *JobManager) Stop()
Stop method to signal the registered jobs to stop
type JobRunLogModel ¶
type JobRunLogModel struct { // Job name Name string `bson:"name"` // Last execution date time in format dd-MMM-yyyy HH:mm:ss LastExecutionDateTime string `bson:"lastExecutionDateTime"` // Last execution status LastExecutionStatus JobStatus `bson:"lastExecutionStatus"` // Last execution message LastExecutionMessage string `bson:"lastExecutionMessage"` // Last execution duration LastExecutionDuration time.Duration `bson:"lastExecutionDuration"` }
func (*JobRunLogModel) Id ¶
func (j *JobRunLogModel) Id() string
type JobRunLogRepository ¶
type JobRunLogRepository struct { odm.UnimplementedBootRepository[JobRunLogModel] }
func (*JobRunLogRepository) IsRunning ¶
func (j *JobRunLogRepository) IsRunning(id string) chan bool
Click to show internal directories.
Click to hide internal directories.