sinks

type AsyncMetrics struct {
	Processed  uint64 // Number of events successfully processed
	Dropped    uint64 // Number of events dropped due to overflow
	Errors     uint64 // Number of errors encountered
	BufferSize int    // Current number of events in buffer
	BufferCap  int    // Buffer capacity
}

type AsyncOptions struct {
	// BufferSize is the size of the channel buffer for log events.
	BufferSize int

	// OverflowStrategy defines what to do when the buffer is full.
	OverflowStrategy OverflowStrategy

	// FlushInterval is how often to flush events to the wrapped sink.
	// 0 means flush immediately for each event.
	FlushInterval time.Duration

	// BatchSize is the maximum number of events to batch together.
	// 0 means no batching.
	BatchSize int

	// OnError is called when an error occurs in the background worker.
	OnError func(error)

	// ShutdownTimeout is the maximum time to wait for pending events during shutdown.
	ShutdownTimeout time.Duration
}

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

type BufferedLogEvent struct {
	Event     *core.LogEvent `json:"event"`
	Timestamp int64          `json:"timestamp"`
	Sequence  uint64         `json:"sequence"`
}

type Color string

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

type ConsoleTheme struct {
	// Level colors
	VerboseColor     Color
	DebugColor       Color
	InformationColor Color
	WarningColor     Color
	ErrorColor       Color
	FatalColor       Color

	// Element colors
	TimestampColor   Color
	MessageColor     Color
	PropertyKeyColor Color
	PropertyValColor Color
	BracketColor     Color // Color for brackets and delimiters

	// Formatting
	LevelFormat     string // Format string for level, e.g., "[%s]" or "%s:"
	TimestampFormat string // Time format string
	PropertyFormat  string // Format for properties, e.g., "%s=%v"
}

type DurableOptions struct {
	// BufferPath is the directory where buffer files are stored.
	BufferPath string

	// MaxBufferSize is the maximum size in bytes of the buffer file.
	MaxBufferSize int64

	// MaxBufferFiles is the maximum number of buffer files to keep.
	MaxBufferFiles int

	// RetryInterval is how often to attempt delivery to the wrapped sink.
	RetryInterval time.Duration

	// BatchSize is the number of events to process in each retry batch.
	BatchSize int

	// OnError is called when an error occurs in the background worker.
	OnError func(error)

	// ShutdownTimeout is the maximum time to wait during shutdown.
	ShutdownTimeout time.Duration

	// FlushInterval is how often to flush the buffer file to disk.
	FlushInterval time.Duration

	// ChannelBufferSize is the size of the internal event channel.
	// Defaults to 10000 if not specified.
	ChannelBufferSize int
}

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

type ElasticsearchOption func(*ElasticsearchSink)

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

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

type FilteredSink[T any] struct {
	// contains filtered or unexported fields
}

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

type OverflowStrategy int

type RollingFileOptions struct {
	// FilePath is the path to the log file.
	FilePath string

	// MaxFileSize is the maximum size of a file before rolling (in bytes).
	// 0 means no size limit.
	MaxFileSize int64

	// RollingInterval defines time-based rolling.
	RollingInterval RollingInterval

	// RetainFileCount is the number of rolled files to keep.
	// 0 means keep all files.
	RetainFileCount int

	// CompressRolledFiles enables gzip compression for rolled files.
	CompressRolledFiles bool

	// Formatter to use for formatting log events.
	Formatter interface {
		Format(event *core.LogEvent) ([]byte, error)
	}

	// BufferSize for file writes (default 64KB).
	BufferSize int
}

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

type RollingInterval int

type SeqOption func(*SeqSink)

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

type SplunkOption func(*SplunkSink)

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

type TypedBatchingSink[T any] struct {
	// contains filtered or unexported fields
}

type TypedEvent[T any] struct {
	Event *core.LogEvent
	Data  T
}

type TypedSink[T any] interface {
	EmitTyped(event *core.LogEvent, typedData T) error
	Close() error
}