event

package module

Go to main page

Versions in this module

v1

v1.2.0

Aug 30, 2025

Changes in this version

+ func FireEventCtx(ctx context.Context, e Event) error

+ func Once(name string, listener Listener, priority ...int)

type BasicEvent

+ func NewEvent(name string, data M) *BasicEvent

+ type ContextAble interface

+ Context func() context.Context

+ WithContext func(ctx context.Context)

+ type ContextTrait struct

+ func (t *ContextTrait) Context() context.Context

+ func (t *ContextTrait) WithContext(ctx context.Context)

type Event

+ func FireCtx(ctx context.Context, name string, params M) (error, Event)

type Manager

+ func (em *Manager) FireCtx(ctx context.Context, name string, params M) (err error, e Event)

+ func (em *Manager) FireEventCtx(ctx context.Context, e Event) (err error)

+ func (em *Manager) MustCloseWait()

+ func (em *Manager) Once(name string, listener Listener, priority ...int)

type OptionFn

+ func WithChannelSize(size int) OptionFn

+ func WithConsumerNum(num int) OptionFn

v1.1.2

Feb 6, 2024

v1.1.1

Jun 10, 2023

Changes in this version

+ func AddEventFc(name string, fc FactoryFunc)

+ func Async(name string, params M)

+ func CloseWait() error

+ func Config(fn ...OptionFn)

+ func FireAsync(e Event)

type BasicEvent

+ func New(name string, data M) *BasicEvent

type Manager

+ func NewM(name string, fns ...OptionFn) *Manager

+ func (em *Manager) CloseWait() error

+ func (em *Manager) Wait() error

v1.1.0

Jun 7, 2023

Changes in this version

+ const AllNode

+ const AnyNode

+ const ModePath

+ const ModeSimple

+ func EnableLock(o *Options)

+ func UsePathMode(o *Options)

type BasicEvent

+ func (e *BasicEvent) Clone() Event

+ type Cloneable interface

+ Clone func() Event

+ type FactoryFunc func() Event

type Manager

+ func Std() *Manager

+ func (em *Manager) AddEventFc(name string, fc FactoryFunc)

+ func (em *Manager) Async(name string, params M)

+ func (em *Manager) Close() error

+ func (em *Manager) FireAsync(e Event)

+ func (em *Manager) FireC(name string, params M)

+ func (em *Manager) WithOptions(fns ...OptionFn) *Manager

+ type OptionFn func(o *Options)

+ type Options struct

+ ChannelSize int

+ ConsumerNum int

+ EnableLock bool

+ MatchMode uint8

v1.0.6

Apr 14, 2022

v1.0.5

Mar 11, 2021

Changes in this version

+ func AddSubscriber(sbr Subscriber)

+ func FireBatch(es ...interface{}) []error

+ func Reset()

type Manager

+ EnableLock bool

+ func (em *Manager) MustTrigger(name string, params M) Event

+ func (em *Manager) Reset()

v1.0.4

Jan 15, 2021

Changes in this version

+ func AsyncFire(e Event)

+ func Listen(name string, listener Listener, priority ...int)

+ func Subscribe(sbr Subscriber)

+ func TriggerEvent(e Event) error

type Event

+ func MustTrigger(name string, params M) Event

+ func Trigger(name string, params M) (error, Event)

type Manager

+ func (em *Manager) Listen(name string, listener Listener, priority ...int)

+ func (em *Manager) Subscribe(sbr Subscriber)

v1.0.3

Jun 8, 2019

v1.0.2

Apr 1, 2019

v1.0.1

Apr 1, 2019

Changes in this version

type Manager

+ func (em *Manager) Listeners() map[string]*ListenerQueue

+ func (em *Manager) ListenersByName(name string) *ListenerQueue

v1.0.0

Jan 4, 2019

Changes in this version

+ const AboveNormal

+ const BelowNormal

+ const High

+ const Low

+ const Max

+ const Min

+ const Normal

+ const Wildcard

+ var DefaultEM = NewManager("default")

+ func AddEvent(e Event)

+ func FireEvent(e Event) error

