Documentation
¶
Index ¶
Constants ¶
View Source
const ( KubernetesSourceType = "kubernetes_logs" BlackholeSinkType = "blackhole" InternalMetricsSourceType = "internal_metrics" InternalMetricsSinkType = "prometheus_exporter" OptimizedKubernetesSourceName = "optimizedKubernetesSource" FilterTransformType = "filter" DefaultSourceName = "defaultSource" PodSelectorType = "pod_labels" NamespaceSelectorType = "ns_labels" )
Variables ¶
Functions ¶
func Mapper ¶ added in v0.0.2
func Mapper(c ConfigComponent) (map[string]interface{}, error)
Types ¶
type Builder ¶ added in v0.0.2
type Builder struct {
Name string
Pipelines []pipeline.Pipeline
// contains filtered or unexported fields
}
func NewBuilder ¶ added in v0.0.2
func NewBuilder(vaCtrl *vectoragent.Controller, pipelines ...pipeline.Pipeline) *Builder
func (*Builder) GetByteConfig ¶ added in v0.0.2
type ConfigComponent ¶ added in v0.0.2
type ConfigComponent interface {
GetOptions() map[string]interface{}
}
type Sink ¶ added in v0.0.2
type Sink struct {
Name string
Type string `mapper:"type"`
Inputs []string `mapper:"inputs"`
Options map[string]interface{} `mapstructure:",remain"`
}
func (Sink) GetOptions ¶ added in v0.0.2
type Source ¶ added in v0.0.2
type Source struct {
Name string
Type string `mapper:"type"`
ExtraNamespaceLabelSelector string `mapstructure:"extra_namespace_label_selector" mapper:"extra_namespace_label_selector,omitempty"`
ExtraLabelSelector string `mapstructure:"extra_label_selector" mapper:"extra_label_selector,omitempty"`
ExtraFieldSelector string `mapstructure:"extra_field_selector" mapper:"extra_field_selector,omitempty"`
Options map[string]interface{} `mapstructure:",remain"`
}
func (Source) GetOptions ¶ added in v0.0.2
type Transform ¶ added in v0.0.2
type Transform struct {
Name string
Type string `mapper:"type"`
Inputs []string `mapper:"inputs"`
Condition string `mapper:"condition,omitempty"`
Options map[string]interface{} `mapstructure:",remain"`
}
func (Transform) GetOptions ¶ added in v0.0.2
type VectorConfig ¶ added in v0.0.2
type VectorConfig struct {
DataDir string `mapstructure:"data_dir"`
Api *ApiSpec `mapstructure:"api"`
Sources []*Source `mapstructure:"sources"`
Transforms []*Transform `mapstructure:"transforms"`
Sinks []*Sink `mapstructure:"sinks"`
}
func New ¶
func New(vector *vectorv1alpha1.Vector) *VectorConfig
Click to show internal directories.
Click to hide internal directories.