Documentation ¶
Index ¶
Constants ¶
View Source
const UnknownEventType string = "Unknown event type"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GRPCEvent ¶
type GRPCEvent struct { Event G // Info contains unary call info. Info *grpc.UnaryServerInfo // Error associated with event. Error error // event timings Start time.Time Elapsed time.Duration }
JobEvent represent job event.
type Handler ¶
type Handler interface { // NumListeners return number of active listeners NumListeners() int // AddListener adds lister to the publisher AddListener(listener Listener) // Push pushes event to the listeners Push(e interface{}) }
Handler interface
func NewEventsHandler ¶
func NewEventsHandler() Handler
type HandlerImpl ¶
type HandlerImpl struct { sync.RWMutex // all receivers should be pointers // contains filtered or unexported fields }
HandlerImpl helps to broadcast events to multiple listeners.
func (*HandlerImpl) AddListener ¶
func (eb *HandlerImpl) AddListener(listener Listener)
AddListener registers new event listener.
func (*HandlerImpl) NumListeners ¶
func (eb *HandlerImpl) NumListeners() int
NumListeners returns number of event listeners.
func (*HandlerImpl) Push ¶
func (eb *HandlerImpl) Push(e interface{})
Push broadcast events across all event listeners.
type J ¶
type J int64
const ( // EventPushOK thrown when new job has been added. JobEvent is passed as context. EventPushOK J = iota + 12000 // 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 // EventPipeActive when pipeline has started. EventPipeActive // EventPipeStopped when pipeline has been stopped. EventPipeStopped // EventPipePaused when pipeline has been paused. EventPipePaused // EventPipeError when pipeline specific error happen. EventPipeError // EventDriverReady thrown when broken is ready to accept/serve tasks. EventDriverReady )
type JobEvent ¶
type JobEvent struct { Event J // String is job id. ID string // Pipeline name Pipeline string // Associated driver name (amqp, ephemeral, etc) Driver string // Error for the jobs/pipes errors Error error // event timings Start time.Time Elapsed time.Duration }
JobEvent represent job event.
type Listener ¶
type Listener func(event interface{})
Listener .. (type alias) event listener listens for the events produced by worker, worker pool or other service.
type P ¶
type P int64
const ( // EventWorkerConstruct thrown when new worker is spawned. EventWorkerConstruct P = iota + 10000 // EventWorkerDestruct thrown after worker destruction. EventWorkerDestruct // EventSupervisorError triggered when supervisor can not complete work. EventSupervisorError // EventWorkerProcessExit triggered on process wait exit EventWorkerProcessExit // EventNoFreeWorkers triggered when there are no free workers in the stack and timeout for worker allocate elapsed EventNoFreeWorkers // EventMaxMemory caused when worker consumes more memory than allowed. EventMaxMemory // EventTTL thrown when worker is removed due TTL being reached. TTL defines maximum time worker is allowed to live (seconds) EventTTL // EventIdleTTL triggered when worker spends too much time at rest. EventIdleTTL // EventExecTTL triggered when worker spends too much time doing the task (max_execution_time). EventExecTTL // EventPoolRestart triggered when pool restart is needed EventPoolRestart )
type PoolEvent ¶
type PoolEvent struct { // Event type, see below. Event P // Payload depends on event type, typically it's worker or error. Payload interface{} Error error }
PoolEvent triggered by pool on different events. Pool as also trigger WorkerEvent in case of log.
type W ¶
type W int64
const ( // EventWorkerError triggered after WorkerProcess. Except payload to be error. EventWorkerError W = iota + 11000 // EventWorkerLog triggered on every write to WorkerProcess StdErr pipe (batched). Except payload to be []byte string. EventWorkerLog // EventWorkerStderr is the worker standard error output EventWorkerStderr // EventWorkerWaitExit is the worker exit event EventWorkerWaitExit )
type WorkerEvent ¶
type WorkerEvent struct { // Event id, see below. Event W // Worker triggered the event. Worker interface{} // Event specific payload. Payload interface{} }
WorkerEvent wraps worker events.
Click to show internal directories.
Click to hide internal directories.