Worker interface

[mingard]

type Worker interface {
  // Start the worker with the given context
  GetID() string
  // Start the worker with the given context
  Start(context.Context) error
  // Stop the worker
  Stop() error
  // AddJob to the workers queue
  AddJob(interface{}) error
  // ScheduleJob
  ScheduleJob(interface{}, time.Time) error
  // JobHandler
  JobHandler(func(interface{})) error
  // OnClose
  OnClose(func())
  // SetMetadata sets arbitrary metadata values
  SetMetadata(interface{})
  // GetMetadata gets metadata
  GetMetadata(interface{})
}