engine

Documentation

Index

• func NewFlowEnvironment(env utils.Environment, flowList []flows.Flow, runList []flows.FlowRun, ...) flows.FlowEnvironment
• func ResumeFlow(env flows.FlowEnvironment, run flows.FlowRun, event flows.Event) (flows.Session, error)
• func StartFlow(env flows.FlowEnvironment, flow flows.Flow, contact *flows.Contact, ...) (flows.Session, error)

Functions

func NewFlowEnvironment

func NewFlowEnvironment(env utils.Environment, flowList []flows.Flow, runList []flows.FlowRun, contactList []*flows.Contact) flows.FlowEnvironment

NewFlowEnvironment creates and returns a new FlowEnvironment given the passed in environment and flow map

func ResumeFlow

func ResumeFlow(env flows.FlowEnvironment, run flows.FlowRun, event flows.Event) (flows.Session, error)

ResumeFlow resumes our flow from the last step

func StartFlow

func StartFlow(env flows.FlowEnvironment, flow flows.Flow, contact *flows.Contact, parent flows.FlowRun, input flows.Input, extra json.RawMessage) (flows.Session, error)

StartFlow starts the flow for the passed in contact, returning the created FlowRun