flows

Jul 18, 2022

Changes in this version

+ const RedactionMask

+ var EmptyHistory = &SessionHistory

+ var RunContextTopLevels = []string

+ func ContactQueryEscaping(s string) string

+ func ContextFunc(env envs.Environment, fn func(envs.Environment) map[string]types.XValue) *types.XObject

+ func NewEnvironment(base envs.Environment, la *LocationAssets) envs.Environment

+ type AirtimeService interface

+ Transfer func(sender urns.URN, recipient urns.URN, amounts map[string]decimal.Decimal, ...) (*AirtimeTransfer, error)

+ type AirtimeTransfer struct

+ ActualAmount decimal.Decimal

+ Currency string

+ DesiredAmount decimal.Decimal

+ Recipient urns.URN

+ Sender urns.URN

+ UUID uuids.UUID

+ type AirtimeTransferStatus string

+ const AirtimeTransferStatusFailed

+ const AirtimeTransferStatusSuccess

type BaseMsg

+ func (m *BaseMsg) SetID(id MsgID)

+ func (m *BaseMsg) SetURN(urn urns.URN)

+ type CallStatus string

+ const CallStatusConnectionError

+ const CallStatusResponseError

+ const CallStatusSubscriberGone

+ const CallStatusSuccess

+ func HTTPStatusFromCode(t *httpx.Trace) CallStatus

+ type Category interface

+ ExitUUID func() ExitUUID

+ Name func() string

+ UUID func() CategoryUUID

+ type CategoryUUID uuids.UUID

type Channel

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

+ type Classification struct

+ Entities map[string][]ExtractedEntity

+ Intents []ExtractedIntent

+ type ClassificationService interface

+ Classify func(env envs.Environment, input string, logHTTP HTTPLogCallback) (*Classification, error)

+ type Classifier struct

+ func NewClassifier(asset assets.Classifier) *Classifier

+ func (c *Classifier) Asset() assets.Classifier

+ func (c *Classifier) Reference() *assets.ClassifierReference

+ type ClassifierAssets struct

+ func NewClassifierAssets(classifiers []assets.Classifier) *ClassifierAssets

+ func (s *ClassifierAssets) Get(uuid assets.ClassifierUUID) *Classifier

+ type Connection struct

+ func NewConnection(channel *assets.ChannelReference, urn urns.URN) *Connection

+ func (c *Connection) Channel() *assets.ChannelReference

+ func (c *Connection) MarshalJSON() ([]byte, error)

+ func (c *Connection) URN() urns.URN

+ func (c *Connection) UnmarshalJSON(data []byte) error

type Contact

+ func (c *Contact) ClearURNs() bool

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

+ func (c *Contact) Country() envs.Country

+ func (c *Contact) LastSeenOn() *time.Time

+ func (c *Contact) Locale(env envs.Environment) envs.Locale

+ func (c *Contact) PreferredURN() *ContactURN

+ func (c *Contact) QueryProperty(env envs.Environment, key string, propType contactql.PropertyType) []interface{}

+ func (c *Contact) ReevaluateQueryBasedGroups(env envs.Environment) ([]*Group, []*Group)

+ func (c *Contact) RemoveURN(urn urns.URN) bool

+ func (c *Contact) ResolveDestinations(all bool) []Destination

+ func (c *Contact) SetLastSeenOn(t time.Time)

+ func (c *Contact) SetStatus(status ContactStatus)

+ func (c *Contact) Status() ContactStatus

+ func (c *Contact) Tickets() *TicketList

type ContactReference

+ func (r *ContactReference) Identity() string

+ func (r *ContactReference) String() string

+ func (r *ContactReference) Type() string

+ func (r *ContactReference) Variable() bool

+ type ContactStatus string

+ const ContactStatusActive

+ const ContactStatusArchived

+ const ContactStatusBlocked

+ const ContactStatusStopped

type ContactURN

+ func (u *ContactURN) ToXValue(env envs.Environment) types.XValue

+ type Contextable interface

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

+ type Dependency interface

+ Missing func() bool

+ Reference func() assets.Reference

+ Type func() string

+ type Destination struct

+ Channel *Channel

+ URN *ContactURN

+ type Dial struct

+ Duration int

+ Status DialStatus

+ func NewDial(status DialStatus, duration int) *Dial

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

+ type DialStatus string

+ const DialStatusAnswered

+ const DialStatusBusy

+ const DialStatusFailed

+ const DialStatusNoAnswer

+ type EmailService interface

+ Send func(addresses []string, subject, body string) error

+ type Engine interface

+ MaxResumesPerSession func() int

+ MaxStepsPerSprint func() int

+ MaxTemplateChars func() int

+ NewSession func(SessionAssets, Trigger) (Session, Sprint, error)

+ ReadSession func(SessionAssets, json.RawMessage, assets.MissingCallback) (Session, error)

+ Services func() Services

+ type EventCallback func(Event)

type Exit

+ DestinationUUID func() NodeUUID

+ type ExtractedEntity struct

+ Confidence decimal.Decimal

+ Value string

+ type ExtractedIntent struct

+ Confidence decimal.Decimal

+ Name string

+ type ExtractedReference struct

+ Reference assets.Reference

+ func NewExtractedReference(n Node, a Action, r Router, l envs.Language, ref assets.Reference) ExtractedReference

+ type ExtractedResult struct

+ Action Action

+ Info *ResultInfo

+ Node Node

+ Router Router

+ type ExtractedTemplate struct

+ Template string

+ func NewExtractedTemplate(n Node, a Action, r Router, l envs.Language, t string) ExtractedTemplate

type Field

+ func (f *Field) Reference() *assets.FieldReference

type FieldAssets

+ func (s *FieldAssets) ResolveField(key string) assets.Field

+ func (s *FieldAssets) ResolveFlow(name string) assets.Flow

+ func (s *FieldAssets) ResolveGroup(name string) assets.Group

type FieldValue

+ func (v *FieldValue) QueryValue() interface{}

+ func (v *FieldValue) ToXValue(env envs.Environment) types.XValue

type FieldValues

+ func (f FieldValues) Context(env envs.Environment) map[string]types.XValue

+ func (f FieldValues) Parse(env envs.Environment, fields *FieldAssets, field *Field, rawValue string) *Value

type Flow

+ Asset func() assets.Flow

+ ChangeLanguage func(envs.Language) (Flow, error)

+ ExtractLocalizables func() []string

+ ExtractTemplates func() []string

+ Inspect func(sa SessionAssets) *Inspection

type FlowAssets

+ FindByName func(string) (Flow, error)

type FlowType

+ const FlowTypeMessagingBackground

+ func (t FlowType) Allows(r FlowTypeRestricted) bool

+ type FlowTypeRestricted interface

+ AllowedFlowTypes func() []FlowType

+ type Global struct

+ func NewGlobal(asset assets.Global) *Global

+ func (g *Global) Asset() assets.Global

+ func (g *Global) Reference() *assets.GlobalReference

+ type GlobalAssets struct

+ func NewGlobalAssets(globals []assets.Global) *GlobalAssets

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

+ func (s *GlobalAssets) Get(key string) *Global

type Group

+ func (g *Group) CheckQueryBasedMembership(env envs.Environment, contact *Contact) bool

+ func (g *Group) ToXValue(env envs.Environment) types.XValue

