Documentation ¶
Index ¶
- Variables
- func Dispatch(event events.SchedulingEvent)
- func RegisterEventHandler(handlerID string, eventType EventType, handlerFn func(interface{}))
- func Start()
- func Stop()
- func UnregisterAllEventHandlers()
- func UnregisterEventHandler(handlerID string, eventType EventType)
- type Dispatcher
- type EventType
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func Dispatch ¶
func Dispatch(event events.SchedulingEvent)
dispatches scheduler events to actual app/task handler, each app/task has its own state machine and maintain their own states. currently all events share same channel, so they are dispatched one by one in order.
func RegisterEventHandler ¶
func UnregisterAllEventHandlers ¶ added in v1.5.0
func UnregisterAllEventHandlers()
func UnregisterEventHandler ¶ added in v1.5.0
Types ¶
type Dispatcher ¶
type Dispatcher struct {
// contains filtered or unexported fields
}
central dispatcher that dispatches scheduling events.
Click to show internal directories.
Click to hide internal directories.