event

package module

Go to main page

Versions in this module

v1

v1.0.8

Dec 16, 2022

Changes in this version

type LogEnum

+ const EventPubError

v1.0.7

Dec 16, 2022

Changes in this version

type EventT

+ Sender any

v1.0.6

Dec 10, 2022

v1.0.5

Oct 14, 2022

v1.0.4

Sep 30, 2022

Changes in this version

type Topic

+ SubP func(name string, lsner Listener[K], qSize uint32) int

type TopicImpl

+ func (me *TopicImpl[K]) SubP(name string, lsner Listener[K], qSize uint32) int

v1.0.3

Sep 29, 2022

v1.0.2

Sep 29, 2022

v1.0.1

Sep 18, 2022

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, 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

+ 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(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 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, evnt K)

+ Sub 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, evnt K)

+ func (me *TopicImpl[K]) Sub(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

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