execution

package

v0.10.1 Latest Latest Go to latest Published: Jun 14, 2019 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mesg-foundation/core

Links

Open Source Insights

Documentation ¶

Index ¶

type Execution
- func New(service string, parentHash []byte, eventID, taskKey string, ...) *Execution
type Status
- func (s Status) String() (r string)
type StatusError
- func (e StatusError) Error() string

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Execution ¶

type Execution struct {
	Hash        []byte                 `hash:"-"`
	ParentHash  []byte                 `hash:"name:parentHash"`
	EventID     string                 `hash:"name:eventID"`
	Status      Status                 `hash:"-"`
	ServiceHash string                 `hash:"name:serviceHash"`
	TaskKey     string                 `hash:"name:taskKey"`
	Tags        []string               `hash:"name:tags"`
	Inputs      map[string]interface{} `hash:"name:inputs"`
	Outputs     map[string]interface{} `hash:"-"`
	Error       string                 `hash:"-"`
}

Execution stores all informations about executions.

func New ¶ added in v0.4.0

func New(service string, parentHash []byte, eventID, taskKey string, inputs map[string]interface{}, tags []string) *Execution

New returns a new execution. It returns an error if inputs are invalid.

func (*Execution) Complete ¶

func (execution *Execution) Complete(outputs map[string]interface{}) error

Complete changes execution status to completed. It verifies the output. It returns an error if the status is different then InProgress or verification fails.

func (*Execution) Execute ¶

func (execution *Execution) Execute() error

Execute changes executions status to in progres and update its execute time. It returns an error if the status is different then Created.

func (*Execution) Failed ¶ added in v0.6.0

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

Failed changes execution status to failed and puts error information to execution. It returns an error if the status is different then InProgress.

type Status ¶ added in v0.4.0

type Status int

Status stores the state of an execution

const (
	Created Status = iota + 1
	InProgress
	Completed
	Failed
)

Status for an execution Created => The execution is created but not yet processed InProgress => The execution is being processed Completed => The execution is completed

func (Status) String ¶ added in v0.6.0

func (s Status) String() (r string)

type StatusError ¶ added in v0.4.0

type StatusError struct {
	ExpectedStatus Status
	ActualStatus   Status
}

StatusError is an error when the processing is done on en execution with the wrong status

func (StatusError) Error ¶ added in v0.4.0

func (e StatusError) Error() string

Error returns the string representation of error.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL