syslogacquisition

Documentation

Index

• type SyslogConfiguration
• type SyslogSource
  • func (s *SyslogSource) CanRun() error
  • func (s *SyslogSource) Configure(yamlConfig []byte, logger *log.Entry) error
  • func (s *SyslogSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry) error
  • func (s *SyslogSource) Dump() interface{}
  • func (s *SyslogSource) GetAggregMetrics() []prometheus.Collector
  • func (s *SyslogSource) GetMetrics() []prometheus.Collector
  • func (s *SyslogSource) GetMode() string
  • func (s *SyslogSource) GetName() string
  • func (s *SyslogSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (s *SyslogSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error

Types

type SyslogConfiguration

type SyslogConfiguration 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"`
	configuration.DataSourceCommonCfg `yaml:",inline"`
}

type SyslogSource

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

func (*SyslogSource) CanRun

func (s *SyslogSource) CanRun() error

func (*SyslogSource) Configure

func (s *SyslogSource) Configure(yamlConfig []byte, logger *log.Entry) error

func (*SyslogSource) ConfigureByDSN

func (s *SyslogSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry) error

func (*SyslogSource) Dump

func (s *SyslogSource) Dump() interface{}

func (*SyslogSource) GetAggregMetrics

func (s *SyslogSource) GetAggregMetrics() []prometheus.Collector

func (*SyslogSource) GetMetrics

func (s *SyslogSource) GetMetrics() []prometheus.Collector

func (*SyslogSource) GetMode

func (s *SyslogSource) GetMode() string

func (*SyslogSource) GetName

func (s *SyslogSource) GetName() string

func (*SyslogSource) OneShotAcquisition

func (s *SyslogSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*SyslogSource) StreamingAcquisition

func (s *SyslogSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error