event

May 20, 2026

Changes in this version

+ var ErrEventNotRunning = errors.New("event is not running")

+ var ErrEventQueueFull = errors.New("event queue is full")

+ var ErrEventRunning = errors.New("event is running")

+ var ErrInvalidEvent = errors.New("invalid event name")

+ var ErrInvalidEventPayload = errors.New("invalid event payload")

+ var ErrNoConnection = errors.New("invalid event connection")

+ func DurationSetting(setting Map, key string, def time.Duration) time.Duration

+ func Int64Setting(setting Map, key string, def int64) int64

+ func IntSetting(setting Map, key string, def int) int

+ func StringSetting(setting Map, key, def string) string

type Config

+ DrainTimeout time.Duration

+ Queue int

+ QueuePolicy string

+ Workers int

type Context

+ func (ctx *Context) Retry(res Res)

+ type PayloadError struct

+ Event string

+ Result Res

+ func (err *PayloadError) Error() string

+ func (err *PayloadError) Unwrap() error

May 19, 2026

Changes in this version

+ func BroadcastToWithMeta(meta *infra.Meta, conn, name string, values ...Map) error

+ func BroadcastWithMeta(meta *infra.Meta, name string, values ...Map) error

+ func PublishToWithMeta(meta *infra.Meta, conn, name string, values ...Map) error

+ func PublishWithMeta(meta *infra.Meta, name string, values ...Map) error

type Context

+ func (ctx *Context) Broadcast(name string, values ...Map) error

+ func (ctx *Context) BroadcastTo(conn, name string, values ...Map) error

+ func (ctx *Context) Publish(name string, values ...Map) error

+ func (ctx *Context) PublishTo(conn, name string, values ...Map) error

type Instance

+ func (inst *Instance) ServeSync(name string, data []byte) (ok bool)

Mar 1, 2026

Changes in this version

+ func Broadcast(name string, values ...Map) error

+ func BroadcastTo(conn, name string, values ...Map) error

+ func RegisterConfig(name string, cfg Config)

+ func RegisterConfigs(cfgs Configs)

+ func RegisterDriver(name string, driver Driver)

+ type Connection interface

+ Close func() error

+ Open func() error

+ Publish func(name string, data []byte) error

+ Register func(name, group string) error

+ Start func() error

+ Stop func() error

type Context

+ func (ctx *Context) Error(res Res)

type Declare

+ Desc string

type Event

+ Desc string

+ func (Event) RegistryComponent() string

+ type Events map[string]Event

+ func (Events) RegistryComponent() string

type Filter

+ Desc string

type Handler

+ Desc string

type Module

+ func (m *Module) Close()

+ func (m *Module) Open()

+ func (m *Module) RegisterConfig(name string, cfg Config)

+ func (m *Module) RegisterConfigs(configs Configs)

+ func (m *Module) RegisterDeclare(name string, cfg Declare)

+ func (m *Module) RegisterDriver(name string, driver Driver)

+ func (m *Module) RegisterEvent(name string, cfg Event)

+ func (m *Module) RegisterEvents(prefix string, events Events)

+ func (m *Module) RegisterFilter(name string, cfg Filter)

+ func (m *Module) RegisterHandler(name string, cfg Handler)

+ func (m *Module) Setup()

+ func (m *Module) Start()

+ func (m *Module) Stop()

Mar 28, 2023

Changes in this version

+ const NAME

+ var ErrInvalidConnection = errors.New("Invalid event connection.")

+ var ErrInvalidDeclare = errors.New("Invalid event declare.")

+ var ErrInvalidMsg = errors.New("Invalid event msg.")

+ var ErrInvalidWeight = errors.New("Invalid event connection weight.")

+ func Publish(name string, values ...Map) error

+ func PublishTo(conn, name string, values ...Map) error

+ type Config struct

+ Codec string

+ Driver string

+ External bool

+ Prefix string

+ Setting Map

+ Weight int

+ type Configs map[string]Config

+ type Connect interface

+ Close func() error

+ Health func() (Health, error)

+ Open func() error

+ Publish func(name string, data []byte) error

+ Register func(name, group string) error

+ Start func() error

+ Stop func() error

+ type Context struct

+ Args Map

+ Body Any

+ Config *Event

+ Locals Map

+ Name string

+ Setting Map

+ Value Map

+ func (ctx *Context) Denied(res Res)

+ func (ctx *Context) Erred(res Res)

+ func (ctx *Context) Failed(res Res)

+ func (ctx *Context) Found()

+ func (ctx *Context) Next()

+ type Declare struct

+ Alias []string

+ Args Vars

+ Name string

+ Nullable bool

+ Text string

+ type Driver interface

+ Connect func(*Instance) (Connect, error)

+ type Event struct

+ Action ctxFunc

+ Actions []ctxFunc

+ Alias []string

+ Args Vars

+ Coding bool

+ Connect string

+ Denied ctxFunc

+ Error ctxFunc

+ Failed ctxFunc

+ Found ctxFunc

+ Group bool

+ Name string

+ Nullable bool

+ Setting Map

+ Text string

+ type Filter struct

+ Execute ctxFunc

+ Name string

+ Request ctxFunc

+ Response ctxFunc

+ Serve ctxFunc

+ Text string

+ type Handler struct

+ Denied ctxFunc

+ Error ctxFunc

+ Failed ctxFunc

+ Found ctxFunc

+ Name string

+ Text string

+ type Health struct

+ Workload int64

+ type Instance struct

+ Config Config

+ Name string

+ Setting Map

+ func (this *Instance) Serve(name string, data []byte)

+ func (this *Instance) Submit(next func())

+ type Module struct

+ func (module *Module) Declare(name string, config Declare)

+ func (module *Module) Driver(name string, driver Driver)

+ func (module *Module) Event(name string, config Event)

+ func (module *Module) Filter(name string, config Filter)

+ func (module *Module) Handler(name string, config Handler)

+ func (this *Module) Config(name string, config Config)

+ func (this *Module) Configs(config Configs)

+ func (this *Module) Configure(global Map)

+ func (this *Module) Connect()

+ func (this *Module) Initialize()

+ func (this *Module) Launch()

+ func (this *Module) Publish(name string, values ...Map) error

+ func (this *Module) PublishTo(conn, name string, values ...Map) error

+ func (this *Module) Register(name string, value Any)

+ func (this *Module) Terminate()