waits

Documentation

Index

• Constants
• func WaitFromEnvelope(envelope *utils.TypedEnvelope) (flows.Wait, error)
• type FlowWait
  • func (w *FlowWait) Begin(run flows.FlowRun, step flows.Step) error
  • func (w *FlowWait) Default() interface{}
  • func (w *FlowWait) End(run flows.FlowRun, step flows.Step, event flows.Event) error
  • func (w *FlowWait) GetEndEvent(run flows.FlowRun, step flows.Step) (flows.Event, error)
  • func (w *FlowWait) Resolve(key string) interface{}
  • func (w *FlowWait) String() string
  • func (w *FlowWait) Type() string
• type MsgWait
  • func (w *MsgWait) Begin(run flows.FlowRun, step flows.Step) error
  • func (w *MsgWait) Default() interface{}
  • func (w *MsgWait) End(run flows.FlowRun, step flows.Step, event flows.Event) error
  • func (w *MsgWait) GetEndEvent(run flows.FlowRun, step flows.Step) (flows.Event, error)
  • func (w *MsgWait) Resolve(key string) interface{}
  • func (w *MsgWait) String() string
  • func (w *MsgWait) Type() string

Constants

const TypeFlow string = "flow"

const TypeMsg string = "msg"

Functions

func WaitFromEnvelope

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

Types

type FlowWait

type FlowWait struct {
	FlowUUID flows.FlowUUID `json:"flow_uuid"   validate:"required,uuid4"`
}

func (*FlowWait) Begin

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

func (*FlowWait) Default

func (w *FlowWait) Default() interface{}

func (*FlowWait) End

func (w *FlowWait) End(run flows.FlowRun, step flows.Step, event flows.Event) error

func (*FlowWait) GetEndEvent

func (w *FlowWait) GetEndEvent(run flows.FlowRun, step flows.Step) (flows.Event, error)

func (*FlowWait) Resolve

func (w *FlowWait) Resolve(key string) interface{}

func (*FlowWait) String

func (w *FlowWait) String() string

func (*FlowWait) Type

func (w *FlowWait) Type() string

type MsgWait

type MsgWait struct {
	Timeout int `json:"timeout,omitempty"`
}

func (*MsgWait) Begin

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

func (*MsgWait) Default

func (w *MsgWait) Default() interface{}

func (*MsgWait) End

func (w *MsgWait) End(run flows.FlowRun, step flows.Step, event flows.Event) error

func (*MsgWait) GetEndEvent

func (w *MsgWait) GetEndEvent(run flows.FlowRun, step flows.Step) (flows.Event, error)

func (*MsgWait) Resolve

func (w *MsgWait) Resolve(key string) interface{}

func (*MsgWait) String

func (w *MsgWait) String() string

func (*MsgWait) Type

func (w *MsgWait) Type() string