+ func (g *Group) UsesQuery() bool

type GroupList

+ func (l *GroupList) Clear()

+ func (l GroupList) ToXValue(env envs.Environment) types.XValue

+ type HTTPLog struct

+ CreatedOn time.Time

+ func NewHTTPLog(trace *httpx.Trace, statusFn HTTPLogStatusResolver, redact utils.Redactor) *HTTPLog

+ type HTTPLogCallback func(*HTTPLog)

+ type HTTPLogStatusResolver func(t *httpx.Trace) CallStatus

+ type HTTPLogger struct

+ Logs []*HTTPLog

+ func (l *HTTPLogger) Log(h *HTTPLog)

+ type HTTPTrace struct

+ ElapsedMS int

+ Request string

+ Response string

+ Retries int

+ Status CallStatus

+ StatusCode int

+ URL string

+ func NewHTTPTrace(trace *httpx.Trace, status CallStatus) *HTTPTrace

+ type Hint interface

+ type Inspection struct

+ Dependencies []Dependency

+ Issues []Issue

+ ParentRefs []string

+ Results []*ResultSpec

+ WaitingExits []ExitUUID

+ type Issue interface

+ ActionUUID func() ActionUUID

+ Description func() string

+ Language func() envs.Language

+ NodeUUID func() NodeUUID

+ type Localizable interface

+ LocalizationUUID func() uuids.UUID

type Localization

+ GetItemTranslation func(envs.Language, uuids.UUID, string) []string

+ SetItemTranslation func(envs.Language, uuids.UUID, string, []string)

+ type Modifier interface

+ Apply func(envs.Environment, Services, SessionAssets, *Contact, EventCallback) bool

+ type ModifierCallback func(Modifier)

type MsgIn

+ ExternalID_ string

+ func (m *MsgIn) ExternalID() string

+ func (m *MsgIn) SetExternalID(id string)

type MsgOut

+ Templating_ *MsgTemplating

+ TextLanguage envs.Language

+ Topic_ MsgTopic

+ func NewIVRMsgOut(urn urns.URN, channel *assets.ChannelReference, text string, ...) *MsgOut

+ func (m *MsgOut) Templating() *MsgTemplating

+ func (m *MsgOut) Topic() MsgTopic

+ type MsgTemplating struct

+ Country_ envs.Country

+ Language_ envs.Language

+ Namespace_ string

+ Template_ *assets.TemplateReference

+ Variables_ []string

+ func NewMsgTemplating(template *assets.TemplateReference, language envs.Language, ...) *MsgTemplating

+ func (t MsgTemplating) Country() envs.Country

+ func (t MsgTemplating) Language() envs.Language

+ func (t MsgTemplating) Namespace() string

+ func (t MsgTemplating) Template() *assets.TemplateReference

+ func (t MsgTemplating) Variables() []string

+ type MsgTopic string

+ const MsgTopicAccount

+ const MsgTopicAgent

+ const MsgTopicEvent

+ const MsgTopicPurchase

+ const NilMsgTopic

type Node

+ EnumerateDependencies func(Localization, func(Action, Router, envs.Language, assets.Reference))

+ EnumerateLocalizables func(func(uuids.UUID, string, []string, func([]string)))

+ EnumerateResults func(func(Action, Router, *ResultInfo))

+ EnumerateTemplates func(Localization, func(Action, Router, envs.Language, string))

type Result

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

+ type ResultInfo struct

+ Categories []string

+ Key string

+ Name string

+ func NewResultInfo(name string, categories []string) *ResultInfo

+ func (r *ResultInfo) String() string

+ type ResultSpec struct

+ NodeUUIDs []string

+ func NewResultSpecs(results []ExtractedResult) []*ResultSpec

type Results

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

type Router

+ AllowTimeout func() bool

+ Categories func() []Category

+ EnumerateDependencies func(Localization, func(envs.Language, assets.Reference))

+ EnumerateLocalizables func(func(uuids.UUID, string, []string, func([]string)))

+ EnumerateResults func(func(*ResultInfo))

+ EnumerateTemplates func(Localization, func(envs.Language, string))

+ Route func(Run, Step, EventCallback) (ExitUUID, string, error)

+ RouteTimeout func(Run, Step, EventCallback) (ExitUUID, error)

+ Wait func() Wait

+ type Run interface

+ Ancestors func() []Run

+ CreateStep func(Node) Step

+ CreatedOn func() time.Time

+ Environment func() envs.Environment

+ EvaluateTemplate func(string) (string, error)

+ EvaluateTemplateText func(string, excellent.Escaping, bool) (string, error)

+ EvaluateTemplateValue func(string) (types.XValue, error)

+ Events func() []Event

+ Exit func(RunStatus)

+ ExitedOn func() *time.Time

+ FlowReference func() *assets.FlowReference

+ GetText func(uuids.UUID, string, string) string

+ GetTextArray func(uuids.UUID, string, []string) ([]string, envs.Language)

+ GetTranslatedTextArray func(uuids.UUID, string, []string, []envs.Language) []string

+ LogError func(Step, error)

+ LogEvent func(Step, Event)

+ ModifiedOn func() time.Time

+ Parent func() RunSummary

+ ParentInSession func() Run

+ Path func() []Step

+ PathLocation func() (Step, Node, error)

+ ReceivedInput func() bool

+ RootContext func(envs.Environment) map[string]types.XValue

+ SaveResult func(*Result)

+ Session func() Session

+ SetStatus func(RunStatus)

+ SetWebhook func(types.XValue)

+ Snapshot func() RunSummary

+ Webhook func() types.XValue

type RunStatus

+ const RunStatusFailed

+ type Segment interface

+ Destination func() Node

+ Exit func() Exit

+ Flow func() Flow

+ Node func() Node

+ Operand func() string

+ Time func() time.Time

+ type Services interface

+ Airtime func(SessionAssets) (AirtimeService, error)

+ Classification func(*Classifier) (ClassificationService, error)

+ Email func(SessionAssets) (EmailService, error)

+ Ticket func(*Ticketer) (TicketService, error)

+ Webhook func(SessionAssets) (WebhookService, error)

type Session

+ BatchStart func() bool

+ CurrentContext func() *types.XObject

+ CurrentResume func() Resume

+ Engine func() Engine

+ FindStep func(uuid StepUUID) (Run, Step)

+ History func() *SessionHistory

+ SetType func(FlowType)

+ Type func() FlowType

+ UUID func() SessionUUID

type SessionAssets

+ Classifiers func() *ClassifierAssets

+ Globals func() *GlobalAssets

+ Source func() assets.Source

+ Templates func() *TemplateAssets

+ Ticketers func() *TicketerAssets

+ Topics func() *TopicAssets

+ Users func() *UserAssets

+ type SessionHistory struct

+ Ancestors int

+ AncestorsSinceInput int

+ ParentUUID SessionUUID

+ func NewChildHistory(parent Session) *SessionHistory

+ func (h *SessionHistory) Advance(newParent SessionUUID, receivedInput bool) *SessionHistory

type SessionStatus

+ const SessionStatusFailed

+ type SessionUUID uuids.UUID

+ type Sprint interface

+ Events func() []Event

+ Modifiers func() []Modifier

+ Segments func() []Segment

+ type Template struct

+ func NewTemplate(t assets.Template) *Template

