diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-12 12:45:53 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-12 12:45:53 +0300 |
| commit | aa1437d24ac215bec7fe053b06fa4773c9b1b1ad (patch) | |
| tree | 7a6868867877f34ac5e2d490bfb589b3dce02917 /plugins/server | |
| parent | 87971c4d310fe3d353197fc96b9b6f9106f01e57 (diff) | |
Update JOBS interface, remove List() method, implemented on the root RPC
level.
AMQP consumer replace sync.Map with atomic.Value, because we associate
only 1 pipeline with a driver. So, we can store pipeline in the
atomic.Value.
Implement events handler, add job events. Use job events to push
information to the logger.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/server')
| -rw-r--r-- | plugins/server/plugin.go | 11 |
1 files changed, 0 insertions, 11 deletions
diff --git a/plugins/server/plugin.go b/plugins/server/plugin.go index 038d83d4..1694cdf1 100644 --- a/plugins/server/plugin.go +++ b/plugins/server/plugin.go @@ -266,14 +266,3 @@ func (server *Plugin) collectWorkerEvents(event interface{}) { } } } - -func (server *Plugin) collectJobsEvents(event interface{}) { //nolint:unused - if jev, ok := event.(events.JobEvent); ok { - switch jev.Event { - case events.EventJobStart: - server.log.Info("Job started", "start", jev.Start, "elapsed", jev.Elapsed) - case events.EventJobOK: - server.log.Info("Job OK", "start", jev.Start, "elapsed", jev.Elapsed) - } - } -} |