execution

Jun 9, 2020

Changes in this version

type Execution

+ Start int64

+ Stop int64

+ func (execution *Execution) GetDuration() int64

Mar 17, 2020

Changes in this version

type Execution

+ Address github_com_cosmos_cosmos_sdk_types.AccAddress

+ Emitters []*Execution_Emitter

+ func (execution *Execution) Fail(err error) error

+ type Execution_Emitter struct

+ BlockHeight int64

+ RunnerHash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Execution_Emitter) Descriptor() ([]byte, []int)

+ func (*Execution_Emitter) ProtoMessage()

+ func (m *Execution_Emitter) Reset()

+ func (m *Execution_Emitter) String() string

+ func (m *Execution_Emitter) XXX_DiscardUnknown()

+ func (m *Execution_Emitter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Execution_Emitter) XXX_Merge(src proto.Message)

+ func (m *Execution_Emitter) XXX_Size() int

+ func (m *Execution_Emitter) XXX_Unmarshal(b []byte) error

+ func (this *Execution_Emitter) Equal(that interface{}) bool

type Status

+ const Status_Proposed

Mar 2, 2020

Changes in this version

+ type ByBlockHeight []*Execution

+ func (a ByBlockHeight) Len() int

+ func (a ByBlockHeight) Less(i, j int) bool

+ func (a ByBlockHeight) Swap(i, j int)

type Execution

+ BlockHeight int64

+ Price string

Dec 26, 2019

Changes in this version

type Execution

+ NodeKey string

Nov 26, 2019

Changes in this version

type Execution

+ ExecutorHash github_com_mesg_foundation_engine_hash.Hash

Sep 6, 2019

Changes in this version

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

type Execution

+ ProcessHash github_com_mesg_foundation_engine_hash.Hash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Execution) Descriptor() ([]byte, []int)

+ func (*Execution) ProtoMessage()

+ func (m *Execution) Reset()

+ func (m *Execution) String() string

+ func (m *Execution) XXX_DiscardUnknown()

+ func (m *Execution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Execution) XXX_Merge(src proto.Message)

+ func (m *Execution) XXX_Size() int

+ func (m *Execution) XXX_Unmarshal(b []byte) error

+ func (this *Execution) Equal(that interface{}) bool

type Status

+ const Status_Completed

+ const Status_Created

+ const Status_Failed

+ const Status_InProgress

+ const Status_Unknown

+ func (Status) EnumDescriptor() ([]byte, []int)

Aug 16, 2019

Changes in this version

type Execution

+ StepID string

+ WorkflowHash hash.Hash

Jul 5, 2019

Changes in this version

type Execution

+ Error string

+ EventHash hash.Hash

+ Hash hash.Hash

+ InstanceHash hash.Hash

+ Outputs map[string]interface{}

+ ParentHash hash.Hash

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

type Status

+ const Failed

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

Nov 2, 2018

Changes in this version

type Execution

+ EventID string

+ OutputKey string

+ Status Status

+ TaskKey string

+ func New(service *service.Service, eventID string, taskKey string, ...) (*Execution, error)

+ type Status int

+ const Completed

+ const Created

+ type StatusError struct

+ ActualStatus Status

+ ExpectedStatus Status

+ func (e StatusError) Error() string

Aug 20, 2018

Changes in this version

type Execution

+ Tags []string

+ type NotInQueueError struct

+ ID string

+ Queue string

+ func (e *NotInQueueError) Error() string

Jul 4, 2018

Changes in this version

+ type Execution struct

+ CreatedAt time.Time

+ ExecutedAt time.Time

+ ExecutionDuration time.Duration

+ ID string

+ Inputs interface{}

+ Output string

+ OutputData interface{}

+ Service *service.Service

+ Task string

+ 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)