eventlogger

Documentation

Index

• type Config
• type EventLogger
  • func NewEventLogger(log *zap.Logger, config *Config, eventsStreaming *event.EventsStreaming, ...) *EventLogger
  • func (eventLogger *EventLogger) Listen()

Types

type Config

type Config struct {
	DatabaseAddress string   `toml:"database_address"`
	DatabaseName    string   `toml:"database_name"`
	NATSClusterID   string   `toml:"nats_cluster_id"`
	NATSURL         string   `toml:"nats_url"`
	NATSClientID    string   `toml:"nats_client_id"`
	Subscribes      []string `toml:"subscribes"`
}

Config of EventLogger service.

type EventLogger

type EventLogger struct {
	// contains filtered or unexported fields
}

EventLogger defines event logging NATS subscriber service.

func NewEventLogger

func NewEventLogger(log *zap.Logger, config *Config, eventsStreaming *event.EventsStreaming, eventRepository event.Repository) *EventLogger

NewEventLogger returns new event logging service.

func (*EventLogger) Listen

func (eventLogger *EventLogger) Listen()

Listen for events to log.