+ func HasEvent(name string) bool

+ func HasListeners(name string) bool

+ func On(name string, listener Listener, priority ...int)

+ type BasicEvent struct

+ func NewBasic(name string, data M) *BasicEvent

+ func (e *BasicEvent) Abort(abort bool)

+ func (e *BasicEvent) Add(key string, val interface{})

+ func (e *BasicEvent) AttachTo(em ManagerFace)

+ func (e *BasicEvent) Data() map[string]interface{}

+ func (e *BasicEvent) Fill(target interface{}, data M) *BasicEvent

+ func (e *BasicEvent) Get(key string) interface{}

+ func (e *BasicEvent) IsAborted() bool

+ func (e *BasicEvent) Name() string

+ func (e *BasicEvent) Set(key string, val interface{})

+ func (e *BasicEvent) SetData(data M) Event

+ func (e *BasicEvent) SetName(name string) *BasicEvent

+ func (e *BasicEvent) SetTarget(target interface{}) *BasicEvent

+ func (e *BasicEvent) Target() interface{}

+ type ByPriorityItems []*ListenerItem

+ func (ls ByPriorityItems) Len() int

+ func (ls ByPriorityItems) Less(i, j int) bool

+ func (ls ByPriorityItems) Swap(i, j int)

+ type Event interface

+ Abort func(bool)

+ Add func(key string, val interface{})

+ Data func() map[string]interface{}

+ Get func(key string) interface{}

+ IsAborted func() bool

+ Name func() string

+ Set func(key string, val interface{})

+ SetData func(M) Event

+ func Fire(name string, params M) (error, Event)

+ func GetEvent(name string) (Event, bool)

+ func MustFire(name string, params M) Event

+ type Listener interface

+ Handle func(e Event) error

+ type ListenerFunc func(e Event) error

+ func (fn ListenerFunc) Handle(e Event) error

+ type ListenerItem struct

+ Listener Listener

+ Priority int

+ type ListenerQueue struct

+ func (lq *ListenerQueue) Clear()

+ func (lq *ListenerQueue) IsEmpty() bool

+ func (lq *ListenerQueue) Items() []*ListenerItem

+ func (lq *ListenerQueue) Len() int

+ func (lq *ListenerQueue) Push(li *ListenerItem) *ListenerQueue

+ func (lq *ListenerQueue) Remove(listener Listener)

+ func (lq *ListenerQueue) Sort() *ListenerQueue

+ type M map[string]interface

+ type Manager struct

+ func NewManager(name string) *Manager

+ func (em *Manager) AddEvent(e Event)

+ func (em *Manager) AddListener(name string, listener Listener, priority ...int)

+ func (em *Manager) AddSubscriber(sbr Subscriber)

+ func (em *Manager) AsyncFire(e Event)

+ func (em *Manager) AwaitFire(e Event) (err error)

+ func (em *Manager) Clear()

+ func (em *Manager) Fire(name string, params M) (err error, e Event)

+ func (em *Manager) FireBatch(es ...interface{}) (ers []error)

+ func (em *Manager) FireEvent(e Event) (err error)

+ func (em *Manager) GetEvent(name string) (e Event, ok bool)

+ func (em *Manager) HasEvent(name string) bool

+ func (em *Manager) HasListeners(name string) bool

+ func (em *Manager) ListenedNames() map[string]int

+ func (em *Manager) ListenersCount(name string) int

+ func (em *Manager) MustFire(name string, params M) Event

+ func (em *Manager) On(name string, listener Listener, priority ...int)

+ func (em *Manager) RemoveEvent(name string)

+ func (em *Manager) RemoveEvents()

+ func (em *Manager) RemoveListener(name string, listener Listener)

+ func (em *Manager) RemoveListeners(name string)

+ func (em *Manager) Trigger(name string, params M) (error, Event)

+ type ManagerFace interface

+ AddEvent func(Event)

+ Fire func(name string, params M) (error, Event)

+ On func(name string, listener Listener, priority ...int)

+ type Subscriber interface

+ SubscribedEvents func() map[string]interface{}

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