schedule

Documentation

Index

• type ScheduleAPI
  • func New(ctx context.Context, logger *zap.Logger, storage storageTY.Plugin, ...) *ScheduleAPI
  • func (sh *ScheduleAPI) Add(cfg *schedulerTY.Config) error
  • func (sh *ScheduleAPI) Delete(IDs []string) (int64, error)
  • func (sh *ScheduleAPI) Disable(ids []string) error
  • func (sh *ScheduleAPI) Enable(ids []string) error
  • func (sh *ScheduleAPI) Get(filters []storageTY.Filter) (*schedulerTY.Config, error)
  • func (sh *ScheduleAPI) GetByID(id string) (*schedulerTY.Config, error)
  • func (sh *ScheduleAPI) GetEntityInterface() interface{}
  • func (sh *ScheduleAPI) Import(data interface{}) error
  • func (sh *ScheduleAPI) List(filters []storageTY.Filter, pagination *storageTY.Pagination) (*storageTY.Result, error)
  • func (sh *ScheduleAPI) LoadAll()
  • func (sh *ScheduleAPI) Reload(ids []string) error
  • func (sh *ScheduleAPI) Remove(cfg *schedulerTY.Config) error
  • func (sh *ScheduleAPI) Save(schedule *schedulerTY.Config) error
  • func (sh *ScheduleAPI) SaveAndReload(cfg *schedulerTY.Config) error
  • func (sh *ScheduleAPI) SetState(id string, state *schedulerTY.State) error
  • func (sh *ScheduleAPI) UnloadAll()

Types

type ScheduleAPI

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

func New

func New(ctx context.Context, logger *zap.Logger, storage storageTY.Plugin, bus busTY.Plugin) *ScheduleAPI

func (*ScheduleAPI) Add

func (sh *ScheduleAPI) Add(cfg *schedulerTY.Config) error

Add scheduler

func (*ScheduleAPI) Delete

func (sh *ScheduleAPI) Delete(IDs []string) (int64, error)

Delete schedulers

func (*ScheduleAPI) Disable

func (sh *ScheduleAPI) Disable(ids []string) error

Disable scheduler

func (*ScheduleAPI) Enable

func (sh *ScheduleAPI) Enable(ids []string) error

Enable scheduler

func (*ScheduleAPI) Get

func (sh *ScheduleAPI) Get(filters []storageTY.Filter) (*schedulerTY.Config, error)

Get returns a scheduler

func (*ScheduleAPI) GetByID

func (sh *ScheduleAPI) GetByID(id string) (*schedulerTY.Config, error)

GetByID returns a scheduler by id

func (*ScheduleAPI) GetEntityInterface

func (sh *ScheduleAPI) GetEntityInterface() interface{}

func (*ScheduleAPI) Import

func (sh *ScheduleAPI) Import(data interface{}) error

func (*ScheduleAPI) List

func (sh *ScheduleAPI) List(filters []storageTY.Filter, pagination *storageTY.Pagination) (*storageTY.Result, error)

List by filter and pagination

func (*ScheduleAPI) LoadAll

func (sh *ScheduleAPI) LoadAll()

LoadAll makes schedulers alive

func (*ScheduleAPI) Reload

func (sh *ScheduleAPI) Reload(ids []string) error

Reload scheduler

func (*ScheduleAPI) Remove

func (sh *ScheduleAPI) Remove(cfg *schedulerTY.Config) error

Remove scheduler

func (*ScheduleAPI) Save

func (sh *ScheduleAPI) Save(schedule *schedulerTY.Config) error

Save a scheduler details

func (*ScheduleAPI) SaveAndReload

func (sh *ScheduleAPI) SaveAndReload(cfg *schedulerTY.Config) error

SaveAndReload scheduler

func (*ScheduleAPI) SetState

func (sh *ScheduleAPI) SetState(id string, state *schedulerTY.State) error

SetState Updates state data

func (*ScheduleAPI) UnloadAll

func (sh *ScheduleAPI) UnloadAll()

UnloadAll makes stop all schedulers