Documentation
¶
Index ¶
- type VLAuthConfiguration
- type VLConfiguration
- type VLSource
- func (l *VLSource) CanRun() error
- func (l *VLSource) Configure(config []byte, logger *log.Entry, metricsLevel metrics.AcquisitionMetricsLevel) 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VLAuthConfiguration ¶
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) ConfigureByDSN ¶
func (*VLSource) GetAggregMetrics ¶
func (l *VLSource) GetAggregMetrics() []prometheus.Collector
func (*VLSource) GetMetrics ¶
func (l *VLSource) GetMetrics() []prometheus.Collector
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 (*VLSource) SupportedModes ¶
SupportedModes returns the supported modes by the acquisition module
func (*VLSource) UnmarshalConfig ¶
Click to show internal directories.
Click to hide internal directories.