impl

Documentation

Index

• type CronJobServiceImpl
  • func (i *CronJobServiceImpl) AddCronJob(ctx context.Context, in *cronjob.CronJobSpec) (*cronjob.CronJob, error)
  • func (i *CronJobServiceImpl) Close(ctx context.Context)
  • func (i *CronJobServiceImpl) DeleteCronJob(ctx context.Context, in *cronjob.DeleteCronJobRequest) (*cronjob.CronJob, error)
  • func (i *CronJobServiceImpl) DescribeCronJob(ctx context.Context, in *cronjob.DescribeCronJobRequest) (*cronjob.CronJob, error)
  • func (i *CronJobServiceImpl) Init() error
  • func (i *CronJobServiceImpl) Name() string
  • func (i *CronJobServiceImpl) QueryCronJob(ctx context.Context, in *cronjob.QueryCronJobRequest) (*types.Set[*cronjob.CronJob], error)
  • func (c *CronJobServiceImpl) Run(ctx context.Context) error
  • func (i *CronJobServiceImpl) UpdateCronJob(ctx context.Context, in *cronjob.UpdateCronJobRequest) (*cronjob.CronJob, error)

Types

type CronJobServiceImpl

type CronJobServiceImpl struct {
	ioc.ObjectImpl

	// 启用更新队列
	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"`
	// contains filtered or unexported fields
}

func (*CronJobServiceImpl) AddCronJob

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

AddCronJob implements cronjob.Service.

func (*CronJobServiceImpl) Close

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

func (*CronJobServiceImpl) DeleteCronJob

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

DeleteCronJob implements cronjob.Service.

func (*CronJobServiceImpl) DescribeCronJob

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

DescribeCronJob implements cronjob.Service.

func (*CronJobServiceImpl) Init

func (i *CronJobServiceImpl) Init() error

func (*CronJobServiceImpl) Name

func (i *CronJobServiceImpl) Name() string

func (*CronJobServiceImpl) QueryCronJob

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

QueryCronJob implements cronjob.Service.

func (*CronJobServiceImpl) Run

func (c *CronJobServiceImpl) Run(ctx context.Context) error

读取消息，处理消息

func (*CronJobServiceImpl) UpdateCronJob

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

UpdateCronJob implements cronjob.Service.