event

Documentation

Index

• Constants
• type DagInstancePatched
  • func (e *DagInstancePatched) Topic() []string
• type DagInstanceUpdated
  • func (e *DagInstanceUpdated) Topic() []string
• type DispatchInitDagInsCompleted
  • func (e *DispatchInitDagInsCompleted) Topic() []string
• type LeaderChanged
  • func (e *LeaderChanged) Topic() []string
• type ParseScheduleDagInsCompleted
  • func (e *ParseScheduleDagInsCompleted) Topic() []string
• type TaskBegin
  • func (e *TaskBegin) Topic() []string
• type TaskCompleted
  • func (e *TaskCompleted) Topic() []string

Constants

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

	KeyTaskCompleted = "TaskCompleted"
	KeyTaskBegin     = "TaskBegin"

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

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