dispatcher

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

Variables

var (
	AsyncDispatchLimit         int32
	AsyncDispatchCheckInterval = 3 * time.Second
	DispatchTimeout            time.Duration
)

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 RegisterEventHandler(handlerID string, eventType EventType, handlerFn func(interface{}))

func Start

func Start()

func Stop

func Stop()

stop the dispatcher and wait at most 5 seconds gracefully

func UnregisterAllEventHandlers

func UnregisterAllEventHandlers()

func UnregisterEventHandler

func UnregisterEventHandler(handlerID string, eventType EventType)

Types

type Dispatcher

type Dispatcher struct {
	// contains filtered or unexported fields
}

central dispatcher that dispatches scheduling events.

type EventType

type EventType int8

const (
	EventTypeApp EventType = iota
	EventTypeTask
	EventTypeNode
)