event

Mar 13, 2024

Changes in this version

+ func Dispatch[K comparable, V any](chains []Chain[V], cmd K, data V)

type AsyncEvent

+ func (a *AsyncEvent[K, V]) Channel(key func(V) K) chan<- V

+ func (a *AsyncEvent[K, V]) Del(name string, cmd K, index int) error

+ type Beat struct

+ Count int

+ func (b *Beat) Abort()

+ type Chain []Handle[V]

type Equal

+ func (e Equal[K, V]) Dispatch(cmd K, data V)

+ type Handle func(*Event, V)

type Regexp

+ func (r Regexp[V]) Add(cmd string, chain Chain[V]) (int, error)

+ func (r Regexp[V]) Del(cmd string, index int) error

+ func (r Regexp[V]) Dispatch(cmd string, data V)

type Rule

+ Dispatch func(cmd K, data V)

Mar 11, 2024

Changes in this version

type Event

+ func (e *Event) OnGet(x ...any)

+ func (e *Event) OnNew()

+ func (e *Event) OnPut()

Nov 22, 2023

Changes in this version

+ const EQUAL

+ func AnySliceTo[T any](x []any) ([]T, error)

+ func Emit[K comparable, V any](handles [][]handle[V], cmd K, data ...any)

type AsyncEvent

+ func (a *AsyncEvent[K, V]) OnEqual(cmd K, handles ...handle[V]) (int, error)

+ type Equal map[K][][]handle[V]

+ func (e Equal[K, V]) Add(cmd K, handles any) (int, error)

+ func (e Equal[K, V]) Del(cmd K, index int)

+ func (e Equal[K, V]) Emit(cmd K, data ...any)

type Regexp

+ func NewRegexp[V any]() Regexp[V]

+ type Rule interface

+ Add func(cmd K, handles any) (int, error)

+ Del func(cmd K, index int)

+ Emit func(cmd K, data ...any)

Oct 28, 2023

Changes in this version

+ const COMMAND

+ const REGEXP

+ var ErrHandles = errors.New("wrong type of handles")

+ var ErrNoRule = errors.New("no rule")

+ type All [][]handle[any]

+ func (a *All[K]) Add(cmd K, handles any) (int, error)

+ func (a *All[K]) Del(cmd K, index int)

+ func (a *All[K]) Emit(cmd K, data ...any)

type AsyncEvent

+ func (a *AsyncEvent[K, V]) Add(name string, cmd K, handles ...any) (int, error)

+ func (a *AsyncEvent[K, V]) Rule(name string) rule[K]

+ type Command map[K][][]handle[V]

+ func (c Command[K, V]) Add(cmd K, handles any) (int, error)

+ func (c Command[K, V]) Del(cmd K, index int)

+ func (c Command[K, V]) Emit(cmd K, data ...any)

+ type Regexp struct

+ func (r Regexp[V]) Emit(cmd string, data ...any)

+ func (r Regexp[V]) Match(cmd, key string) bool

Sep 11, 2023

Changes in this version

+ const ALL

+ const MIN

+ func Heartbeat(initdead, keepalive float64, f func(*Event))

+ func OnlyData(handle func(T)) func(*Event)

+ func WithData(handles ...func(*Event, T)) func(*Event)

+ type AsyncEvent struct

+ func New(all K) AsyncEvent[K]

+ func (a *AsyncEvent[K]) Dispatch(cmd K, data any)

+ func (a *AsyncEvent[K]) On(name string, cmd K, handles ...func(*Event)) func()

+ func (a *AsyncEvent[K]) OnAll(handles ...func(*Event)) func()

+ func (a *AsyncEvent[K]) OnCommand(cmd K, handles ...func(*Event)) func()

+ func (a *AsyncEvent[K]) Register(name string, match func(cmd, key K) bool)

+ type AsyncEventS struct

+ func Default() AsyncEventS

+ func (a *AsyncEventS) OnRegexp(pattern string, handles ...func(*Event)) func()

+ type Event struct

+ func (e *Event) Abort()

+ func (e *Event) Cmd() string

+ func (e *Event) Data(x any) error

+ func (e *Event) Get(name string, x any, _default any) error

+ func (e *Event) New()

+ func (e *Event) Reset()

+ func (e *Event) Set(x ...any)

+ func (e *Event) Store(name string, value any)

+ func (e Event) String() string