update

Documentation

Index

• type Updater
  • func NewUpdater(db store.DB, agentResolver *agent.Resolver) *Updater
  • func (r *Updater) AddEvent(tenantID string, job *model.Job, description string) (err error)
  • func (r *Updater) AddJob(inputJob *model.Job, description string) (job *model.Job, err error)
  • func (r *Updater) EventAdded(ctx context.Context) (ch <-chan *model.EventEdge, err error)
  • func (r *Updater) UpdateJob(job *model.Job, description string) (err error)

Types

type Updater

type Updater struct {
	*agent.Resolver
	// contains filtered or unexported fields
}

func NewUpdater

func NewUpdater(db store.DB, agentResolver *agent.Resolver) *Updater

func (*Updater) AddEvent

func (r *Updater) AddEvent(tenantID string, job *model.Job, description string) (err error)

func (*Updater) AddJob

func (r *Updater) AddJob(inputJob *model.Job, description string) (job *model.Job, err error)

func (*Updater) EventAdded

func (r *Updater) EventAdded(ctx context.Context) (ch <-chan *model.EventEdge, err error)

func (*Updater) UpdateJob

func (r *Updater) UpdateJob(job *model.Job, description string) (err error)