job

Documentation

Index

• type CrossplaneResourcesSync
  • func NewCrossplaneResourcesSync(log logging.Logger, frequency string, dbStore *captenstore.Store) (*CrossplaneResourcesSync, error)
  • func (s *CrossplaneResourcesSync) CronSpec() string
  • func (s *CrossplaneResourcesSync) Run()
• type Scheduler
  • func NewScheduler(log logging.Logger) *Scheduler
  • func (t *Scheduler) AddJob(jobName string, job jobHandler) error
  • func (t *Scheduler) GetJobs() map[string]jobHandler
  • func (t *Scheduler) RemoveJob(jobName string) error
  • func (t *Scheduler) Start()
  • func (t *Scheduler) Stop()

Types

type CrossplaneResourcesSync

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

func NewCrossplaneResourcesSync

func NewCrossplaneResourcesSync(log logging.Logger, frequency string, dbStore *captenstore.Store) (*CrossplaneResourcesSync, error)

func (*CrossplaneResourcesSync) CronSpec

func (s *CrossplaneResourcesSync) CronSpec() string

func (*CrossplaneResourcesSync) Run

func (s *CrossplaneResourcesSync) Run()

type Scheduler

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

func NewScheduler

func NewScheduler(log logging.Logger) *Scheduler

func (*Scheduler) AddJob

func (t *Scheduler) AddJob(jobName string, job jobHandler) error

func (*Scheduler) GetJobs

func (t *Scheduler) GetJobs() map[string]jobHandler

func (*Scheduler) RemoveJob

func (t *Scheduler) RemoveJob(jobName string) error

RemoveJob ...

func (*Scheduler) Start

func (t *Scheduler) Start()

func (*Scheduler) Stop

func (t *Scheduler) Stop()