dispatcher

Documentation

Index

• Variables
• func Dispatch(event events.SchedulingEvent)
• func RegisterEventHandler(eventType EventType, handlerFn func(interface{}))
• func Start()
• func Stop()
• 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(eventType EventType, handlerFn func(interface{}))

func Start

func Start()

func Stop

func Stop()

stop the dispatcher and wait at most 5 seconds gracefully

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
	EventTypeScheduler
	EventTypeAppStatus
)