+ func (t *Template) Asset() assets.Template

+ func (t *Template) FindTranslation(channel assets.ChannelUUID, locales []envs.Locale) *TemplateTranslation

+ func (t *Template) Reference() *assets.TemplateReference

+ type TemplateAssets struct

+ func NewTemplateAssets(ts []assets.Template) *TemplateAssets

+ func (a *TemplateAssets) FindTranslation(uuid assets.TemplateUUID, channel *assets.ChannelReference, ...) *TemplateTranslation

+ func (a *TemplateAssets) Get(uuid assets.TemplateUUID) *Template

+ type TemplateTranslation struct

+ func NewTemplateTranslation(t assets.TemplateTranslation) *TemplateTranslation

+ func (t *TemplateTranslation) Asset() assets.TemplateTranslation

+ func (t *TemplateTranslation) Locale() envs.Locale

+ func (t *TemplateTranslation) Substitute(vars []string) string

+ type Ticket struct

+ func NewTicket(uuid TicketUUID, ticketer *Ticketer, topic *Topic, body, externalID string, ...) *Ticket

+ func OpenTicket(ticketer *Ticketer, topic *Topic, body string, assignee *User) *Ticket

+ func ReadTicket(sa SessionAssets, data []byte, missing assets.MissingCallback) (*Ticket, error)

+ func (t *Ticket) Assignee() *User

+ func (t *Ticket) Body() string

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

+ func (t *Ticket) ExternalID() string

+ func (t *Ticket) MarshalJSON() ([]byte, error)

+ func (t *Ticket) SetExternalID(id string)

+ func (t *Ticket) Ticketer() *Ticketer

+ func (t *Ticket) Topic() *Topic

+ func (t *Ticket) UUID() TicketUUID

+ type TicketList struct

+ func NewTicketList(tickets []*Ticket) *TicketList

+ func (l *TicketList) Add(ticket *Ticket)

+ func (l *TicketList) All() []*Ticket

+ func (l *TicketList) Count() int

+ func (l TicketList) ToXValue(env envs.Environment) types.XValue

+ type TicketService interface

+ Open func(env envs.Environment, contact *Contact, topic *Topic, body string, ...) (*Ticket, error)

+ type TicketUUID uuids.UUID

+ type Ticketer struct

+ func NewTicketer(asset assets.Ticketer) *Ticketer

+ func (t *Ticketer) Asset() assets.Ticketer

+ func (t *Ticketer) Reference() *assets.TicketerReference

+ type TicketerAssets struct

+ func NewTicketerAssets(ticketers []assets.Ticketer) *TicketerAssets

+ func (s *TicketerAssets) Get(uuid assets.TicketerUUID) *Ticketer

+ type Timeout interface

+ CategoryUUID func() CategoryUUID

+ Seconds func() int

+ type Topic struct

+ func NewTopic(asset assets.Topic) *Topic

+ func (t *Topic) Asset() assets.Topic

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

+ func (t *Topic) Reference() *assets.TopicReference

+ type TopicAssets struct

+ func NewTopicAssets(topics []assets.Topic) *TopicAssets

+ func (s *TopicAssets) FindByName(name string) *Topic

+ func (s *TopicAssets) Get(uuid assets.TopicUUID) *Topic

type Trigger

+ Batch func() bool

+ Connection func() *Connection

+ History func() *SessionHistory

+ type TriggerWithRun interface

+ RunSummary func() json.RawMessage

type URNList

+ func (l URNList) MapContext(env envs.Environment) map[string]types.XValue

+ func (l URNList) ToXValue(env envs.Environment) types.XValue

+ type User struct

+ func NewUser(asset assets.User) *User

+ func (u *User) Asset() assets.User

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

+ func (u *User) Format() string

+ func (u *User) Reference() *assets.UserReference

+ type UserAssets struct

+ func NewUserAssets(users []assets.User) *UserAssets

+ func (s *UserAssets) Get(email string) *User

type Wait

+ Accepts func(Resume) bool

type WebhookCall

+ ResponseCleaned bool

+ ResponseJSON []byte

+ type WebhookService interface

+ Call func(request *http.Request) (*WebhookCall, error)

Oct 25, 2018

Changes in this version

type ContactURN

+ func ParseRawURN(a SessionAssets, rawURN urns.URN) (*ContactURN, error)

+ func (u *ContactURN) Equal(other *ContactURN) bool

+ func (u *ContactURN) URN() urns.URN

type Flow

+ Type func() FlowType

type Node

+ Validate func(SessionAssets, *ValidationContext, Flow, map[utils.UUID]bool) error

type URNList

+ func (l URNList) Equal(other URNList) bool

+ type ValidationContext struct

+ func NewValidationContext() *ValidationContext

+ func (v *ValidationContext) IsStarted(flow Flow) bool

+ func (v *ValidationContext) Start(flow Flow)

type WebhookCall

+ func (w *WebhookCall) Resthook() string

type WebhookStatus

+ const WebhookStatusSubscriberGone

Oct 13, 2018

Changes in this version

type Session

+ Input func() Input

+ SetInput func(Input)

Oct 9, 2018

Changes in this version

+ type LegacyExtraContributor interface

+ LegacyExtra func() Results

Oct 5, 2018

Changes in this version

type FlowRun

+ SaveResult func(*Result)

type Result

+ func NewResult(name string, value string, category string, categoryLocalized string, ...) *Result

Oct 3, 2018

Changes in this version

type Contact

+ func (c *Contact) Equal(other *Contact) bool

type FlowRun

+ LogError func(Step, error)

+ LogEvent func(Step, Event)

+ LogFatalError func(Step, error)

+ type Resume interface

+ Apply func(FlowRun, Step) error

+ Contact func() *Contact

+ Environment func() utils.Environment

+ ResumedOn func() time.Time

type Trigger

+ Initialize func(Session) error

+ InitializeRun func(FlowRun, Step) error

type WebhookCall

+ func (w *WebhookCall) TimeTaken() time.Duration

Sep 28, 2018

Changes in this version

type FieldValues

+ func (f FieldValues) Clear(field *Field)

+ func (f FieldValues) Get(field *Field) *Value

+ func (f FieldValues) Set(env utils.Environment, field *Field, rawValue string, fields *FieldAssets) *Value

type Value

+ func (v *Value) Equals(o *Value) bool

Sep 28, 2018

Changes in this version

type FieldValues

+ func (f FieldValues) GetValue(field *Field) *FieldValue

Sep 26, 2018

Changes in this version

+ type CallerEvent interface

+ Apply func(FlowRun) error

+ Validate func(SessionAssets) error

type Value

+ Datetime *types.XDateTime

+ District LocationPath

+ Number *types.XNumber

+ State LocationPath

+ Text types.XText

+ Ward LocationPath

Sep 21, 2018

Changes in this version

type FlowRun

+ GetStep func(StepUUID) Step

type Result

+ Extra json.RawMessage

type WebhookCall

+ func ReconstructWebhookCall(url string, requestTrace string, responseTrace string) (*WebhookCall, error)

type WebhookStatus

+ func WebhookStatusFromCode(code int) WebhookStatus

Sep 19, 2018

Changes in this version

type Route

+ func (r Route) Extra() map[string]string

Sep 14, 2018

Changes in this version

type Contact

+ func NewContactFromAssets(a SessionAssets, uuid ContactUUID, id ContactID, name string, ...) (*Contact, error)

type FieldValues

+ func NewFieldValues(a SessionAssets, values map[assets.Field]*Value) (FieldValues, error)

type GroupList

+ func NewGroupListFromAssets(a SessionAssets, groupAssets []assets.Group) (*GroupList, error)

+ type Value struct

+ func NewValue(text types.XText, datetime *types.XDateTime, number *types.XNumber, ...) *Value

Sep 14, 2018

Changes in this version

type Flow

+ UI func() UI

+ type Position interface

+ type Sticky map[string]interface

+ type UI interface

+ AddNode func(uuid NodeUUID, details UINodeDetails)

+ AddSticky func(sticky Sticky)

+ GetNode func(uuid NodeUUID) UINodeDetails

+ type UINodeConfig map[string]string

+ type UINodeDetails interface

+ type UINodeType string

Sep 13, 2018

Changes in this version

+ const NilMsgID

type BaseMsg

+ ID_ MsgID

+ func (m *BaseMsg) ID() MsgID

type Channel

+ func (c *Channel) Asset() assets.Channel

+ func (c *Channel) Describe() string

+ func (c *Channel) HasParent() bool

+ func (c *Channel) Reduce(env utils.Environment) types.XPrimitive

+ func (c *Channel) ToXJSON(env utils.Environment) types.XText

+ type ChannelAssets struct

+ func NewChannelAssets(channels []assets.Channel) *ChannelAssets

+ func (s *ChannelAssets) Get(uuid assets.ChannelUUID) (*Channel, error)

+ func (s *ChannelAssets) GetForURN(urn *ContactURN, role assets.ChannelRole) *Channel

+ type ContactID int64

type Field

+ func (f *Field) Asset() assets.Field

+ type FieldAssets struct

+ func NewFieldAssets(fields []assets.Field) *FieldAssets

+ func (s *FieldAssets) All() []*Field

+ func (s *FieldAssets) FirstOfType(valueType assets.FieldType) *Field

+ func (s *FieldAssets) Get(key string) (*Field, error)

+ type FlowAssets interface

+ Get func(assets.FlowUUID) (Flow, error)

type Group

+ func (g *Group) Asset() assets.Group

+ type GroupAssets struct

+ func NewGroupAssets(groups []assets.Group) *GroupAssets

+ func (s *GroupAssets) All() []*Group

+ func (s *GroupAssets) FindByName(name string) *Group

+ func (s *GroupAssets) Get(uuid assets.GroupUUID) (*Group, error)

type Label

+ func (l *Label) Asset() assets.Label

+ type LabelAssets struct

+ func NewLabelAssets(labels []assets.Label) *LabelAssets

+ func (s *LabelAssets) All() []*Label

+ func (s *LabelAssets) FindByName(name string) *Label

+ func (s *LabelAssets) Get(uuid assets.LabelUUID) (*Label, error)

+ type LocationAssets struct

+ func NewLocationAssets(hierarchies []assets.LocationHierarchy) *LocationAssets

+ func (s *LocationAssets) Hierarchies() []assets.LocationHierarchy

+ type MsgID int64

type Resthook

+ func (r *Resthook) Asset() assets.Resthook

+ type ResthookAssets struct

+ func NewResthookAssets(resthooks []assets.Resthook) *ResthookAssets

+ func (s *ResthookAssets) FindBySlug(slug string) *Resthook

type SessionAssets

+ Channels func() *ChannelAssets

+ Fields func() *FieldAssets

+ Flows func() FlowAssets

+ Groups func() *GroupAssets

+ Labels func() *LabelAssets

+ Locations func() *LocationAssets

+ Resthooks func() *ResthookAssets

Sep 10, 2018

Changes in this version

type Channel

+ func NewTelChannel(uuid ChannelUUID, name string, address string, roles []ChannelRole, ...) Channel

+ Country func() string

+ MatchPrefixes func() []string

+ Parent func() *ChannelReference

type Contact

+ func NewEmptyContact(name string, language utils.Language, timezone *time.Location) *Contact

Aug 30, 2018

Changes in this version

type Action

+ AllowedFlowTypes func() []FlowType

+ type FlowType string

+ const FlowTypeMessaging

+ const FlowTypeMessagingOffline

+ const FlowTypeVoice

Jul 31, 2018

Changes in this version

type Contact

+ func (c *Contact) PreferredChannel() Channel

+ type LocationHierarchySet struct

+ func NewLocationHierarchySet(hierarchies []*utils.LocationHierarchy) *LocationHierarchySet

+ func ReadLocationHierarchySet(data json.RawMessage) (*LocationHierarchySet, error)

+ func (s *LocationHierarchySet) All() []*utils.LocationHierarchy

type SessionAssets

+ GetLocationHierarchySet func() (*LocationHierarchySet, error)

Jul 7, 2018

Changes in this version

+ var DefaultWebhookPayload = ...

+ type Resthook struct

+ func NewResthook(slug string, subscribers []string) *Resthook

+ func ReadResthook(data json.RawMessage) (*Resthook, error)

+ func (r *Resthook) Slug() string

+ func (r *Resthook) Subscribers() []string

+ type ResthookSet struct

+ func NewResthookSet(resthooks []*Resthook) *ResthookSet

+ func ReadResthookSet(data json.RawMessage) (*ResthookSet, error)

+ func (s *ResthookSet) FindBySlug(slug string) *Resthook

type SessionAssets

+ GetResthookSet func() (*ResthookSet, error)

type WebhookCall

+ func NewWebhookCall(url string, status WebhookStatus, statusCode int, request string, ...) *WebhookCall

Jul 2, 2018

Changes in this version

type Contact

+ func (c *Contact) Format(env utils.Environment) string

+ func (c *Contact) SetID(id int)

Jun 27, 2018

Changes in this version

type Contact

+ func (c *Contact) CreatedOn() time.Time

+ func (c *Contact) SetCreatedOn(createdOn time.Time)

May 31, 2018

Changes in this version

type EngineConfig

+ WebhookMocks func() []*WebhookMock

+ type WebhookMock struct

+ Body string

+ Method string

+ Status int

+ URL string

May 27, 2018

Changes in this version

type GroupSet

+ func (s *GroupSet) Dynamic() []*Group

+ func (s *GroupSet) Static() []*Group

May 25, 2018

Changes in this version

type Flow

+ Revision func() int

May 23, 2018

Changes in this version

+ var REDACTED_URN = types.NewXText("********")

type Contact

+ func (c *Contact) ID() int

May 14, 2018

Changes in this version

type EngineConfig

+ DisableWebhooks func() bool

May 10, 2018

Changes in this version

type Attachment

+ func (a Attachment) Describe() string

type AttachmentList

+ func (a AttachmentList) Describe() string

type Contact

+ func (c *Contact) Describe() string

type ContactURN

+ func (u *ContactURN) Describe() string

type FieldValue

+ func (v *FieldValue) Describe() string

type FieldValues

+ func (f FieldValues) Describe() string

type Group

+ func (g *Group) Describe() string

type GroupList

+ func (l GroupList) Describe() string

type LocationPath

+ func (p LocationPath) Describe() string

type Result

+ func (r *Result) Describe() string

type Results

+ func (r Results) Describe() string

type URNList

