victorialogs

Documentation

Index

• type VLAuthConfiguration
• type VLConfiguration
• type VLSource
  • func (l *VLSource) CanRun() error
  • func (l *VLSource) Configure(config []byte, logger *log.Entry, metricsLevel int) error
  • func (l *VLSource) ConfigureByDSN(dsn string, labels map[string]string, logger *log.Entry, uuid string) error
  • func (l *VLSource) Dump() interface{}
  • func (l *VLSource) GetAggregMetrics() []prometheus.Collector
  • func (l *VLSource) GetMetrics() []prometheus.Collector
  • func (l *VLSource) GetMode() string
  • func (l *VLSource) GetName() string
  • func (l *VLSource) GetUuid() string
  • func (l *VLSource) OneShotAcquisition(ctx context.Context, out chan types.Event, t *tomb.Tomb) error
  • func (l *VLSource) StreamingAcquisition(ctx context.Context, out chan types.Event, t *tomb.Tomb) error
  • func (l *VLSource) SupportedModes() []string
  • func (l *VLSource) UnmarshalConfig(yamlConfig []byte) error

Types

type VLAuthConfiguration

type VLAuthConfiguration struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type VLConfiguration

type VLConfiguration struct {
	URL                               string              `yaml:"url"`    // VictoriaLogs url
	Prefix                            string              `yaml:"prefix"` // VictoriaLogs prefix
	Query                             string              `yaml:"query"`  // LogsQL query
	Limit                             int                 `yaml:"limit"`  // Limit of logs to read
	Since                             time.Duration       `yaml:"since"`
	Headers                           map[string]string   `yaml:"headers"`        // HTTP headers for talking to VictoriaLogs
	WaitForReady                      time.Duration       `yaml:"wait_for_ready"` // Retry interval, default is 10 seconds
	Auth                              VLAuthConfiguration `yaml:"auth"`
	MaxFailureDuration                time.Duration       `yaml:"max_failure_duration"` // Max duration of failure before stopping the source
	configuration.DataSourceCommonCfg `yaml:",inline"`
}

type VLSource

type VLSource struct {
	Config VLConfiguration

	Client *vlclient.VLClient
	// contains filtered or unexported fields
}

func (*VLSource) CanRun

func (l *VLSource) CanRun() error

func (*VLSource) Configure

func (l *VLSource) Configure(config []byte, logger *log.Entry, metricsLevel int) error

func (*VLSource) ConfigureByDSN

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

func (*VLSource) Dump

func (l *VLSource) Dump() interface{}

func (*VLSource) GetAggregMetrics

func (l *VLSource) GetAggregMetrics() []prometheus.Collector

func (*VLSource) GetMetrics

func (l *VLSource) GetMetrics() []prometheus.Collector

func (*VLSource) GetMode

func (l *VLSource) GetMode() string

func (*VLSource) GetName

func (l *VLSource) GetName() string

func (*VLSource) GetUuid

func (l *VLSource) GetUuid() string

func (*VLSource) OneShotAcquisition

func (l *VLSource) OneShotAcquisition(ctx context.Context, out chan types.Event, t *tomb.Tomb) error

OneShotAcquisition reads a set of file and returns when done

func (*VLSource) StreamingAcquisition

func (l *VLSource) StreamingAcquisition(ctx context.Context, out chan types.Event, t *tomb.Tomb) error

func (*VLSource) SupportedModes

func (l *VLSource) SupportedModes() []string

SupportedModes returns the supported modes by the acquisition module

func (*VLSource) UnmarshalConfig

func (l *VLSource) UnmarshalConfig(yamlConfig []byte) error