waits

package
v0.14.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 6, 2018 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const TypeMsg string = "msg"
View Source
const TypeNothing string = "nothing"

Variables

This section is empty.

Functions

func ReadWait added in v0.11.0

func ReadWait(envelope *utils.TypedEnvelope) (flows.Wait, error)

ReadWait reads a wait from the given typed envelope

func RegisterType added in v0.11.0

func RegisterType(name string, initFunc func() flows.Wait)

RegisterType registers a new type of wait

Types

type MsgWait

type MsgWait struct {
	// contains filtered or unexported fields
}

MsgWait is a wait which waits for an incoming message (i.e. a msg_received event)

func NewMsgWait added in v0.4.0

func NewMsgWait(timeout *int) *MsgWait

NewMsgWait creates a new message wait

func (*MsgWait) Begin

func (w *MsgWait) Begin(run flows.FlowRun, step flows.Step)

Begin beings waiting at this wait

func (*MsgWait) CanResume added in v0.4.0

func (w *MsgWait) CanResume(callerEvents []flows.Event) bool

CanResume returns true if a message event has been received

func (*MsgWait) Timeout

func (w *MsgWait) Timeout() *int

Timeout returns the timeout of this wait in seconds or nil if no timeout is set

func (*MsgWait) TimeoutOn added in v0.9.10

func (w *MsgWait) TimeoutOn() *time.Time

TimeoutOn returns when this wait times out

func (*MsgWait) Type

func (w *MsgWait) Type() string

Type returns the type of this wait

type NothingWait added in v0.4.0

type NothingWait struct {
	// contains filtered or unexported fields
}

NothingWait is a wait which waits for nothing.. i.e. a chance for the caller to do something and resume immediately

func (*NothingWait) Begin added in v0.4.0

func (w *NothingWait) Begin(run flows.FlowRun, step flows.Step)

Begin beings waiting at this wait

func (*NothingWait) CanResume added in v0.4.0

func (w *NothingWait) CanResume(callerEvents []flows.Event) bool

CanResume always returns true for a nothing wait because it's not waiting for anything

func (*NothingWait) Timeout added in v0.9.10

func (w *NothingWait) Timeout() *int

Timeout would return the timeout of this wait for wait types that do that

func (*NothingWait) TimeoutOn added in v0.9.10

func (w *NothingWait) TimeoutOn() *time.Time

TimeoutOn would return when this wait times out for wait types that do that

func (*NothingWait) Type added in v0.4.0

func (w *NothingWait) Type() string

Type returns the type of this wait

Jump to

Keyboard shortcuts

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