+ func (l URNList) Describe() string

type WebhookCall

+ func (w *WebhookCall) Describe() string

May 4, 2018

Changes in this version

type FlowRun

+ Events func() []Event

type Results

+ func (r Results) Get(key string) *Result

type Wait

+ Timeout func() *int

+ TimeoutOn func() *time.Time

May 3, 2018

Changes in this version

+ const LocationLevelDistrict

+ const LocationLevelState

+ const LocationLevelWard

+ var EmptyFieldValue = &FieldValue

+ func IsPossibleLocationPath(str string) bool

type Contact

+ func (c *Contact) ReevaluateDynamicGroups(session Session) error

type FieldSet

+ func (s *FieldSet) FirstOfType(valueType FieldValueType) *Field

type FieldValue

+ func NewEmptyFieldValue(field *Field) *FieldValue

+ type LocationPath string

+ func (p LocationPath) Name() string

+ func (p LocationPath) Reduce() types.XPrimitive

+ func (p LocationPath) String() string

+ func (p LocationPath) ToXJSON() types.XText

type RunEnvironment

+ LookupLocation func(LocationPath) (*utils.Location, error)

Apr 25, 2018

Changes in this version

+ type EngineConfig interface

+ MaxWebhookResponseBytes func() int

type Session

+ EngineConfig func() EngineConfig

type WebhookCall

+ func (w *WebhookCall) Method() string

Apr 23, 2018

Changes in this version

type Session

+ HTTPClient func() *utils.HTTPClient

Apr 18, 2018

Changes in this version

type FieldValueType

+ const FieldValueTypeNumber

Apr 16, 2018

Changes in this version

type Attachment

+ func (a Attachment) Reduce() types.XPrimitive

+ func (a Attachment) ToXJSON() types.XString

+ type AttachmentList []Attachment

+ func (a AttachmentList) Index(index int) types.XValue

+ func (a AttachmentList) Length() int

+ func (a AttachmentList) Reduce() types.XPrimitive

+ func (a AttachmentList) ToXJSON() types.XString

type Contact

+ func (c *Contact) Reduce() types.XPrimitive

+ func (c *Contact) SetFieldValue(env utils.Environment, field *Field, rawValue string)

+ func (c *Contact) ToXJSON() types.XString

type ContactURN

+ func (u *ContactURN) Reduce() types.XPrimitive

+ func (u *ContactURN) ToXJSON() types.XString

type FieldReference

+ Name string

type FieldSet

+ func (s *FieldSet) All() []*Field

type FieldValue

+ func (v *FieldValue) IsEmpty() bool

+ func (v *FieldValue) Reduce() types.XPrimitive

+ func (v *FieldValue) ToXJSON() types.XString

+ func (v *FieldValue) TypedValue() types.XValue

type FieldValueType

+ const FieldValueTypeDecimal

type FieldValues

+ func (f FieldValues) Length() int

+ func (f FieldValues) Reduce() types.XPrimitive

+ func (f FieldValues) ToXJSON() types.XString

type FlowRun

+ EvaluateTemplate func(template string) (types.XValue, error)

+ EvaluateTemplateAsString func(template string, urlEncode bool) (string, error)

+ ParentInSession func() FlowRun

type Group

+ func (g *Group) Reduce() types.XPrimitive

+ func (g *Group) ToXJSON() types.XString

type GroupList

+ func (l *GroupList) Index(index int) types.XValue

+ func (l *GroupList) Length() int

+ func (l GroupList) Reduce() types.XPrimitive

+ func (l GroupList) ToXJSON() types.XString

+ type Location struct

+ func NewLocation(id LocationID, level LocationLevel, name string) *Location

+ func (b *Location) Aliases() []string

+ func (b *Location) Children() []*Location

+ func (b *Location) ID() LocationID

+ func (b *Location) Level() LocationLevel

+ func (b *Location) Name() string

+ func (b *Location) Parent() *Location

+ func (b *Location) Reduce() types.XPrimitive

+ func (b *Location) ToXJSON() types.XString

+ type LocationHierarchy struct

+ func NewLocationHierarchy(root *Location, numLevels int) *LocationHierarchy

+ func ReadLocationHierarchy(data json.RawMessage) (*LocationHierarchy, error)

+ func (s *LocationHierarchy) FindByID(id LocationID, level LocationLevel) *Location

+ func (s *LocationHierarchy) FindByName(name string, level LocationLevel, parent *Location) []*Location

+ func (s *LocationHierarchy) Root() *Location

+ type LocationID string

+ type LocationLevel int

type Node

+ AddAction func(Action)

type Result

+ func (r *Result) Reduce() types.XPrimitive

+ func (r *Result) ToXJSON() types.XString

type Results

+ func (r Results) Length() int

+ func (r Results) Reduce() types.XPrimitive

+ func (r Results) ToXJSON() types.XString

+ type RunEnvironment interface

+ FindLocations func(string, LocationLevel, *Location) ([]*Location, error)

+ FindLocationsFuzzy func(string, LocationLevel, *Location) ([]*Location, error)

type Session

+ ParentRun func() RunSummary

type URNList

+ func (l URNList) Index(index int) types.XValue

+ func (l URNList) Length() int

+ func (l URNList) Reduce() types.XPrimitive

+ func (l URNList) ToXJSON() types.XString

+ type WebhookCall struct

+ func MakeWebhookCall(req *http.Request) (*WebhookCall, error)

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

+ func (w *WebhookCall) Body() string

+ func (w *WebhookCall) JSON() types.XValue

+ func (w *WebhookCall) Reduce() types.XPrimitive

+ func (w *WebhookCall) Request() string

+ func (w *WebhookCall) Resolve(key string) types.XValue

+ func (w *WebhookCall) Response() string

+ func (w *WebhookCall) Status() WebhookStatus

+ func (w *WebhookCall) StatusCode() int

+ func (w *WebhookCall) ToXJSON() types.XString

+ func (w *WebhookCall) URL() string

+ func (w *WebhookCall) UnmarshalJSON(data []byte) error

+ type WebhookStatus string

+ const WebhookStatusConnectionError

+ const WebhookStatusResponseError

+ const WebhookStatusSuccess

+ func (r WebhookStatus) String() string

Mar 21, 2018

Changes in this version

type Event

+ SetStepUUID func(StepUUID)

+ StepUUID func() StepUUID

Mar 16, 2018

Changes in this version

type Flow

+ Localization func() Localization

+ type Localization interface

+ AddItemTranslation func(utils.Language, utils.UUID, string, []string)

+ GetTranslations func(utils.Language) Translations

+ Languages func() utils.LanguageList

type Result

+ Operand string

Mar 13, 2018

Changes in this version

type Contact

+ func (c *Contact) HasURN(urn urns.URN) bool

type FlowRun

+ GetTranslatedTextArray func(utils.UUID, string, []string, utils.LanguageList) []string

type FlowTranslations

+ Languages func() utils.LanguageList

Mar 12, 2018

Changes in this version

+ type BaseMsg struct

+ Attachments_ []Attachment

+ Channel_ *ChannelReference

+ Text_ string

+ URN_ urns.URN

+ UUID_ MsgUUID

+ func (m *BaseMsg) Attachments() []Attachment

+ func (m *BaseMsg) Channel() *ChannelReference

+ func (m *BaseMsg) Text() string

