job

package

v1.0.4 Latest Latest Go to latest Published: Jul 22, 2023 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func NewDistributedJobInfra(redisInfra common.RedisInfra) common.JobInfra

NewDistributedJobInfra 创建分布式job基础设施

func NewStandaloneJobInfra() common.JobInfra

NewStandaloneJobInfra 创建单机式job基础设施

type DistributedJobInfra struct {
	base.BaseInfra // 基础设施基类
	// contains filtered or unexported fields
}

DistributedJobInfra 分布式定时任务基础设施

func (i *DistributedJobInfra) AddTask(name string, expr string, job func() error) error

AddTask 增加分布式定时任务

func (i *DistributedJobInfra) Name() string

Name 基础设施名称

func (i *DistributedJobInfra) RemoveTask(name string) error

RemoveTask 移除分布式定时任务

func (i *DistributedJobInfra) Start(ctx context.Context) error

start 基础设施启动

func (i *DistributedJobInfra) Stop() error

stop 停止基础设施

type StandaloneJobInfra struct {
	base.BaseInfra // 基础设施基类
	// contains filtered or unexported fields
}

StandaloneJobInfra 单机定时任务基础设施

func (i *StandaloneJobInfra) AddTask(name string, expr string, job func() error) error

AddTask 增加单机式定时任务

func (i *StandaloneJobInfra) Name() string

Name 基础设施名称

func (i *StandaloneJobInfra) RemoveTask(name string) error

RemoveTask 移除单机式定时任务

func (i *StandaloneJobInfra) Start(ctx context.Context) error

start 基础设施启动

func (i *StandaloneJobInfra) Stop() error

stop 停止基础设施