task

Documentation

Index

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

Types

type TaskAPI

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

func New

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

func (*TaskAPI) Add

func (t *TaskAPI) Add(task *taskTY.Config) error

Add task

func (*TaskAPI) Delete

func (t *TaskAPI) Delete(IDs []string) (int64, error)

Delete tasks

func (*TaskAPI) Disable

func (t *TaskAPI) Disable(ids []string) error

Disable task

func (*TaskAPI) Enable

func (t *TaskAPI) Enable(ids []string) error

Enable task

func (*TaskAPI) Get

func (t *TaskAPI) Get(filters []storageTY.Filter) (*taskTY.Config, error)

Get returns a task

func (*TaskAPI) GetByID

func (t *TaskAPI) GetByID(id string) (*taskTY.Config, error)

GetByID returns a task by id

func (*TaskAPI) GetEntityInterface

func (t *TaskAPI) GetEntityInterface() interface{}

func (*TaskAPI) Import

func (t *TaskAPI) Import(data interface{}) error

func (*TaskAPI) List

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

List by filter and pagination

func (*TaskAPI) LoadAll

func (t *TaskAPI) LoadAll()

LoadAll makes tasks alive

func (*TaskAPI) Reload

func (t *TaskAPI) Reload(ids []string) error

Reload task

func (*TaskAPI) Remove

func (t *TaskAPI) Remove(task *taskTY.Config) error

Remove task

func (*TaskAPI) Save

func (t *TaskAPI) Save(task *taskTY.Config) error

Save a task details

func (*TaskAPI) SaveAndReload

func (t *TaskAPI) SaveAndReload(cfg *taskTY.Config) error

SaveAndReload task

func (*TaskAPI) SetState

func (t *TaskAPI) SetState(id string, state *taskTY.State) error

SetState Updates state data

func (*TaskAPI) UnloadAll

func (t *TaskAPI) UnloadAll()

UnloadAll makes stop all tasks