proccess

Documentation

Index

• Constants
• type ExecutorRegistryProccessor
  • func NewExecutorRegistryProccessor(appname string, address string) *ExecutorRegistryProccessor
  • func (t *ExecutorRegistryProccessor) Start()
  • func (t *ExecutorRegistryProccessor) Stop()
• type JobLogFileCleanProccessor
  • func NewJobLogFileCleanProccessor(logRetentionDays int32, logPath string) *JobLogFileCleanProccessor
  • func (t *JobLogFileCleanProccessor) Start()
  • func (t *JobLogFileCleanProccessor) Stop()
• type TriggerCallbackProccessor
  • func NewTriggerCallbackProccessor() *TriggerCallbackProccessor
  • func (t *TriggerCallbackProccessor) PushTriggerCallback(callbackParam HandleCallbackParam)
  • func (t *TriggerCallbackProccessor) Start()
  • func (t *TriggerCallbackProccessor) Stop()

Constants

const (
	EXECUTOR = "EXECUTOR"
	ADMIN    = "ADMIN"
)

const (
	DEFAULT_TRIGGER_QUEUE_SIZE = 50
	RETRY_BEAT_TIMEOUT         = 30
)

const (
	CLEAN_IDLE_HOURS = 6
)

const (
	REGISTRY_IDLE_SECOND = 30
)

Types

type ExecutorRegistryProccessor

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

注册处理器

func NewExecutorRegistryProccessor

func NewExecutorRegistryProccessor(appname string, address string) *ExecutorRegistryProccessor

func (*ExecutorRegistryProccessor) Start

func (t *ExecutorRegistryProccessor) Start()

func (*ExecutorRegistryProccessor) Stop

func (t *ExecutorRegistryProccessor) Stop()

type JobLogFileCleanProccessor

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

func NewJobLogFileCleanProccessor

func NewJobLogFileCleanProccessor(logRetentionDays int32, logPath string) *JobLogFileCleanProccessor

func (*JobLogFileCleanProccessor) Start

func (t *JobLogFileCleanProccessor) Start()

func (*JobLogFileCleanProccessor) Stop

func (t *JobLogFileCleanProccessor) Stop()

type TriggerCallbackProccessor

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

触发任务回调处理器

func NewTriggerCallbackProccessor

func NewTriggerCallbackProccessor() *TriggerCallbackProccessor

func (*TriggerCallbackProccessor) PushTriggerCallback

func (t *TriggerCallbackProccessor) PushTriggerCallback(callbackParam HandleCallbackParam)

func (*TriggerCallbackProccessor) Start

func (t *TriggerCallbackProccessor) Start()

func (*TriggerCallbackProccessor) Stop

func (t *TriggerCallbackProccessor) Stop()