execution

Documentation

Index

• type Execution
  • func Create(service *service.Service, task string, inputs interface{}) (execution *Execution, err error)
  • func InProgress(ID string) (execution *Execution)
  • func (execution *Execution) Complete(output string, data interface{}) (err error)
  • func (execution *Execution) Execute() (err error)

Types

type Execution

type Execution struct {
	ID                string
	Service           *service.Service
	Task              string
	CreatedAt         time.Time
	ExecutedAt        time.Time
	ExecutionDuration time.Duration
	Inputs            interface{}
	Output            string
	OutputData        interface{}
}

Execution is a type that store all informations about executions

func Create

func Create(service *service.Service, task string, inputs interface{}) (execution *Execution, err error)

Create an execution with a unique ID and put it in the pending list

func InProgress

func InProgress(ID string) (execution *Execution)

InProgress returns the matching in progress execution if exists

func (*Execution) Complete

func (execution *Execution) Complete(output string, data interface{}) (err error)

Complete mark an execution as complete and put it in the list of processed tasks

func (*Execution) Execute

func (execution *Execution) Execute() (err error)

Execute moves an exection from the pending to the in progress queue and publish the job for processing