event

package
v0.0.0-...-aaf3491 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 20, 2023 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

View Source
const (
	KeyDagInstanceUpdated = "DagInstanceUpdated"
	KeyDagInstancePatched = "DagInstancePatched"

	KeyTaskCompleted = "TaskCompleted"
	KeyTaskBegin     = "TaskBegin"

	KeyLeaderChanged                = "LeaderChanged"
	KeyDispatchInitDagInsCompleted  = "DispatchInitDagInsCompleted"
	KeyParseScheduleDagInsCompleted = "ParseScheduleDagInsCompleted"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DagInstancePatched

type DagInstancePatched struct {
	Payload         *entity.DagInstance
	MustPatchFields []string
}

DagInstanceUpdated will raise when dag instance he updated

func (*DagInstancePatched) Topic

func (e *DagInstancePatched) Topic() []string

Topic

type DagInstanceUpdated

type DagInstanceUpdated struct {
	Payload *entity.DagInstance
}

DagInstanceUpdated will raise when dag instance he updated

func (*DagInstanceUpdated) Topic

func (e *DagInstanceUpdated) Topic() []string

Topic

type DispatchInitDagInsCompleted

type DispatchInitDagInsCompleted struct {
	ElapsedMs int64
	Error     error
}

DispatchInitDagInsCompleted will raise when leader changed such as campaign success or continue leader failed

func (*DispatchInitDagInsCompleted) Topic

func (e *DispatchInitDagInsCompleted) Topic() []string

Topic

type LeaderChanged

type LeaderChanged struct {
	IsLeader  bool
	WorkerKey string
}

LeaderChanged will raise when leader changed such as campaign success or continue leader failed

func (*LeaderChanged) Topic

func (e *LeaderChanged) Topic() []string

Topic

type ParseScheduleDagInsCompleted

type ParseScheduleDagInsCompleted struct {
	ElapsedMs int64
	Error     error
}

ParseScheduleDagInsCompleted will raise when leader changed such as campaign success or continue leader failed

func (*ParseScheduleDagInsCompleted) Topic

func (e *ParseScheduleDagInsCompleted) Topic() []string

Topic

type TaskBegin

type TaskBegin struct {
	TaskIns *entity.TaskInstance
}

TaskCompleted will raise when executor completed a task instance,

func (*TaskBegin) Topic

func (e *TaskBegin) Topic() []string

Topic

type TaskCompleted

type TaskCompleted struct {
	TaskIns *entity.TaskInstance
}

TaskCompleted will raise when executor completed a task instance,

func (*TaskCompleted) Topic

func (e *TaskCompleted) Topic() []string

Topic

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL