eventlogger

package module

Go to main page

Versions in this module

v0

v0.5.0

Oct 29, 2025

Changes in this version

type EventLoggerConfig

+ EventTypeBlacklist []string

+ ExcludeOwnEvents bool

v0.4.0

Oct 9, 2025

Changes in this version

+ var ErrQueueCorruption = errors.New("event queue corruption: empty queue marked as full")

v0.3.0

Oct 2, 2025

v0.2.4

Oct 1, 2025

v0.2.3

Aug 30, 2025

v0.2.2

Aug 29, 2025

v0.2.1

Aug 25, 2025

Changes in this version

type EventLoggerConfig

+ ShutdownDrainTimeout time.Duration

+ ShutdownEmitStopped bool

+ StartupSync bool

v0.2.0

Aug 20, 2025

Changes in this version

+ const EventTypeBufferFull

+ const EventTypeConfigLoaded

+ const EventTypeEventDropped

+ const EventTypeEventProcessed

+ const EventTypeEventReceived

+ const EventTypeLoggerStarted

+ const EventTypeLoggerStopped

+ const EventTypeOutputError

+ const EventTypeOutputRegistered

+ const EventTypeOutputSuccess

+ var ErrNoSubjectForEventEmission = errors.New("no subject available for event emission")

type EventLoggerModule

+ func (m *EventLoggerModule) GetRegisteredEventTypes() []string

v0.1.1

Aug 11, 2025

v0.1.0

Jul 31, 2025

Changes in this version

+ const ModuleName

+ const ServiceName

+ var ErrEventBufferFull = errors.New("event buffer is full")

+ var ErrFileNotOpen = errors.New("file not open")

+ var ErrInvalidFlushInterval = errors.New("invalid flush interval")

+ var ErrInvalidFormat = errors.New("invalid log format")

+ var ErrInvalidLogLevel = errors.New("invalid log level")

+ var ErrInvalidOutputType = errors.New("invalid output target type")

+ var ErrInvalidSyslogNetwork = errors.New("invalid syslog network type")

+ var ErrLoggerDoesNotEmitEvents = errors.New("event logger module does not emit events")

+ var ErrLoggerNotStarted = errors.New("event logger not started")

+ var ErrMissingFileConfig = errors.New("missing file configuration for file output target")

+ var ErrMissingFilePath = errors.New("missing file path for file output target")

+ var ErrMissingSyslogConfig = errors.New("missing syslog configuration for syslog output target")

+ var ErrOutputTargetFailed = errors.New("output target failed")

+ var ErrSyslogWriterNotInit = errors.New("syslog writer not initialized")

+ var ErrUnknownOutputTargetType = errors.New("unknown output target type")

+ func NewModule() modular.Module

+ type ConsoleTarget struct

+ func NewConsoleTarget(config OutputTargetConfig, logger modular.Logger) *ConsoleTarget

+ func (c *ConsoleTarget) Flush() error

+ func (c *ConsoleTarget) Start(ctx context.Context) error

+ func (c *ConsoleTarget) Stop(ctx context.Context) error

+ func (c *ConsoleTarget) WriteEvent(entry *LogEntry) error

+ type ConsoleTargetConfig struct

+ Timestamps bool

+ UseColor bool

+ type EventLoggerConfig struct

+ BufferSize int

+ Enabled bool

+ EventTypeFilters []string

+ FlushInterval string

+ Format string

+ IncludeMetadata bool

+ IncludeStackTrace bool

+ LogLevel string

+ OutputTargets []OutputTargetConfig

+ func (c *EventLoggerConfig) Validate() error

+ type EventLoggerModule struct

+ func (m *EventLoggerModule) Constructor() modular.ModuleConstructor

+ func (m *EventLoggerModule) Dependencies() []string

+ func (m *EventLoggerModule) EmitEvent(ctx context.Context, event cloudevents.Event) error

+ func (m *EventLoggerModule) Init(app modular.Application) error

+ func (m *EventLoggerModule) Name() string

+ func (m *EventLoggerModule) ObserverID() string

+ func (m *EventLoggerModule) OnEvent(ctx context.Context, event cloudevents.Event) error

+ func (m *EventLoggerModule) ProvidesServices() []modular.ServiceProvider

+ func (m *EventLoggerModule) RegisterConfig(app modular.Application) error

+ func (m *EventLoggerModule) RegisterObservers(subject modular.Subject) error

+ func (m *EventLoggerModule) RequiresServices() []modular.ServiceDependency

+ func (m *EventLoggerModule) Start(ctx context.Context) error

+ func (m *EventLoggerModule) Stop(ctx context.Context) error

+ type FileTarget struct

+ func NewFileTarget(config OutputTargetConfig, logger modular.Logger) (*FileTarget, error)

+ func (f *FileTarget) Flush() error

+ func (f *FileTarget) Start(ctx context.Context) error

+ func (f *FileTarget) Stop(ctx context.Context) error

+ func (f *FileTarget) WriteEvent(entry *LogEntry) error

+ type FileTargetConfig struct

+ Compress bool

+ MaxAge int

+ MaxBackups int

+ MaxSize int

+ Path string

+ type LogEntry struct

+ Data interface{}

+ Level string

+ Metadata map[string]interface{}

+ Source string

+ Timestamp time.Time

+ Type string

+ type OutputTarget interface

+ Flush func() error

+ Start func(ctx context.Context) error

+ Stop func(ctx context.Context) error

+ WriteEvent func(entry *LogEntry) error

+ func NewOutputTarget(config OutputTargetConfig, logger modular.Logger) (OutputTarget, error)

+ type OutputTargetConfig struct

+ Console *ConsoleTargetConfig

+ File *FileTargetConfig

+ Format string

+ Level string

+ Syslog *SyslogTargetConfig

+ Type string

+ func (o *OutputTargetConfig) Validate() error

+ type OutputTargetError struct

+ Err error

+ Index int

+ func NewOutputTargetError(index int, err error) *OutputTargetError

+ func (e *OutputTargetError) Error() string

+ func (e *OutputTargetError) Unwrap() error

+ type SyslogTarget struct

+ func NewSyslogTarget(config OutputTargetConfig, logger modular.Logger) (*SyslogTarget, error)

+ func (s *SyslogTarget) Flush() error

+ func (s *SyslogTarget) Start(ctx context.Context) error

+ func (s *SyslogTarget) Stop(ctx context.Context) error

+ func (s *SyslogTarget) WriteEvent(entry *LogEntry) error

+ type SyslogTargetConfig struct

+ Address string

+ Facility string

+ Network string

+ Tag string

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