Documentation
¶
Index ¶
Constants ¶
View Source
const ( // types KubernetesSourceType = "kubernetes_logs" BlackholeSinkType = "blackhole" InternalMetricsSourceType = "internal_metrics" InternalMetricsSinkType = "prometheus_exporter" // default names DefaultSourceName = "defaultSource" DefaultSinkName = "defaultSink" DefaultInternalMetricsSourceName = "internalMetricsSource" DefaultInternalMetricsSinkName = "internalMetricsSink" )
Variables ¶
Functions ¶
func BuildByteConfig ¶
func BuildByteConfig(vaCtrl *vectoragent.Controller, pipelines ...pipeline.Pipeline) ([]byte, error)
func UnmarshalJson ¶
func UnmarshalJson(spec vectorv1alpha1.VectorPipelineSpec, p *PipelineConfig) error
Types ¶
type PipelineConfig ¶
type Source ¶
type Source struct {
Name string `yaml:"-"`
Type string `mapstructure:"type" yaml:"type"`
ExtraNamespaceLabelSelector string `mapstructure:"extra_namespace_label_selector" yaml:"extra_namespace_label_selector,omitempty"`
ExtraLabelSelector string `mapstructure:"extra_label_selector" yaml:"extra_label_selector,omitempty"`
ExtraFieldSelector string `mapstructure:"extra_field_selector" yaml:"extra_field_selector,omitempty"`
UseApiServerCache bool `mapstructure:"use_apiserver_cache" yaml:"use_apiserver_cache,omitempty"`
Options map[string]interface{} `mapstructure:",remain" yaml:",inline,omitempty"`
}
type VectorConfig ¶
type VectorConfig struct {
DataDir string `yaml:"data_dir"`
Api *ApiSpec `yaml:"api"`
PipelineConfig `yaml:",inline"`
}
func BuildConfig ¶
func BuildConfig(vaCtrl *vectoragent.Controller, pipelines ...pipeline.Pipeline) (*VectorConfig, error)
func New ¶
func New(vector *vectorv1alpha1.Vector) *VectorConfig
Click to show internal directories.
Click to hide internal directories.