crondsvc

Documentation

Index

• type CrondSvc
  • func New(dbClient *dbclient.Client, bdl *bundle.Bundle, js jsonstore.JsonStore) *CrondSvc
  • func (s *CrondSvc) AddIntoPipelineCrond(cronID uint64) error
  • func (s *CrondSvc) CleanBuildCacheImages()
  • func (s *CrondSvc) CrondSnapshot() []string
  • func (s *CrondSvc) DeletePipelineCrond(cronID uint64) error
  • func (s *CrondSvc) ListenCrond(ctx context.Context, pipelineCronFunc func(id uint64))
  • func (s *CrondSvc) ReloadCrond(ctx context.Context, pipelineCronFunc func(uint64)) ([]string, error)

Types

type CrondSvc

type CrondSvc struct {
	// contains filtered or unexported fields
}

func New

func New(dbClient *dbclient.Client, bdl *bundle.Bundle, js jsonstore.JsonStore) *CrondSvc

func (*CrondSvc) AddIntoPipelineCrond

func (s *CrondSvc) AddIntoPipelineCrond(cronID uint64) error

add the timing task of a certain timing id todo Multi-instance watch etcd add key

func (*CrondSvc) CleanBuildCacheImages

func (s *CrondSvc) CleanBuildCacheImages()

func (*CrondSvc) CrondSnapshot

func (s *CrondSvc) CrondSnapshot() []string

func (*CrondSvc) DeletePipelineCrond

func (s *CrondSvc) DeletePipelineCrond(cronID uint64) error

delete the timing task of a certain timing id todo Multi-instance watch etcd delete key

func (*CrondSvc) ListenCrond

func (s *CrondSvc) ListenCrond(ctx context.Context, pipelineCronFunc func(id uint64))

Listen the key in the channel decide to delete or add a scheduled task according to the prefix of the key

func (*CrondSvc) ReloadCrond

func (s *CrondSvc) ReloadCrond(ctx context.Context, pipelineCronFunc func(uint64)) ([]string, error)

ReloadCrond 触发当前 crond 实例更新任务.