behavior

package

v0.1.7 Latest Latest Go to latest Published: Apr 9, 2020 License: MIT Imports: 6 Imported by: 13

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

git.sr.ht/~cco/go-integrator

Links

Open Source Insights

Documentation ¶

Overview ¶

Package behavior provides dynamic lookup of functions for handling events like receiving messages and for setting up and running stuff like actors.

Index ¶

Variables
func LoadRegistry(uname string, specs HSpecs)
type ActionHandler
type Context
- 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) Deadline() (deadline time.Time, ok bool)
- func (ctx Context) Done() <-chan struct{}
- func (ctx Context) Err() error
- 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) Value(key interface{}) interface{}
type DummyHandler
type HSpecs
type Handler
- func GetHandler(uname, fname string) Handler
type Logger
type Message
- func (msg Message) GetPayload(ctx *Context) m.Map
type MsgCtx
type MsgHandler
type MsgProc
type Payload
type Proc
type Registry
- func (reg Registry) Add(uname string, fname string, hdlr Handler)
type SpecHandler
type Step

Constants ¶

This section is empty.

Variables ¶

View Source

var Quit = Message{Action: "quit"}

Functions ¶

func LoadRegistry ¶

func LoadRegistry(uname string, specs HSpecs)

Types ¶

type ActionHandler ¶

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

type Context ¶

type Context struct {
	Name      string
	Home      string
	Config    m.Map
	State     interface{}
	Logger    Logger
	Parent    *Context
	Self      chan Message
	DoneCh    chan struct{}
	WaitGroup *sync.WaitGroup
	Children  map[string]*Context
	Services  map[string]*Context
}

func ChildContext ¶

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

func RootContext ¶

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

func (Context) Deadline ¶

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

func (Context) Done ¶

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

func (Context) Err ¶

func (ctx Context) Err() error

func (*Context) GetHandler ¶

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

func (*Context) GetStep ¶

func (ctx *Context) GetStep() Step

func (*Context) HandleAction ¶

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

func (*Context) HandleDone ¶

func (ctx *Context) HandleDone() bool

func (*Context) HandleMsg ¶

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

func (*Context) HandleSpec ¶

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

func (*Context) Log ¶

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

func (*Context) LogCatch ¶

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

func (*Context) LogDebug ¶

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

func (*Context) LogErr ¶

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

func (*Context) LogInfo ¶

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

func (*Context) LogTrace ¶

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

func (*Context) LogWarn ¶

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

func (*Context) Msg ¶

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

func (*Context) Run ¶

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

func (*Context) RunListener ¶

func (ctx *Context) RunListener()

func (*Context) RunMsg ¶

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

func (*Context) RunProc ¶

func (ctx *Context) RunProc(fct Proc)

func (*Context) Send ¶

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

func (*Context) Startup ¶

func (ctx *Context) Startup()

func (Context) Value ¶

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

type DummyHandler ¶

type DummyHandler = func(*Context) bool

type HSpecs ¶

type HSpecs []struct {
	FName    string
	Function Handler
}

type Handler ¶

type Handler interface{}

func GetHandler ¶

func GetHandler(uname, fname string) Handler

type Logger ¶

type Logger interface {
	Log(l.Level, string, m.Map)
	GetMaxLevel() l.Level
	SetMaxLevel(l.Level)
}

type Message ¶

type Message struct {
	Domain  string
	Action  string
	Class   string
	Item    string
	Sender  chan Message
	Payload Payload
}

func (Message) GetPayload ¶

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

type MsgCtx ¶

type MsgCtx = msgCtx

type MsgHandler ¶

type MsgHandler = func(*Context, Message) bool

type MsgProc ¶

type MsgProc = func(*Context, Message)

type Payload ¶

type Payload string

type Proc ¶

type Proc = func(*Context)

type Registry ¶

type Registry map[string]unit

func (Registry) Add ¶

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

type SpecHandler ¶

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

type Step ¶

type Step = func(*Context) bool

Source Files ¶

View all Source files

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