+ func (m *BaseMsg) URN() urns.URN

+ func (m *BaseMsg) UUID() MsgUUID

type Channel

+ func NewChannel(uuid ChannelUUID, name string, address string, schemes []string, ...) Channel

+ HasRole func(ChannelRole) bool

+ Roles func() []ChannelRole

+ Schemes func() []string

+ SupportsScheme func(string) bool

+ type ChannelRole string

+ const ChannelRoleAnswer

+ const ChannelRoleCall

+ const ChannelRoleReceive

+ const ChannelRoleSend

+ const ChannelRoleUSSD

+ type ChannelSet struct

+ func NewChannelSet(channels []Channel) *ChannelSet

+ func ReadChannelSet(data json.RawMessage) (*ChannelSet, error)

+ func (s *ChannelSet) FindByUUID(uuid ChannelUUID) Channel

+ func (s *ChannelSet) GetForURN(urn *ContactURN) Channel

type Contact

+ func (c *Contact) UpdatePreferredChannel(channel Channel)

+ type ContactURN struct

+ func NewContactURN(urn urns.URN, channel Channel) *ContactURN

+ func (u *ContactURN) Channel() Channel

+ func (u *ContactURN) Default() interface{}

+ func (u *ContactURN) Resolve(key string) interface{}

+ func (u *ContactURN) SetChannel(channel Channel)

+ func (u *ContactURN) String() string

type Event

+ AllowedOrigin func() EventOrigin

+ Validate func(SessionAssets) error

+ type EventOrigin int

+ const EventOriginCaller

+ const EventOriginEngine

type MsgIn

+ func NewMsgIn(uuid MsgUUID, urn urns.URN, channel Channel, text string, ...) *MsgIn

type MsgOut

+ QuickReplies_ []string

+ func NewMsgOut(urn urns.URN, channel Channel, text string, attachments []Attachment, ...) *MsgOut

+ func (m *MsgOut) QuickReplies() []string

+ type MsgUUID utils.UUID

+ func (u MsgUUID) String() string

type SessionAssets

+ GetChannelSet func() (*ChannelSet, error)

type URNList

+ func ReadURNList(session Session, rawURNs []urns.URN) (URNList, error)

+ func (l URNList) RawURNs(includeChannels bool) []urns.URN

Mar 2, 2018

Changes in this version

type Contact

+ func NewContact(uuid ContactUUID, name string, language utils.Language, ...) *Contact

Mar 1, 2018

Changes in this version

type Channel

+ Reference func() *ChannelReference

type Trigger

+ Contact func() *Contact

+ Environment func() utils.Environment

+ Params func() *utils.JSONFragment

Dec 19, 2017

Changes in this version

type URNList

+ func (l URNList) WithScheme(scheme string) URNList

Oct 31, 2017

Changes in this version

type Result

+ Category string

+ CategoryLocalized string

+ CreatedOn time.Time

+ Input string

+ Name string

+ NodeUUID NodeUUID

+ Value string

Oct 30, 2017

Changes in this version

+ func GroupReferenceValidation(sl validator.StructLevel)

+ func LabelReferenceValidation(sl validator.StructLevel)

+ func ValidateURN(fl validator.FieldLevel) bool

+ func ValidateURNScheme(fl validator.FieldLevel) bool

type Action

+ UUID func() ActionUUID

+ type Attachment string

+ func (a Attachment) ContentType() string

+ func (a Attachment) Default() interface{}

+ func (a Attachment) Resolve(key string) interface{}

+ func (a Attachment) String() string

+ func (a Attachment) URL() string

type Channel

+ func ReadChannels(data []json.RawMessage) ([]Channel, error)

+ Address func() string

+ type ChannelReference struct

+ Name string

+ UUID ChannelUUID

+ func NewChannelReference(uuid ChannelUUID, name string) *ChannelReference

type Contact

+ func (c *Contact) AddURN(urn urns.URN)

+ func (c *Contact) Channel() Channel

+ func (c *Contact) Clone() *Contact

+ func (c *Contact) Reference() *ContactReference

+ func (c *Contact) ResolveQueryKey(key string) interface{}

+ func (c *Contact) SetChannel(channel Channel)

+ func (c *Contact) UpdateDynamicGroups(session Session) error

type ContactReference

+ func NewContactReference(uuid ContactUUID, name string) *ContactReference

type Event

+ Apply func(FlowRun) error

+ FromCaller func() bool

+ SetFromCaller func(bool)

+ type EventLog interface

+ Add func(Event)

+ Events func() []Event

type Field

+ func NewField(key FieldKey, label string, valueType FieldValueType) *Field

+ func ReadField(data json.RawMessage) (*Field, error)

+ func (f *Field) Key() FieldKey

+ func (f *Field) ParseValue(env utils.Environment, value string) (interface{}, error)

+ type FieldKey string

+ type FieldReference struct

+ Key FieldKey

+ Label string

+ func NewFieldReference(key FieldKey, label string) *FieldReference

+ type FieldSet struct

+ func NewFieldSet(fields []*Field) *FieldSet

+ func ReadFieldSet(data json.RawMessage) (*FieldSet, error)

+ func (s *FieldSet) FindByKey(key FieldKey) *Field

+ type FieldValue struct

+ func NewFieldValue(field *Field, value interface{}, createdOn time.Time) *FieldValue

+ func (v *FieldValue) Default() interface{}

+ func (v *FieldValue) Resolve(key string) interface{}

+ func (v *FieldValue) SerializeValue() string

+ func (v *FieldValue) String() string

+ type FieldValueType string

+ const FieldValueTypeDatetime

+ const FieldValueTypeDistrict

+ const FieldValueTypeNumeric

+ const FieldValueTypeState

+ const FieldValueTypeText

+ const FieldValueTypeWard

+ type FieldValues map[FieldKey]*FieldValue

+ func (f FieldValues) Clone() FieldValues

+ func (f FieldValues) Default() interface{}

+ func (f FieldValues) Resolve(key string) interface{}

+ func (f FieldValues) Save(env utils.Environment, field *Field, rawValue string) error

+ func (f FieldValues) String() string

type Flow

+ ExpireAfterMinutes func() int

+ Reference func() *FlowReference

+ type FlowReference struct

+ Name string

+ UUID FlowUUID

+ func NewFlowReference(uuid FlowUUID, name string) *FlowReference

type FlowRun

+ AddFatalError func(Step, Action, error)

+ Ancestors func() []FlowRun

+ ApplyEvent func(Step, Action, Event) error

+ GetTextArray func(uuid UUID, key string, native []string) []string

+ PathLocation func() (Step, Node, error)

+ ResetExpiration func(*time.Time)

+ SessionParent func() FlowRun

+ SetContact func(*Contact)

+ SetStatus func(RunStatus)

+ Snapshot func() RunSummary

type FlowTranslations

+ GetLanguageTranslations func(utils.Language) Translations

type Group

+ func ReadGroup(data json.RawMessage) (*Group, error)

+ func (g *Group) CheckDynamicMembership(session Session, contact *Contact) (bool, error)

+ func (g *Group) IsDynamic() bool

+ func (g *Group) ParsedQuery() (*contactql.ContactQuery, error)

+ func (g *Group) Query() string

+ func (g *Group) Reference() *GroupReference

type GroupList

