inputs

Documentation

Index

• Constants
• func ReadInput(sessionAssets flows.SessionAssets, data json.RawMessage, ...) (flows.Input, error)
• func RegisterType(name string, f readFunc)
• type MsgInput
  • func NewMsgInput(assets flows.SessionAssets, msg *flows.MsgIn, createdOn time.Time) (*MsgInput, error)
  • func (i *MsgInput) Channel() *flows.Channel
  • func (i *MsgInput) CreatedOn() time.Time
  • func (i *MsgInput) Describe() string
  • func (i *MsgInput) MarshalJSON() ([]byte, error)
  • func (i *MsgInput) Reduce(env utils.Environment) types.XPrimitive
  • func (i *MsgInput) Resolve(env utils.Environment, key string) types.XValue
  • func (i *MsgInput) ToXJSON(env utils.Environment) types.XText
  • func (i *MsgInput) Type() string
  • func (i *MsgInput) UUID() flows.InputUUID

Constants

const TypeMsg string = "msg"

TypeMsg is a constant for incoming messages

Functions

func ReadInput

func ReadInput(sessionAssets flows.SessionAssets, data json.RawMessage, missing assets.MissingCallback) (flows.Input, error)

ReadInput reads an input from the given typed envelope

func RegisterType

func RegisterType(name string, f readFunc)

RegisterType registers a new type of input

Types

type MsgInput

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

MsgInput is a message which can be used as input

func NewMsgInput

func NewMsgInput(assets flows.SessionAssets, msg *flows.MsgIn, createdOn time.Time) (*MsgInput, error)

NewMsgInput creates a new user input based on a message

func (*MsgInput) Channel

func (i *MsgInput) Channel() *flows.Channel

func (*MsgInput) CreatedOn

func (i *MsgInput) CreatedOn() time.Time

func (*MsgInput) Describe

func (i *MsgInput) Describe() string

Describe returns a representation of this type for error messages

func (*MsgInput) MarshalJSON

func (i *MsgInput) MarshalJSON() ([]byte, error)

MarshalJSON marshals this msg input into JSON

func (*MsgInput) Reduce

func (i *MsgInput) Reduce(env utils.Environment) types.XPrimitive

Reduce is called when this object needs to be reduced to a primitive

func (*MsgInput) Resolve

func (i *MsgInput) Resolve(env utils.Environment, key string) types.XValue

Resolve resolves the given key when this input is referenced in an expression

func (*MsgInput) ToXJSON

func (i *MsgInput) ToXJSON(env utils.Environment) types.XText

ToXJSON is called when this type is passed to @(json(...))

func (*MsgInput) Type

func (i *MsgInput) Type() string

Type returns the type of this input

func (*MsgInput) UUID

func (i *MsgInput) UUID() flows.InputUUID