impl

package
v0.0.21 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2025 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CronJobServiceImpl added in v0.0.17 

type CronJobServiceImpl struct {
	ioc.ObjectImpl

	// 随机节点名, 用于单节点调试
	RandomNodeName bool `toml:"random_node_name" json:"random_node_name" yaml:"random_node_name"  env:"RANDOM_NODE_NAME"`
	// 启用更新队列
	EnableUpdate bool `toml:"enable_update" json:"enable_update" yaml:"enable_update"  env:"ENABLE_UPDATE"`
	// 当前这个消费者 配置的topic
	UpdateTopic string `toml:"update_topic" json:"update_topic" yaml:"update_topic"  env:"UPDATE_TOPIC"`
	// 执行时锁的TTL
	TaskLockTTL string `toml:"task_lock_ttl" json:"task_lock_ttl" yaml:"task_lock_ttl"  env:"TASK_LOCK_TTL"`
	// contains filtered or unexported fields
}

func (*CronJobServiceImpl) AddCronJob added in v0.0.17 

func (c *CronJobServiceImpl) AddCronJob(ctx context.Context, in *cronjob.CronJobSpec) (*cronjob.CronJob, error)

AddCronJob implements cronjob.Service.

func (*CronJobServiceImpl) Close added in v0.0.17 

func (i *CronJobServiceImpl) Close(ctx context.Context)

func (*CronJobServiceImpl) DeleteCronJob added in v0.0.17 

func (i *CronJobServiceImpl) DeleteCronJob(ctx context.Context, in *cronjob.DeleteCronJobRequest) (*cronjob.CronJob, error)

DeleteCronJob implements cronjob.Service.

func (*CronJobServiceImpl) DescribeCronJob added in v0.0.17 

func (i *CronJobServiceImpl) DescribeCronJob(ctx context.Context, in *cronjob.DescribeCronJobRequest) (*cronjob.CronJob, error)

DescribeCronJob implements cronjob.Service.

func (*CronJobServiceImpl) HandleUpdateEvents added in v0.0.21 

func (c *CronJobServiceImpl) HandleUpdateEvents(ctx context.Context)

处理CronJob更新队列

func (*CronJobServiceImpl) Init added in v0.0.17 

func (i *CronJobServiceImpl) Init() error

func (*CronJobServiceImpl) Name added in v0.0.17 

func (i *CronJobServiceImpl) Name() string

func (*CronJobServiceImpl) Priority added in v0.0.21 

func (i *CronJobServiceImpl) Priority() int

func (*CronJobServiceImpl) QueryCronJob added in v0.0.17 

func (i *CronJobServiceImpl) QueryCronJob(ctx context.Context, in *cronjob.QueryCronJobRequest) (*types.Set[*cronjob.CronJob], error)

QueryCronJob implements cronjob.Service.

func (*CronJobServiceImpl) UpdateCronJob added in v0.0.17 

func (i *CronJobServiceImpl) UpdateCronJob(ctx context.Context, in *cronjob.UpdateCronJobRequest) (*cronjob.CronJob, error)

UpdateCronJob implements cronjob.Service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.