Documentation
¶
Index ¶
- type Configuration
- type Source
- func (*Source) CanRun() error
- func (s *Source) Configure(_ context.Context, yamlConfig []byte, logger *log.Entry, ...) error
- func (s *Source) ConfigureByDSN(_ context.Context, dsn string, labels map[string]string, 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) IsTailing(filename string) bool
- func (s *Source) OneShotAcquisition(_ context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (s *Source) RemoveTail(filename string)
- func (s *Source) StreamingAcquisition(_ context.Context, out chan pipeline.Event, t *tomb.Tomb) error
- func (s *Source) UnmarshalConfig(yamlConfig []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configuration ¶ added in v1.7.4
type Configuration struct {
Filenames []string
ExcludeRegexps []string `yaml:"exclude_regexps"`
Filename string
ForceInotify bool `yaml:"force_inotify"`
MaxBufferSize int `yaml:"max_buffer_size"`
PollWithoutInotify *bool `yaml:"poll_without_inotify"`
DiscoveryPollEnable bool `yaml:"discovery_poll_enable"`
DiscoveryPollInterval time.Duration `yaml:"discovery_poll_interval"`
configuration.DataSourceCommonCfg `yaml:",inline"`
}
type Source ¶ added in v1.7.4
type Source struct {
// contains filtered or unexported fields
}
func (*Source) ConfigureByDSN ¶ added in v1.7.4
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) IsTailing ¶ added in v1.7.4
IsTailing returns whether a given file is currently being tailed. For testing purposes. It is case sensitive and path delimiter sensitive (filename must match exactly what the filename would look being OS specific)
func (*Source) OneShotAcquisition ¶ added in v1.7.4
OneShotAcquisition reads a set of file and returns when done
func (*Source) RemoveTail ¶ added in v1.7.4
RemoveTail is used for testing to simulate a dead tailer. For testing purposes. It is case sensitive and path delimiter sensitive (filename must match exactly what the filename would look being OS specific)
func (*Source) StreamingAcquisition ¶ added in v1.7.4
func (*Source) UnmarshalConfig ¶ added in v1.7.4
Source Files
Click to show internal directories.
Click to hide internal directories.