behavior

package

Go to main page

Versions in this module

v0

v0.1.19

Aug 17, 2023

Changes in this version

type Address

+ Interaction string

type Context

+ ForgeEnv *forge.ForgeEnv

+ func (ctx *Context) Setup()

type ContextState

+ GetSession func(string) Session

type DefaultState

+ func (st *DefaultState) GetSession(sid string) Session

+ type Mailbox chan Message

+ type Session interface

+ Send func(ctx *Context, msg *Message)

v0.1.18

Mar 23, 2022

v0.1.15

Mar 23, 2022

Changes in this version

type Message

+ func (msg *Message) SetTimestampInPayload(ctx *Context, ts *Timestamp)

type Payload

+ func (pl Payload) JSONToMap(ctx *Context) m.Map

type Timestamp

+ func GetTimestamp(data m.Map, key string) *Timestamp

+ func GetTimestampDef(data m.Map, key string, def *Timestamp) *Timestamp

+ func (t *Timestamp) AsTime() *time.Time

v0.1.14

Sep 8, 2021

v0.1.13

Jul 22, 2021

Changes in this version

type Context

+ func (ctx *Context) SendToAddr(msg *Message, addr Address)

+ func (ctx *Context) SendToMailbox(mb chan Message, msg *Message)

type Message

+ func (msg *Message) SetPayload(ctx *Context, data m.Map)

v0.1.11

Feb 27, 2021

Changes in this version

type Context

+ Errors []error

v0.1.10

Jan 15, 2021

v0.1.9

May 14, 2020

Changes in this version

type Context

+ func (ctx *Context) RunAction(fct ActionHandler, spec m.Map, msg *Message)

type Message

+ func (msg *Message) GetSenderMailbox(ctx *Context) chan Message

v0.1.8

Apr 18, 2020

Changes in this version

+ func FormatTimestamp(t time.Time) string

+ type Address struct

+ Service string

+ Session string

type Context

+ func (ctx *Context) SendAddr(msg *Message, addr Address)

+ func (ctx *Context) WrappedFromJson(jsstr string) WrappedMessage

+ type ContextState interface

+ GetSessionMailbox func(string) chan Message

+ type DefaultState struct

+ func (st *DefaultState) GetSessionMailbox(sid string) chan Message

type Message

+ func (msg *Message) Wrapped() *WrappedMessage

+ type Timestamp time.Time

+ func (t *Timestamp) MarshalText() ([]byte, error)

+ func (t *Timestamp) Unix() int64

+ func (t *Timestamp) UnmarshalText(data []byte) error

+ type WrappedMessage struct

+ Message *Message

+ Timestamp Timestamp

+ func (wm *WrappedMessage) Json(ctx *Context) string

v0.1.7

Apr 9, 2020

Changes in this version

+ var Quit = Message

+ func LoadRegistry(uname string, specs HSpecs)

+ type ActionHandler = func(*Context, m.Map, Message) bool

+ type Context struct

+ Children map[string]*Context

+ Config m.Map

+ DoneCh chan struct{}

+ Home string

+ Logger Logger

+ Name string

+ Parent *Context

+ Self chan Message

+ Services map[string]*Context

+ State interface{}

+ WaitGroup *sync.WaitGroup

+ func ChildContext(pctx *Context, conf m.Map, name string) *Context

+ func RootContext(home string, conf m.Map, logger Logger, name string) *Context

+ func (ctx *Context) GetHandler(name string) Handler

+ func (ctx *Context) GetStep() Step

+ func (ctx *Context) HandleAction(spec m.Map, msg Message) bool

+ func (ctx *Context) HandleDone() bool

+ func (ctx *Context) HandleMsg(msg Message) bool

+ func (ctx *Context) HandleSpec(spec m.Map) bool

+ func (ctx *Context) Log(lvl l.Level, txt string, fields m.Map)

+ func (ctx *Context) LogCatch(txt string, err interface{})

+ func (ctx *Context) LogDebug(txt string, fields m.Map)

+ func (ctx *Context) LogErr(txt string, fields m.Map)

+ func (ctx *Context) LogInfo(txt string, fields m.Map)

+ func (ctx *Context) LogTrace(txt string, fields m.Map)

+ func (ctx *Context) LogWarn(txt string, fields m.Map)

+ func (ctx *Context) Msg(par ...string) msgCtx

+ func (ctx *Context) Run(fct func())

+ func (ctx *Context) RunListener()

+ func (ctx *Context) RunMsg(fct MsgProc, msg Message)

+ func (ctx *Context) RunProc(fct Proc)

+ func (ctx *Context) Send(msg *Message, svcName string)

+ func (ctx *Context) Startup()

+ func (ctx Context) Deadline() (deadline time.Time, ok bool)

+ func (ctx Context) Done() <-chan struct{}

+ func (ctx Context) Err() error

+ func (ctx Context) Value(key interface{}) interface{}

+ type DummyHandler = func(*Context) bool

+ type HSpecs []struct

+ type Handler interface

+ func GetHandler(uname, fname string) Handler

+ type Logger interface

+ GetMaxLevel func() l.Level

+ Log func(l.Level, string, m.Map)

+ SetMaxLevel func(l.Level)

+ type Message struct

+ Action string

+ Class string

+ Domain string

+ Item string

+ Payload Payload

+ Sender chan Message

+ func (msg Message) GetPayload(ctx *Context) m.Map

+ type MsgCtx = msgCtx

+ type MsgHandler = func(*Context, Message) bool

+ type MsgProc = func(*Context, Message)

+ type Payload string

+ type Proc = func(*Context)

+ type Registry map[string]unit

+ func (reg Registry) Add(uname string, fname string, hdlr Handler)

+ type SpecHandler = func(*Context, m.Map) bool

+ type Step = func(*Context) bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL