Versions in this module Expand all Collapse all v0 v0.1.11 Oct 3, 2023 v0.1.10 Oct 2, 2023 Changes in this version + func BoolCaller(handler interface{}, params ...interface{}) + func ByteCaller(handler interface{}, params ...interface{}) + func ByteSliceCaller(handler interface{}, params ...interface{}) + func ErrorCaller(handler interface{}, params ...interface{}) + func Int16Caller(handler interface{}, params ...interface{}) + func Int16SliceCaller(handler interface{}, params ...interface{}) + func Int32Caller(handler interface{}, params ...interface{}) + func Int32SliceCaller(handler interface{}, params ...interface{}) + func Int64Caller(handler interface{}, params ...interface{}) + func Int64SliceCaller(handler interface{}, params ...interface{}) + func Int8Caller(handler interface{}, params ...interface{}) + func Int8SliceCaller(handler interface{}, params ...interface{}) + func IntCaller(handler interface{}, params ...interface{}) + func IntSliceCaller(handler interface{}, params ...interface{}) + func StringCaller(handler interface{}, params ...interface{}) + func StringSliceCaller(handler interface{}, params ...interface{}) + func Uint16Caller(handler interface{}, params ...interface{}) + func Uint16SliceCaller(handler interface{}, params ...interface{}) + func Uint32Caller(handler interface{}, params ...interface{}) + func Uint32SliceCaller(handler interface{}, params ...interface{}) + func Uint64Caller(handler interface{}, params ...interface{}) + func Uint64SliceCaller(handler interface{}, params ...interface{}) + func Uint8Caller(handler interface{}, params ...interface{}) + func Uint8SliceCaller(handler interface{}, params ...interface{}) + func VoidCaller(handler interface{}, params ...interface{}) + func WaitForChannelClosed(ctx context.Context, ch chan struct{}) error + type Closure struct + Fnc interface{} + ID uint64 + func NewClosure(f interface{}) *Closure + type Event struct + func NewEvent(triggerFunc func(handler interface{}, params ...interface{})) *Event + func (ev *Event) Detach(closure *Closure) + func (ev *Event) DetachAll() + func (ev *Event) DetachID(closureID uint64) + func (ev *Event) Hook(closure *Closure, triggerMaxCount ...uint64) + func (ev *Event) HookAfter(closure *Closure, triggerMaxCount ...uint64) + func (ev *Event) HookBefore(closure *Closure, triggerMaxCount ...uint64) + func (ev *Event) Trigger(params ...interface{}) + type Queue struct + func NewQueue() *Queue + func (q *Queue) Clear() + func (q *Queue) Queue(event *Event, params ...interface{}) + func (q *Queue) Trigger() + type SyncEvent struct + func NewSyncEvent() *SyncEvent + func (se *SyncEvent) DeregisterEvent(key interface{}) + func (se *SyncEvent) RegisterEvent(key interface{}) chan struct{} + func (se *SyncEvent) Trigger(key interface{}) + type ThresholdEvent struct + func NewThresholdEvent(options ...ThresholdEventOption) (thresholdEvent *ThresholdEvent) + func ThresholdEventFromBytes(bytes []byte, options ...ThresholdEventOption) (thresholdEvent *ThresholdEvent, consumedBytes int, err error) + func ThresholdEventFromMarshalUtil(marshalUtil *marshalutil.MarshalUtil, options ...ThresholdEventOption) (*ThresholdEvent, error) + func (t *ThresholdEvent) Bytes() []byte + func (t *ThresholdEvent) Level(identifier ThresholdEventIdentifier) (level int) + func (t *ThresholdEvent) Set(identifier ThresholdEventIdentifier, newValue float64) (newLevel int, transition ThresholdEventTransition) + type ThresholdEventCallbackTypecaster func(handler interface{}, identifier interface{}, newLevel int, ...) + type ThresholdEventConfiguration struct + CallbackTypecaster ThresholdEventCallbackTypecaster + IdentifierParser ThresholdEventIdentifierParser + Thresholds []float64 + func NewThresholdEventConfiguration(options ...ThresholdEventOption) (configuration *ThresholdEventConfiguration) + type ThresholdEventIdentifier marshalutil.SimpleBinaryMarshaler + type ThresholdEventIdentifierParser func(marshalUtil *marshalutil.MarshalUtil) (identifier interface{}, err error) + type ThresholdEventOption func(*ThresholdEventConfiguration) + func WithCallbackTypeCaster(callbackTypeCaster ThresholdEventCallbackTypecaster) ThresholdEventOption + func WithIdentifierParser(identifierParser ThresholdEventIdentifierParser) ThresholdEventOption + func WithThresholds(thresholds ...float64) ThresholdEventOption + type ThresholdEventTransition int + const ThresholdLevelDecreased + const ThresholdLevelIncreased + const ThresholdLevelMaintained + func (t ThresholdEventTransition) String() string
Go to main page