eventsink

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 29, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const SPLUNK_HEC_FIELDS_SUPPORT_VERSION = "6.4"

Variables

This section is empty.

Functions

This section is empty.

Types

type ParseConfig added in v1.3.0

type ParseConfig = fevents.Config

type Sink

type Sink interface {
	Open() error
	Close() error
	Write(fields *events.Envelope) error
}

type Splunk

type Splunk struct {
	FirehoseDroppedEvents utils.Counter
	SplunkDroppedEvents   utils.Counter
	// contains filtered or unexported fields
}

func NewSplunk

func NewSplunk(writers []eventwriter.Writer, config *SplunkConfig, parseConfig *ParseConfig, appCache cache.Cache) *Splunk

func (*Splunk) Close

func (s *Splunk) Close() error

func (*Splunk) Log

func (s *Splunk) Log(message lager.LogFormat)

Log implements lager.Sink required interface

func (*Splunk) LogStatus added in v1.3.0

func (s *Splunk) LogStatus()

func (*Splunk) Open

func (s *Splunk) Open() error

func (*Splunk) Write

func (s *Splunk) Write(fields *events.Envelope) error

type SplunkConfig

type SplunkConfig struct {
	FlushInterval           time.Duration
	QueueSize               int // consumer queue buffer size
	BatchSize               int
	Retries                 int // No of retries to post events to HEC before dropping events
	Hostname                string
	SubscriptionID          string
	ExtraFields             map[string]string
	TraceLogging            bool
	UUID                    string
	Logger                  lager.Logger
	StatusMonitorInterval   time.Duration
	LoggingIndex            string
	RefreshSplunkConnection bool
	KeepAliveTimer          time.Duration
}

type Std

type Std struct{}

func (*Std) Close

func (l *Std) Close() error

func (*Std) Open

func (l *Std) Open() error

func (*Std) Write

func (l *Std) Write(fields *events.Envelope) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL