fileacquisition

Documentation

Index

• type FileConfiguration
• type FileSource
  • func (f *FileSource) CanRun() error
  • func (f *FileSource) Configure(yamlConfig []byte, logger *log.Entry, MetricsLevel int) error
  • func (f *FileSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry, uuid string) error
  • func (f *FileSource) Dump() interface{}
  • func (f *FileSource) GetAggregMetrics() []prometheus.Collector
  • func (f *FileSource) GetMetrics() []prometheus.Collector
  • func (f *FileSource) GetMode() string
  • func (f *FileSource) GetName() string
  • func (f *FileSource) GetUuid() string
  • func (f *FileSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (f *FileSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (f *FileSource) SupportedModes() []string
  • func (f *FileSource) UnmarshalConfig(yamlConfig []byte) error

Types

type FileConfiguration

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

type FileSource

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

func (*FileSource) CanRun

func (f *FileSource) CanRun() error

func (*FileSource) Configure

func (f *FileSource) Configure(yamlConfig []byte, logger *log.Entry, MetricsLevel int) error

func (*FileSource) ConfigureByDSN

func (f *FileSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry, uuid string) error

func (*FileSource) Dump

func (f *FileSource) Dump() interface{}

func (*FileSource) GetAggregMetrics

func (f *FileSource) GetAggregMetrics() []prometheus.Collector

func (*FileSource) GetMetrics

func (f *FileSource) GetMetrics() []prometheus.Collector

func (*FileSource) GetMode

func (f *FileSource) GetMode() string

func (*FileSource) GetName

func (f *FileSource) GetName() string

func (*FileSource) GetUuid

func (f *FileSource) GetUuid() string

func (*FileSource) OneShotAcquisition

func (f *FileSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error

OneShotAcquisition reads a set of file and returns when done

func (*FileSource) StreamingAcquisition

func (f *FileSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*FileSource) SupportedModes

func (f *FileSource) SupportedModes() []string

SupportedModes returns the supported modes by the acquisition module

func (*FileSource) UnmarshalConfig

func (f *FileSource) UnmarshalConfig(yamlConfig []byte) error