syslogacquisition

package
v1.7.4 Latest Latest
Warning

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

Go to latest
Published: Dec 3, 2025 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrUnrecognized = errors.New("unrecognized syslog message")

Functions

This section is empty.

Types

type Configuration added in v1.7.4

type Configuration struct {
	Proto                             string `yaml:"protocol,omitempty"`
	Port                              int    `yaml:"listen_port,omitempty"`
	Addr                              string `yaml:"listen_addr,omitempty"`
	MaxMessageLen                     int    `yaml:"max_message_len,omitempty"`
	DisableRFCParser                  bool   `yaml:"disable_rfc_parser,omitempty"` // if true, we don't try to be smart and just remove the PRI
	configuration.DataSourceCommonCfg `yaml:",inline"`
}

func ConfigurationFromYAML added in v1.7.4

func ConfigurationFromYAML(y []byte) (Configuration, error)

func (*Configuration) SetDefaults added in v1.7.4

func (c *Configuration) SetDefaults()

func (*Configuration) Validate added in v1.7.4

func (c *Configuration) Validate() error

type ParseError added in v1.7.4

type ParseError struct {
	Reason     error
	RawMessage []byte
	// keep the both attempts for ErrUnrecognized
	RFC3164 error
	RFC5424 error
}

func (*ParseError) Error added in v1.7.4

func (e *ParseError) Error() string

func (*ParseError) Fields added in v1.7.4

func (e *ParseError) Fields() logrus.Fields

func (*ParseError) Unwrap added in v1.7.4

func (e *ParseError) Unwrap() error

type Source added in v1.7.4

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

func (*Source) CanRun added in v1.7.4

func (*Source) CanRun() error

func (*Source) Configure added in v1.7.4

func (s *Source) Configure(_ context.Context, yamlConfig []byte, logger *log.Entry, metricsLevel metrics.AcquisitionMetricsLevel) error

func (*Source) Dump added in v1.7.4

func (s *Source) Dump() any

func (*Source) GetAggregMetrics added in v1.7.4

func (*Source) GetAggregMetrics() []prometheus.Collector

func (*Source) GetMetrics added in v1.7.4

func (*Source) GetMetrics() []prometheus.Collector

func (*Source) GetMode added in v1.7.4

func (s *Source) GetMode() string

func (*Source) GetName added in v1.7.4

func (*Source) GetName() string

func (*Source) GetUuid added in v1.7.4

func (s *Source) GetUuid() string

func (*Source) Stream added in v1.7.4

func (s *Source) Stream(ctx context.Context, out chan pipeline.Event) error

func (*Source) UnmarshalConfig added in v1.7.4

func (s *Source) UnmarshalConfig(yamlConfig []byte) error

Directories

Path Synopsis
internal

Jump to

Keyboard shortcuts

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