resumes

Jul 18, 2022

Changes in this version

+ const TypeDial

+ func RegisteredTypes() map[string]ReadFunc

+ type Context struct

+ type DialResume struct

+ func NewDial(env envs.Environment, contact *flows.Contact, dial *flows.Dial) *DialResume

+ func (r *DialResume) Apply(run flows.Run, logEvent flows.EventCallback)

+ func (r *DialResume) Contact() *flows.Contact

+ func (r *DialResume) Context(env envs.Environment) map[string]types.XValue

+ func (r *DialResume) Environment() envs.Environment

+ func (r *DialResume) MarshalJSON() ([]byte, error)

+ func (r *DialResume) ResumedOn() time.Time

+ func (r *DialResume) Type() string

type MsgResume

+ func NewMsg(env envs.Environment, contact *flows.Contact, msg *flows.MsgIn) *MsgResume

+ func (r *MsgResume) Context(env envs.Environment) map[string]types.XValue

+ func (r *MsgResume) Msg() *flows.MsgIn

+ type ReadFunc func(flows.SessionAssets, json.RawMessage, assets.MissingCallback) (flows.Resume, error)

type RunExpirationResume

+ func NewRunExpiration(env envs.Environment, contact *flows.Contact) *RunExpirationResume

+ func (r *RunExpirationResume) Context(env envs.Environment) map[string]types.XValue

type WaitTimeoutResume

+ func NewWaitTimeout(env envs.Environment, contact *flows.Contact) *WaitTimeoutResume

+ func (r *WaitTimeoutResume) Context(env envs.Environment) map[string]types.XValue

Oct 13, 2018

Changes in this version

type MsgResume

+ func (r *MsgResume) MarshalJSON() ([]byte, error)

type RunExpirationResume

+ func (r *RunExpirationResume) MarshalJSON() ([]byte, error)

type WaitTimeoutResume

+ func (r *WaitTimeoutResume) MarshalJSON() ([]byte, error)

Oct 3, 2018

Changes in this version

+ const TypeMsg

+ const TypeRunExpiration

+ const TypeWaitTimeout

+ func ReadMsgResume(session flows.Session, data json.RawMessage) (flows.Resume, error)

+ func ReadResume(session flows.Session, envelope *utils.TypedEnvelope) (flows.Resume, error)

+ func ReadRunExpirationResume(session flows.Session, data json.RawMessage) (flows.Resume, error)

+ func ReadWaitTimeoutResume(session flows.Session, data json.RawMessage) (flows.Resume, error)

+ func RegisterType(name string, f readFunc)

+ type MsgResume struct

+ func NewMsgResume(env utils.Environment, contact *flows.Contact, msg *flows.MsgIn) *MsgResume

+ func (r *MsgResume) Apply(run flows.FlowRun, step flows.Step) error

+ func (r *MsgResume) Contact() *flows.Contact

+ func (r *MsgResume) Environment() utils.Environment

+ func (r *MsgResume) ResumedOn() time.Time

+ func (r *MsgResume) Type() string

+ type RunExpirationResume struct

+ func NewRunExpirationResume(env utils.Environment, contact *flows.Contact) *RunExpirationResume

+ func (r *RunExpirationResume) Apply(run flows.FlowRun, step flows.Step) error

+ func (r *RunExpirationResume) Contact() *flows.Contact

+ func (r *RunExpirationResume) Environment() utils.Environment

+ func (r *RunExpirationResume) ResumedOn() time.Time

+ func (r *RunExpirationResume) Type() string

+ type WaitTimeoutResume struct

+ func NewWaitTimeoutResume(env utils.Environment, contact *flows.Contact) *WaitTimeoutResume

+ func (r *WaitTimeoutResume) Apply(run flows.FlowRun, step flows.Step) error

+ func (r *WaitTimeoutResume) Contact() *flows.Contact

+ func (r *WaitTimeoutResume) Environment() utils.Environment

+ func (r *WaitTimeoutResume) ResumedOn() time.Time

+ func (r *WaitTimeoutResume) Type() string