Documentation
¶
Overview ¶
Send passing flows to one or more lumberjack (Elastic Beats) servers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DoDebugPrintf ¶
func NewResilientClient ¶
func NewResilientClient(serverName string, options ServerOptions, reconnectWait time.Duration) *resilientClient
func NoDebugPrintf ¶
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) Run ¶
func (segment *Lumberjack) Run(wg *sync.WaitGroup)
type ServerOptions ¶
Click to show internal directories.
Click to hide internal directories.