summaryrefslogtreecommitdiff
path: root/plugins/jobs/oooold/event.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/jobs/oooold/event.go')
-rw-r--r--plugins/jobs/oooold/event.go96
1 files changed, 0 insertions, 96 deletions
diff --git a/plugins/jobs/oooold/event.go b/plugins/jobs/oooold/event.go
deleted file mode 100644
index 6524712f..00000000
--- a/plugins/jobs/oooold/event.go
+++ /dev/null
@@ -1,96 +0,0 @@
-package oooold
-
-import "time"
-
-const (
- // EventPushOK thrown when new job has been added. JobEvent is passed as context.
- EventPushOK = iota + 1500
-
- // EventPushError caused when job can not be registered.
- EventPushError
-
- // EventJobStart thrown when new job received.
- EventJobStart
-
- // EventJobOK thrown when job execution is successfully completed. JobEvent is passed as context.
- EventJobOK
-
- // EventJobError thrown on all job related errors. See JobError as context.
- EventJobError
-
- // EventPipeConsume when pipeline pipelines has been requested.
- EventPipeConsume
-
- // EventPipeActive when pipeline has started.
- EventPipeActive
-
- // EventPipeStop when pipeline has begun stopping.
- EventPipeStop
-
- // EventPipeStopped when pipeline has been stopped.
- EventPipeStopped
-
- // EventPipeError when pipeline specific error happen.
- EventPipeError
-
- // EventBrokerReady thrown when broken is ready to accept/serve tasks.
- EventBrokerReady
-)
-
-// JobEvent represent job event.
-type JobEvent struct {
- // String is job id.
- ID string
-
- // Job is failed job.
- Job *Job
-
- // event timings
- start time.Time
- elapsed time.Duration
-}
-
-// Elapsed returns duration of the invocation.
-func (e *JobEvent) Elapsed() time.Duration {
- return e.elapsed
-}
-
-// JobError represents singular Job error event.
-type JobError struct {
- // String is job id.
- ID string
-
- // Job is failed job.
- Job *Job
-
- // Caused contains job specific error.
- Caused error
-
- // event timings
- start time.Time
- elapsed time.Duration
-}
-
-// Elapsed returns duration of the invocation.
-func (e *JobError) Elapsed() time.Duration {
- return e.elapsed
-}
-
-// Caused returns error message.
-func (e *JobError) Error() string {
- return e.Caused.Error()
-}
-
-// PipelineError defines pipeline specific errors.
-type PipelineError struct {
- // Pipeline is associated pipeline.
- Pipeline *Pipeline
-
- // Caused send by broker.
- Caused error
-}
-
-// Error returns error message.
-func (e *PipelineError) Error() string {
- return e.Caused.Error()
-}