impl

Documentation

Index

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

Types

type CronServiceImpl

type CronServiceImpl struct {
	ioc.ObjectImpl

	// 当前这个消费者 配置的topic
	UpdateTopic []string `toml:"update_topic" json:"update_topic" yaml:"update_topic"  env:"UPDATE_TOPIC"`
	// contains filtered or unexported fields
}

func (*CronServiceImpl) AddCronJob

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

AddCronJob implements cronjob.Service.

func (*CronServiceImpl) Close

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

func (*CronServiceImpl) DeleteCronJob

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

DeleteCronJob implements cronjob.Service.

func (*CronServiceImpl) DescribeCronJob

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

DescribeCronJob implements cronjob.Service.

func (*CronServiceImpl) Init

func (i *CronServiceImpl) Init() error

func (*CronServiceImpl) Name

func (i *CronServiceImpl) Name() string

func (*CronServiceImpl) QueryCronJob

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

QueryCronJob implements cronjob.Service.

func (*CronServiceImpl) Run

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

读取消息，处理消息

func (*CronServiceImpl) UpdateCronJob

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

UpdateCronJob implements cronjob.Service.