proccess

package
v0.0.0-...-7eb9a9b Latest Latest
Warning

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

Go to latest
Published: Nov 24, 2022 License: GPL-2.0 Imports: 14 Imported by: 0

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()

Jump to

Keyboard shortcuts

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