+ func NewGroupList(groups []*Group) *GroupList

+ func (l *GroupList) Add(group *Group) bool

+ func (l *GroupList) All() []*Group

+ func (l *GroupList) Clone() *GroupList

+ func (l *GroupList) Count() int

+ func (l *GroupList) FindByUUID(uuid GroupUUID) *Group

+ func (l *GroupList) Remove(group *Group) bool

+ type GroupReference struct

+ Name string

+ NameMatch string

+ UUID GroupUUID

+ func NewGroupReference(uuid GroupUUID, name string) *GroupReference

+ func NewVariableGroupReference(nameMatch string) *GroupReference

+ type GroupSet struct

+ func NewGroupSet(groups []*Group) *GroupSet

+ func ReadGroupSet(data json.RawMessage) (*GroupSet, error)

+ func (s *GroupSet) All() []*Group

+ func (s *GroupSet) FindByName(name string) *Group

+ func (s *GroupSet) FindByUUID(uuid GroupUUID) *Group

type Input

+ Channel func() Channel

+ CreatedOn func() time.Time

+ UUID func() InputUUID

+ type InputUUID UUID

+ func (u InputUUID) String() string

type Label

+ func ReadLabel(data json.RawMessage) (*Label, error)

+ func (l *Label) Reference() *LabelReference

+ type LabelReference struct

+ Name string

+ NameMatch string

+ UUID LabelUUID

+ func NewLabelReference(uuid LabelUUID, name string) *LabelReference

+ func NewVariableLabelReference(nameMatch string) *LabelReference

+ type LabelSet struct

+ func NewLabelSet(labels []*Label) *LabelSet

+ func ReadLabelSet(data json.RawMessage) (*LabelSet, error)

+ func (s *LabelSet) FindByName(name string) *Label

+ func (s *LabelSet) FindByUUID(uuid LabelUUID) *Label

+ type LogEntry interface

+ Action func() Action

+ Event func() Event

+ Step func() Step

type Results

+ func (r *Results) Clone() *Results

type RunStatus

+ const RunStatusActive

+ const RunStatusCompleted

+ const RunStatusErrored

+ const RunStatusExpired

+ const RunStatusInterrupted

+ const RunStatusWaiting

+ type RunSummary interface

+ Contact func() *Contact

+ Flow func() Flow

+ Results func() *Results

+ Status func() RunStatus

+ UUID func() RunUUID

+ func NewRunSummaryFromRun(run FlowRun) RunSummary

+ func ReadRunSummary(session Session, data json.RawMessage) (RunSummary, error)

type Session

+ Assets func() SessionAssets

+ ClearLog func()

+ Contact func() *Contact

+ Environment func() utils.Environment

+ FlowOnStack func(FlowUUID) bool

+ GetCurrentChild func(FlowRun) FlowRun

+ GetRun func(RunUUID) (FlowRun, error)

+ Log func() []LogEntry

+ LogEvent func(Step, Action, Event)

+ PushFlow func(Flow, FlowRun)

+ Resume func([]Event) error

+ SetContact func(*Contact)

+ SetEnvironment func(utils.Environment)

+ Start func(Trigger, []Event) error

+ Status func() SessionStatus

+ Trigger func() Trigger

+ Wait func() Wait

+ type SessionAssets interface

+ GetChannel func(ChannelUUID) (Channel, error)

+ GetField func(FieldKey) (*Field, error)

+ GetFieldSet func() (*FieldSet, error)

+ GetFlow func(FlowUUID) (Flow, error)

+ GetGroup func(GroupUUID) (*Group, error)

+ GetGroupSet func() (*GroupSet, error)

+ GetLabel func(LabelUUID) (*Label, error)

+ GetLabelSet func() (*LabelSet, error)

+ GetLocationHierarchy func() (*utils.LocationHierarchy, error)

+ HasLocations func() bool

+ type SessionStatus string

+ const SessionStatusActive

+ const SessionStatusCompleted

+ const SessionStatusErrored

+ const SessionStatusWaiting

+ func (r SessionStatus) String() string

type Translations

+ GetTextArray func(uuid UUID, key string) []string

+ type Trigger interface

+ Flow func() Flow

+ TriggeredOn func() time.Time

type URNList

+ func (l URNList) Clone() URNList

type Wait

+ CanResume func(FlowRun, Step) bool

+ HasTimedOut func() bool

+ Resume func(FlowRun)

+ ResumeByTimeOut func(FlowRun)

Jul 7, 2017

Changes in this version

+ const EmailScheme

+ const FacebookScheme

+ const TelScheme

+ const TelegramScheme

+ const TwitterScheme

+ const ViberScheme

+ var NoRoute = Route

+ func ValidateGroup(sl validator.StructLevel)

+ type Action interface

+ Execute func(FlowRun, Step) error

+ Validate func() error

+ type ActionUUID UUID

+ func (u ActionUUID) String() string

+ type Channel struct

+ func ReadChannel(data json.RawMessage) (*Channel, error)

+ func (c *Channel) Default() interface{}

+ func (c *Channel) MarshalJSON() ([]byte, error)

+ func (c *Channel) Name() string

+ func (c *Channel) Resolve(key string) interface{}

+ func (c *Channel) String() string

+ func (c *Channel) Type() ChannelType

+ func (c *Channel) UUID() ChannelUUID

+ func (c *Channel) UnmarshalJSON(data []byte) error

+ type ChannelType string

+ func (ct ChannelType) String() string

+ type ChannelUUID UUID

+ func (u ChannelUUID) String() string

+ type Contact struct

+ func ReadContact(data json.RawMessage) (*Contact, error)

+ func (c *Contact) AddGroup(uuid GroupUUID, name string)

+ func (c *Contact) Default() interface{}

+ func (c *Contact) Fields() *Fields

+ func (c *Contact) Groups() GroupList

+ func (c *Contact) Language() utils.Language

+ func (c *Contact) MarshalJSON() ([]byte, error)

+ func (c *Contact) Name() string

+ func (c *Contact) RemoveGroup(uuid GroupUUID) bool

+ func (c *Contact) Resolve(key string) interface{}

+ func (c *Contact) SetLanguage(lang utils.Language)

+ func (c *Contact) SetName(name string)

+ func (c *Contact) SetTimezone(tz *time.Location)

+ func (c *Contact) String() string

+ func (c *Contact) Timezone() *time.Location

+ func (c *Contact) URNs() URNList

+ func (c *Contact) UUID() ContactUUID

+ func (c *Contact) UnmarshalJSON(data []byte) error

+ type ContactReference struct

+ Name string

+ UUID ContactUUID

+ type ContactUUID UUID

+ func (u ContactUUID) String() string

+ type Context interface

+ Contact func() *Contact

+ Run func() FlowRun

+ type Event interface

+ CreatedOn func() *time.Time

+ SetCreatedOn func(time.Time)

+ SetStep func(StepUUID)

+ Step func() StepUUID

+ type Exit interface

+ DestinationNodeUUID func() NodeUUID

+ Name func() string

+ UUID func() ExitUUID

+ type ExitUUID UUID

+ func (u ExitUUID) String() string

+ type Field struct

+ func (f *Field) Default() interface{}

+ func (f *Field) MarshalJSON() ([]byte, error)

+ func (f *Field) Resolve(key string) interface{}

+ func (f *Field) String() string

