Versions in this module Expand all Collapse all v1 v1.1.0 Sep 22, 2023 v1.0.9 Sep 22, 2023 Changes in this version + func LogEnumStrings() []string + func LogLevelStrings() []string + type Event = *EventT + func NewCloseEvent(id EventId, hub string, topic string) Event + func NewDataEvent(id EventId, sender any, hub string, topic string, dat any) Event + func (me Event) MarshalObject(entry *phuslu.Entry) + func (me Event) String() string + type EventId int64 + type EventListener struct + func NewEventListener(name string, lsner Listener[K], qSize uint32, topicLogr TopicLogger) *EventListener[K] + func (me *EventListener[K]) SendEvent(evnt Event) + func (me *EventListener[K]) Start() + func (me *EventListener[K]) Stop(stopEvnt Event) + type EventT struct + Close bool + Data any + Hub string + Id EventId + Sender any + Topic string + type Hub = *HubT + func NewHub(name string, logr Logger) Hub + func (me Hub) Close(wait bool) + func (me Hub) GetTopic(name string, evntExample any) TopicBase + func (me Hub) HasTopic(name string) bool + func (me Hub) Logger() HubLogger + func (me Hub) Name() string + func (me Hub) RegisterTopic(topic TopicBase) + type HubLogger = *HubLoggerT + func NewHubLogger(hub string, logr Logger) HubLogger + func (me HubLogger) Hub() string + func (me HubLogger) LogDebug(enm LogEnum, topic string, lsner string) + func (me HubLogger) LogError(enm LogEnum, topic string, lsner string, err any) + func (me HubLogger) LogEventDebug(enm LogEnum, lsner string, evnt Event) + func (me HubLogger) LogEventError(enm LogEnum, lsner string, evnt Event, err any) + func (me HubLogger) LogEventInfo(enm LogEnum, lsner string, evnt Event) + func (me HubLogger) LogInfo(enm LogEnum, topic string, lsner string) + type HubLoggerT struct + type HubT struct + type LevelFilteringLogger = *LevelFilteringLoggerT + func NewLevelFilteringLogger(level LogLevel, target Logger) LevelFilteringLogger + func (me LevelFilteringLogger) LogDebug(enm LogEnum, hub string, topic string, lsner string) + func (me LevelFilteringLogger) LogError(enm LogEnum, hub string, topic string, lsner string, err any) + func (me LevelFilteringLogger) LogEventDebug(enm LogEnum, lsner string, evnt Event) + func (me LevelFilteringLogger) LogEventError(enm LogEnum, lsner string, evnt Event, err any) + func (me LevelFilteringLogger) LogEventInfo(enm LogEnum, lsner string, evnt Event) + func (me LevelFilteringLogger) LogInfo(enm LogEnum, hub string, topic string, lsner string) + func (me LevelFilteringLogger) Target() Logger + type LevelFilteringLoggerT struct + Level LogLevel + type Listener func(sender any, evnt K) + type ListenerLogger = *ListenerLoggerT + func NewListenerLogger(lsner string, logr TopicLogger) ListenerLogger + func (me ListenerLogger) Listener() string + func (me ListenerLogger) LogDebug(enm LogEnum) + func (me ListenerLogger) LogError(enm LogEnum, err any) + func (me ListenerLogger) LogEventDebug(enm LogEnum, evnt Event) + func (me ListenerLogger) LogEventError(enm LogEnum, evnt Event, err any) + func (me ListenerLogger) LogEventInfo(enm LogEnum, evnt Event) + func (me ListenerLogger) LogInfo(enm LogEnum) + type ListenerLoggerT struct + type LogEnum int64 + const EventHandleBegin + const EventHandleErr + const EventHandleOk + const EventPubBegin + const EventPubError + const EventPubOk + const EventSendBegin + const EventSendOk + const HubCloseBegin + const HubCloseOk + const ListenerCloseBegin + const ListenerCloseOk + const ListenerSubErr + const ListenerSubOk + const ListenerUnsubErr + const ListenerUnsubOk + const TopicCloseBegin + const TopicCloseOk + const TopicRegisterBegin + const TopicRegisterOk + func LogEnumString(s string) (LogEnum, error) + func LogEnumValues() []LogEnum + func (i *LogEnum) Scan(value interface{}) error + func (i *LogEnum) UnmarshalGQL(value interface{}) error + func (i *LogEnum) UnmarshalJSON(data []byte) error + func (i *LogEnum) UnmarshalText(text []byte) error + func (i *LogEnum) UnmarshalYAML(unmarshal func(interface{}) error) error + func (i LogEnum) IsALogEnum() bool + func (i LogEnum) MarshalGQL(w io.Writer) + func (i LogEnum) MarshalJSON() ([]byte, error) + func (i LogEnum) MarshalText() ([]byte, error) + func (i LogEnum) MarshalYAML() (interface{}, error) + func (i LogEnum) String() string + func (i LogEnum) Value() (driver.Value, error) + type LogLevel int8 + const LogLevelAnyway + const LogLevelDebug + const LogLevelError + const LogLevelInfo + const LogLevelSilient + func LogLevelString(s string) (LogLevel, error) + func LogLevelValues() []LogLevel + func (i *LogLevel) Scan(value interface{}) error + func (i *LogLevel) UnmarshalGQL(value interface{}) error + func (i *LogLevel) UnmarshalJSON(data []byte) error + func (i *LogLevel) UnmarshalText(text []byte) error + func (i *LogLevel) UnmarshalYAML(unmarshal func(interface{}) error) error + func (i LogLevel) IsALogLevel() bool + func (i LogLevel) MarshalGQL(w io.Writer) + func (i LogLevel) MarshalJSON() ([]byte, error) + func (i LogLevel) MarshalText() ([]byte, error) + func (i LogLevel) MarshalYAML() (interface{}, error) + func (i LogLevel) String() string + func (i LogLevel) Value() (driver.Value, error) + type Logger interface + LogDebug func(enm LogEnum, hub string, topic string, lsner string) + LogError func(enm LogEnum, hub string, topic string, lsner string, err any) + LogEventDebug func(enm LogEnum, lsner string, evnt Event) + LogEventError func(enm LogEnum, lsner string, evnt Event, err any) + LogEventInfo func(enm LogEnum, lsner string, evnt Event) + LogInfo func(enm LogEnum, hub string, topic string, lsner string) + type PubMode byte + const PubModeAsync + const PubModeAuto + const PubModeSync + type Topic interface + Pub func(mode PubMode, sender any, evnt K) + Sub func(name string, lsner Listener[K], qSize uint32) (int, error) + SubP func(name string, lsner Listener[K], qSize uint32) int + func CreateTopic(hub Hub, name string, evntExample K) Topic[K] + func GetTopic(me Hub, name string, evntExample K) Topic[K] + func NewTopic(name string, hub Hub, evntExample K, logr HubLogger) Topic[K] + type TopicBase interface + Close func(wait bool) + CurrEventId func() EventId + EventType func() reflect.Type + Hub func() Hub + Name func() string + NewEventId func() EventId + UnSub func(name string) bool + type TopicImpl struct + func NewTopicImpl(name string, hub Hub, example K, logr HubLogger) *TopicImpl[K] + func (me *TopicImpl[K]) Close(wait bool) + func (me *TopicImpl[K]) CurrEventId() EventId + func (me *TopicImpl[K]) EventType() reflect.Type + func (me *TopicImpl[K]) Hub() Hub + func (me *TopicImpl[K]) Name() string + func (me *TopicImpl[K]) NewEventId() EventId + func (me *TopicImpl[K]) Pub(mode PubMode, sender any, evntData K) + func (me *TopicImpl[K]) Sub(name string, lsner Listener[K], qSize uint32) (int, error) + func (me *TopicImpl[K]) SubP(name string, lsner Listener[K], qSize uint32) int + func (me *TopicImpl[K]) UnSub(name string) bool + type TopicLogger = *TopicLoggerT + func NewTopicLogger(topic string, logr HubLogger) TopicLogger + func (me TopicLogger) LogDebug(enm LogEnum, lsner string) + func (me TopicLogger) LogError(enm LogEnum, lsner string, err any) + func (me TopicLogger) LogEventDebug(enm LogEnum, lsner string, evnt Event) + func (me TopicLogger) LogEventError(enm LogEnum, lsner string, evnt Event, err any) + func (me TopicLogger) LogEventInfo(enm LogEnum, lsner string, evnt Event) + func (me TopicLogger) LogInfo(enm LogEnum, lsner string) + func (me TopicLogger) Topic() string + type TopicLoggerT struct