scheduler

Documentation

Index

• type BaseScheduler
  • func NewBaseScheduler(IScheduler IScheduler) *BaseScheduler
  • func (b *BaseScheduler) Do(params ...interface{})
• type IScheduler
• type RevealPipelineStatusScheduler
  • func NewRevealPipelineStatusScheduler() *RevealPipelineStatusScheduler
  • func (r *RevealPipelineStatusScheduler) Enable(params ...interface{}) (bool, string)
  • func (r *RevealPipelineStatusScheduler) Exec(params ...interface{})
• type Scheduler
  • func NewScheduler() (*Scheduler, error)
  • func (s *Scheduler) Start()
• type SmembersPipelineStatusScheduler
  • func NewSmembersPipelineStatusScheduler() *SmembersPipelineStatusScheduler
  • func (s *SmembersPipelineStatusScheduler) Enable(params ...interface{}) (bool, string)
  • func (s *SmembersPipelineStatusScheduler) Exec(params ...interface{})
  • func (s *SmembersPipelineStatusScheduler) SwitchPublisher(status pipeline.Status) *cony.Publisher

Types

type BaseScheduler

type BaseScheduler struct {
	IScheduler IScheduler
}

func NewBaseScheduler

func NewBaseScheduler(IScheduler IScheduler) *BaseScheduler

func (*BaseScheduler) Do

func (b *BaseScheduler) Do(params ...interface{})

type IScheduler

type IScheduler interface {
	Enable(params ...interface{}) (bool, string)
	Exec(params ...interface{})
}

type RevealPipelineStatusScheduler

type RevealPipelineStatusScheduler struct {
}

func NewRevealPipelineStatusScheduler

func NewRevealPipelineStatusScheduler() *RevealPipelineStatusScheduler

func (*RevealPipelineStatusScheduler) Enable

func (r *RevealPipelineStatusScheduler) Enable(params ...interface{}) (bool, string)

func (*RevealPipelineStatusScheduler) Exec

func (r *RevealPipelineStatusScheduler) Exec(params ...interface{})

type Scheduler

type Scheduler struct {
	Scheduler *gocron.Scheduler
}

func NewScheduler

func NewScheduler() (*Scheduler, error)

func (*Scheduler) Start

func (s *Scheduler) Start()

type SmembersPipelineStatusScheduler

type SmembersPipelineStatusScheduler struct {
}

func NewSmembersPipelineStatusScheduler

func NewSmembersPipelineStatusScheduler() *SmembersPipelineStatusScheduler

func (*SmembersPipelineStatusScheduler) Enable

func (s *SmembersPipelineStatusScheduler) Enable(params ...interface{}) (bool, string)

func (*SmembersPipelineStatusScheduler) Exec

func (s *SmembersPipelineStatusScheduler) Exec(params ...interface{})

func (*SmembersPipelineStatusScheduler) SwitchPublisher

func (s *SmembersPipelineStatusScheduler) SwitchPublisher(status pipeline.Status) *cony.Publisher