Documentation
¶
Index ¶
- Variables
- type Configuration
- type ParseError
- type Source
- func (*Source) CanRun() error
- func (s *Source) Configure(_ context.Context, yamlConfig []byte, logger *log.Entry, ...) error
- func (s *Source) Dump() any
- func (*Source) GetAggregMetrics() []prometheus.Collector
- func (*Source) GetMetrics() []prometheus.Collector
- func (s *Source) GetMode() string
- func (*Source) GetName() string
- func (s *Source) GetUuid() string
- func (s *Source) Stream(ctx context.Context, out chan pipeline.Event) error
- func (s *Source) UnmarshalConfig(yamlConfig []byte) error
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) 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) UnmarshalConfig ¶ added in v1.7.4
Click to show internal directories.
Click to hide internal directories.