lumberjack

Documentation

Overview

Send passing flows to one or more lumberjack (Elastic Beats) servers.

Index

• func DoDebugPrintf(format string, v ...any)
• func NewResilientClient(serverName string, options ServerOptions, reconnectWait time.Duration) *resilientClient
• func NoDebugPrintf(format string, v ...any)
• type Lumberjack
  • func (segment *Lumberjack) New(config map[string]string) segments.Segment
  • func (segment *Lumberjack) Run(wg *sync.WaitGroup)
• type ServerOptions

Functions

func DoDebugPrintf

func DoDebugPrintf(format string, v ...any)

func NewResilientClient

func NewResilientClient(serverName string, options ServerOptions, reconnectWait time.Duration) *resilientClient

func NoDebugPrintf

func NoDebugPrintf(format string, v ...any)

Types

type Lumberjack

type Lumberjack struct {
	segments.BaseSegment
	Servers             map[string]ServerOptions
	BatchSize           int
	BatchTimeout        time.Duration
	BatchDebugPrintf    func(format string, v ...any)
	QueueStatusInterval time.Duration
	ReconnectWait       time.Duration
	LumberjackOut       chan *pb.EnrichedFlow
}

func (*Lumberjack) New

func (segment *Lumberjack) New(config map[string]string) segments.Segment

func (*Lumberjack) Run

func (segment *Lumberjack) Run(wg *sync.WaitGroup)

type ServerOptions

type ServerOptions struct {
	UseTLS            bool
	VerifyCertificate bool
	CompressionLevel  int
}