sink

package

v1.3.0 Latest Latest Go to latest Published: Dec 6, 2025 License: MIT Imports: 21 Imported by: 0

Details

View Source

const (
	ExitOnWarningEnv string = "CONNTRACKD_SINK_EXIT_ON_WARNING"
)

View Source

var LokiProtocols = []string{"http", "https"}

View Source

var StreamWriters = []string{"stdout", "stderr", "discard"}

View Source

var SyslogProtocols = []string{"udp", "tcp", "unix", "unixgram", "unixpacket"}

This section is empty.

type Config struct {
	Journal Journal
	Syslog  Syslog
	Loki    Loki
	Stream  Stream
}

type Journal struct {
	Enable bool
}

func (j *Journal) TargetJournal(options *slog.HandlerOptions) (slog.Handler, error)

type Loki struct {
	Enable  bool
	Address string
	Labels  []string
}

func (l *Loki) TargetLoki(options *slog.HandlerOptions) (slog.Handler, error)

type Sink struct {
	Logger *slog.Logger
}

func NewSink(config *Config) (*Sink, error)

type SinkTarget func(*slog.HandlerOptions) (slog.Handler, error)

type Stream struct {
	Enable bool
	Writer string
}

func (s *Stream) TargetStream(options *slog.HandlerOptions) (slog.Handler, error)

type Syslog struct {
	Enable  bool
	Address string
}

func (s *Syslog) TargetSyslog(options *slog.HandlerOptions) (slog.Handler, error)