+ func (f *Field) UnmarshalJSON(data []byte) error

+ type FieldUUID UUID

+ func (u FieldUUID) String() string

+ type Fields struct

+ func NewFields() *Fields

+ func (f *Fields) Default() interface{}

+ func (f *Fields) MarshalJSON() ([]byte, error)

+ func (f *Fields) Resolve(key string) interface{}

+ func (f *Fields) Save(uuid FieldUUID, name string, value string)

+ func (f *Fields) String() string

+ func (f *Fields) UnmarshalJSON(data []byte) error

+ type Flow interface

+ CreateRun func(env FlowEnvironment, contact *Contact, parent FlowRun) FlowRun

+ GetNode func(uuid NodeUUID) Node

+ Language func() utils.Language

+ Name func() string

+ Nodes func() []Node

+ Translations func() FlowTranslations

+ UUID func() FlowUUID

+ Validate func() error

+ type FlowEnvironment interface

+ GetContact func(ContactUUID) (*Contact, error)

+ GetFlow func(FlowUUID) (Flow, error)

+ GetRun func(RunUUID) (FlowRun, error)

+ type FlowRun interface

+ AddError func(Step, error)

+ AddEvent func(Step, Event)

+ Channel func() *Channel

+ ChannelUUID func() ChannelUUID

+ Child func() FlowRunReference

+ Contact func() *Contact

+ ContactUUID func() ContactUUID

+ Context func() Context

+ CreateStep func(Node) Step

+ CreatedOn func() time.Time

+ Environment func() FlowEnvironment

+ Exit func(RunStatus)

+ ExitedOn func() *time.Time

+ ExpiresOn func() *time.Time

+ Extra func() utils.JSONFragment

+ Flow func() Flow

+ FlowUUID func() FlowUUID

+ GetText func(uuid UUID, key string, backdown string) string

+ GetTranslations func(uuid UUID, key string, backdown []string) []string

+ Hydrate func(FlowEnvironment) error

+ Input func() Input

+ IsComplete func() bool

+ ModifiedOn func() time.Time

+ Parent func() FlowRunReference

+ Path func() []Step

+ ResetSession func()

+ Results func() *Results

+ Session func() Session

+ SetChannel func(*Channel)

+ SetExtra func(json.RawMessage)

+ SetFlowTranslations func(FlowTranslations)

+ SetInput func(Input)

+ SetLanguage func(utils.Language)

+ SetSession func(Session)

+ SetWait func(Wait)

+ SetWebhook func(*utils.RequestResponse)

+ Status func() RunStatus

+ TimesOutOn func() *time.Time

+ UUID func() RunUUID

+ Wait func() Wait

+ Webhook func() *utils.RequestResponse

+ type FlowRunReference interface

+ ChannelUUID func() ChannelUUID

+ ContactUUID func() ContactUUID

+ CreatedOn func() time.Time

+ ExitedOn func() *time.Time

+ ExpiresOn func() *time.Time

+ FlowUUID func() FlowUUID

+ ModifiedOn func() time.Time

+ Results func() *Results

+ Status func() RunStatus

+ TimesOutOn func() *time.Time

+ UUID func() RunUUID

+ type FlowTranslations interface

+ GetTranslations func(utils.Language) Translations

+ type FlowUUID UUID

+ func (u FlowUUID) String() string

+ type Group struct

+ func NewGroup(uuid GroupUUID, name string) *Group

+ func (g *Group) Default() interface{}

+ func (g *Group) MarshalJSON() ([]byte, error)

+ func (g *Group) Name() string

+ func (g *Group) Resolve(key string) interface{}

+ func (g *Group) String() string

+ func (g *Group) UUID() GroupUUID

+ func (g *Group) UnmarshalJSON(data []byte) error

+ type GroupList []*Group

+ func (l GroupList) Default() interface{}

+ func (l GroupList) FindGroup(uuid GroupUUID) *Group

+ func (l GroupList) Resolve(key string) interface{}

+ func (l GroupList) String() string

+ type GroupUUID UUID

+ func (u GroupUUID) String() string

+ type Input interface

+ type Label struct

+ func NewLabel(uuid LabelUUID, name string) *Label

+ func (l *Label) MarshalJSON() ([]byte, error)

+ func (l *Label) Name() string

+ func (l *Label) UUID() LabelUUID

+ func (l *Label) UnmarshalJSON(data []byte) error

+ type LabelUUID UUID

+ func (u LabelUUID) String() string

+ type MsgDirection string

+ const MsgIn

+ const MsgOut

+ type Node interface

+ Actions func() []Action

+ Exits func() []Exit

+ Router func() Router

+ UUID func() NodeUUID

+ Wait func() Wait

+ type NodeUUID UUID

+ func (u NodeUUID) String() string

+ type Result struct

+ func (r *Result) Default() interface{}

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

+ func (r *Result) Resolve(key string) interface{}

+ func (r *Result) String() string

+ func (r *Result) UnmarshalJSON(data []byte) error

+ type Results struct

+ func NewResults() *Results

+ func (r *Results) Default() interface{}

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

+ func (r *Results) Resolve(key string) interface{}

+ func (r *Results) Save(node NodeUUID, name string, value string, category string, ...)

+ func (r *Results) String() string

+ func (r *Results) UnmarshalJSON(data []byte) error

+ type Route struct

+ func NewRoute(exit ExitUUID, match string) Route

+ func (r Route) Exit() ExitUUID

+ func (r Route) Match() string

+ type Router interface

+ PickRoute func(FlowRun, []Exit, Step) (Route, error)

+ ResultName func() string

+ Validate func([]Exit) error

+ type RunStatus string

+ const StatusActive

+ const StatusCompleted

+ const StatusErrored

+ const StatusExpired

+ const StatusInterrupted

+ func (r RunStatus) String() string

+ type RunUUID UUID

+ func (u RunUUID) String() string

+ type Session interface

+ ActiveRun func() FlowRun

+ AddEvent func(Event)

+ AddRun func(FlowRun)

+ ClearEvents func()

+ Events func() []Event

+ Runs func() []FlowRun

+ type Step interface

+ ArrivedOn func() time.Time

+ Events func() []Event

+ ExitUUID func() ExitUUID

+ Leave func(ExitUUID)

+ LeftOn func() *time.Time

+ NodeUUID func() NodeUUID

+ UUID func() StepUUID

+ type StepUUID UUID

+ func (u StepUUID) String() string

+ type Translations interface

+ GetText func(uuid UUID, key string, backdown string) string

+ GetTranslations func(uuid UUID, key string, backdown []string) []string

+ type URN string

+ func (u URN) Default() interface{}

+ func (u URN) Path() URNPath

+ func (u URN) Resolve(key string) interface{}

+ func (u URN) Scheme() URNScheme

+ func (u URN) String() string

+ type URNList []URN

+ func (l URNList) Default() interface{}

+ func (l URNList) Resolve(key string) interface{}

+ func (l URNList) String() string

+ type URNPath string

+ func (u URNPath) String() string

+ type URNScheme string

+ func GetScheme(scheme string) URNScheme

+ func (u URNScheme) String() string

+ type UUID string

+ type Wait interface

+ Begin func(FlowRun, Step) error

+ End func(FlowRun, Step, Event) error

+ GetEndEvent func(FlowRun, Step) (Event, error)