eventlogger

package module

Go to main page

Versions in this module

v1

v1.14.0

Mar 11, 2026

Changes in this version

type EventLoggerModule

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

v1.13.0

Mar 11, 2026

v1.12.0

Mar 9, 2026

Changes in this version

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

type EventLoggerConfig

+ EventTypeBlacklist []string

+ ExcludeOwnEvents bool

v0

v0.1.2

Sep 6, 2025

v0.1.1

Sep 6, 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 EventLoggerConfig

+ ShutdownDrainTimeout time.Duration

+ ShutdownEmitStopped bool

+ StartupSync bool

type EventLoggerModule

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

v0.1.0

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