coordinator

Documentation

Index

• type Coordinator
  • func New(logger *zap.Logger, scheduler backend.Scheduler, st backend.Store, ...) *Coordinator
  • func (c *Coordinator) CancelRun(ctx context.Context, taskID, runID platform.ID) error
  • func (c *Coordinator) CreateTask(ctx context.Context, req backend.CreateTaskRequest) (platform.ID, error)
  • func (c *Coordinator) DeleteOrg(ctx context.Context, orgID platform.ID) error
  • func (c *Coordinator) DeleteTask(ctx context.Context, id platform.ID) (deleted bool, err error)
  • func (c *Coordinator) DeleteUser(ctx context.Context, userID platform.ID) error
  • func (c *Coordinator) UpdateTask(ctx context.Context, req backend.UpdateTaskRequest) (backend.UpdateTaskResult, error)
• type Option
  • func WithLimit(i int) Option

Types

type Coordinator

type Coordinator struct {
	backend.Store
	// contains filtered or unexported fields
}

func New

func New(logger *zap.Logger, scheduler backend.Scheduler, st backend.Store, opts ...Option) *Coordinator

func (*Coordinator) CancelRun

func (c *Coordinator) CancelRun(ctx context.Context, taskID, runID platform.ID) error

func (*Coordinator) CreateTask

func (c *Coordinator) CreateTask(ctx context.Context, req backend.CreateTaskRequest) (platform.ID, error)

func (*Coordinator) DeleteOrg

func (c *Coordinator) DeleteOrg(ctx context.Context, orgID platform.ID) error

func (*Coordinator) DeleteTask

func (c *Coordinator) DeleteTask(ctx context.Context, id platform.ID) (deleted bool, err error)

func (*Coordinator) DeleteUser

func (c *Coordinator) DeleteUser(ctx context.Context, userID platform.ID) error

func (*Coordinator) UpdateTask

func (c *Coordinator) UpdateTask(ctx context.Context, req backend.UpdateTaskRequest) (backend.UpdateTaskResult, error)

type Option

type Option func(*Coordinator)

func WithLimit

func WithLimit(i int) Option