Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDistributedJobInfra ¶
func NewDistributedJobInfra(redisInfra common.RedisInfra) common.JobInfra
NewDistributedJobInfra 创建分布式job基础设施
func NewStandaloneJobInfra ¶
NewStandaloneJobInfra 创建单机式job基础设施
Types ¶
type DistributedJobInfra ¶
type DistributedJobInfra struct { base.BaseInfra // 基础设施基类 // contains filtered or unexported fields }
DistributedJobInfra 分布式定时任务基础设施
func (*DistributedJobInfra) AddTask ¶
func (i *DistributedJobInfra) AddTask(name string, expr string, job func() error) error
AddTask 增加分布式定时任务
func (*DistributedJobInfra) RemoveTask ¶
func (i *DistributedJobInfra) RemoveTask(name string) error
RemoveTask 移除分布式定时任务
type StandaloneJobInfra ¶
type StandaloneJobInfra struct { base.BaseInfra // 基础设施基类 // contains filtered or unexported fields }
StandaloneJobInfra 单机定时任务基础设施
func (*StandaloneJobInfra) AddTask ¶
func (i *StandaloneJobInfra) AddTask(name string, expr string, job func() error) error
AddTask 增加单机式定时任务
func (*StandaloneJobInfra) RemoveTask ¶
func (i *StandaloneJobInfra) RemoveTask(name string) error
RemoveTask 移除单机式定时任务
Click to show internal directories.
Click to hide internal directories.