Documentation ¶
Index ¶
Constants ¶
View Source
const ( EXECUTOR = "EXECUTOR" ADMIN = "ADMIN" )
View Source
const ( DEFAULT_TRIGGER_QUEUE_SIZE = 50 RETRY_BEAT_TIMEOUT = 30 )
View Source
const (
CLEAN_IDLE_HOURS = 6
)
View Source
const (
REGISTRY_IDLE_SECOND = 30
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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()
Click to show internal directories.
Click to hide internal directories.