pipelinecronsvc

Documentation

Index

• type PipelineCronSvc
  • func New(dbClient *dbclient.Client, crondSvc *crondsvc.CrondSvc) *PipelineCronSvc
  • func (s *PipelineCronSvc) Create(req apistructs.PipelineCronCreateRequest) (*spec.PipelineCron, error)
  • func (s *PipelineCronSvc) Delete(cronID uint64) error
  • func (s *PipelineCronSvc) Get(cronID uint64) (*spec.PipelineCron, error)
  • func (s *PipelineCronSvc) Paging(req apistructs.PipelineCronPagingRequest) ([]spec.PipelineCron, int64, error)
  • func (s *PipelineCronSvc) PipelineCronUpdate(req apistructs.PipelineCronUpdateRequest) error
  • func (s *PipelineCronSvc) Start(cronID uint64) (*spec.PipelineCron, error)
  • func (s *PipelineCronSvc) Stop(cronID uint64) (*spec.PipelineCron, error)

Types

type PipelineCronSvc

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

func New

func New(dbClient *dbclient.Client, crondSvc *crondsvc.CrondSvc) *PipelineCronSvc

func (*PipelineCronSvc) Create

func (s *PipelineCronSvc) Create(req apistructs.PipelineCronCreateRequest) (*spec.PipelineCron, error)

func (*PipelineCronSvc) Delete

func (s *PipelineCronSvc) Delete(cronID uint64) error

func (*PipelineCronSvc) Get

func (s *PipelineCronSvc) Get(cronID uint64) (*spec.PipelineCron, error)

func (*PipelineCronSvc) Paging

func (s *PipelineCronSvc) Paging(req apistructs.PipelineCronPagingRequest) ([]spec.PipelineCron, int64, error)

func (*PipelineCronSvc) PipelineCronUpdate

func (s *PipelineCronSvc) PipelineCronUpdate(req apistructs.PipelineCronUpdateRequest) error

PipelineCronUpdate pipeline cron update

func (*PipelineCronSvc) Start

func (s *PipelineCronSvc) Start(cronID uint64) (*spec.PipelineCron, error)

func (*PipelineCronSvc) Stop

func (s *PipelineCronSvc) Stop(cronID uint64) (*spec.PipelineCron, error)