logger

README

logger

Documentation

Index

• type Exporter
• type LogDispatcher
  • func NewLogDispatcher(serviceName string, bufferSize int, walPath string) (*LogDispatcher, error)
  • func (ld *LogDispatcher) Audit(actor, action, message string)
  • func (ld *LogDispatcher) Close()
  • func (ld *LogDispatcher) Debug(message string)
  • func (ld *LogDispatcher) Error(message string)
  • func (ld *LogDispatcher) Info(message string)
  • func (ld *LogDispatcher) RegisterExporter(e Exporter)
• type LogItem

Types

type Exporter

type Exporter interface {
	Export(item LogItem) error
}

Exporter defines the interface for custom log targets (SIEM, RPC, etc.)

type LogDispatcher

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

LogDispatcher manages the async pipeline and exporter registry.

func NewLogDispatcher

func NewLogDispatcher(serviceName string, bufferSize int, walPath string) (*LogDispatcher, error)

NewLogDispatcher initializes the pub/sub logging system.

func (*LogDispatcher) Audit

func (ld *LogDispatcher) Audit(actor, action, message string)

func (*LogDispatcher) Close

func (ld *LogDispatcher) Close()

func (*LogDispatcher) Debug

func (ld *LogDispatcher) Debug(message string)

func (*LogDispatcher) Error

func (ld *LogDispatcher) Error(message string)

func (*LogDispatcher) Info

func (ld *LogDispatcher) Info(message string)

func (*LogDispatcher) RegisterExporter

func (ld *LogDispatcher) RegisterExporter(e Exporter)

RegisterExporter adds a new destination (e.g., SIEM, RPC) to the dispatcher.

type LogItem

type LogItem struct {
	Timestamp int64  `json:"timestamp"`
	Level     string `json:"level"`
	Message   string `json:"message"`
	Service   string `json:"service"`
	Actor     string `json:"actor,omitempty"`
	Action    string `json:"action,omitempty"`
}

LogItem represents a structured log entry.