config

Documentation

Index

• Constants
• Variables
• func Mapper(c ConfigComponent) (map[string]interface{}, error)
• type ApiSpec
• type Builder
  • func NewBuilder(vaCtrl *vectoragent.Controller, pipelines ...pipeline.Pipeline) *Builder
  • func (b *Builder) GetByteConfig() ([]byte, error)
• type ConfigComponent
• type Sink
  • func (t Sink) GetOptions() map[string]interface{}
• type Source
  • func (t Source) GetOptions() map[string]interface{}
• type Transform
  • func (t Transform) GetOptions() map[string]interface{}
• type VectorConfig
  • func New(vector *vectorv1alpha1.Vector) *VectorConfig

Constants

const (
	KubernetesSourceType          = "kubernetes_logs"
	BlackholeSinkType             = "blackhole"
	InternalMetricsSourceType     = "internal_metrics"
	InternalMetricsSinkType       = "prometheus_exporter"
	OptimizedKubernetesSourceName = "optimizedKubernetesSource"
	FilterTransformType           = "filter"
	DefaultSourceName             = "defaultSource"
	PodSelectorType               = "pod_labels"
	NamespaceSelectorType         = "ns_labels"
	OptimizationConditionType     = "vrl"
)

Variables

var (
	PipelineTypeError  error = errors.New("type kubernetes_logs only allowed")
	PipelineScopeError error = errors.New("logs from external namespace not allowed")
)

Functions

func Mapper

func Mapper(c ConfigComponent) (map[string]interface{}, error)

Types

type ApiSpec

type ApiSpec struct {
	Address    string `json:"address,omitempty"`
	Enabled    bool   `json:"enabled,omitempty"`
	Playground bool   `json:"playground,omitempty"`
}

type Builder

type Builder struct {
	Name string

	Pipelines []pipeline.Pipeline
	// contains filtered or unexported fields
}

func NewBuilder

func NewBuilder(vaCtrl *vectoragent.Controller, pipelines ...pipeline.Pipeline) *Builder

func (*Builder) GetByteConfig

func (b *Builder) GetByteConfig() ([]byte, error)

type ConfigComponent

type ConfigComponent interface {
	GetOptions() map[string]interface{}
}

type Sink

type Sink struct {
	Name    string
	Type    string                 `mapper:"type"`
	Inputs  []string               `mapper:"inputs"`
	Options map[string]interface{} `mapstructure:",remain"`
}

func (Sink) GetOptions

func (t Sink) GetOptions() map[string]interface{}

type Source

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

func (t Source) GetOptions() map[string]interface{}

type Transform

type Transform struct {
	Name      string
	Type      string                 `mapper:"type"`
	Inputs    []string               `mapper:"inputs"`
	Condition interface{}            `mapper:"condition,omitempty"`
	Options   map[string]interface{} `mapstructure:",remain"`
}

func (Transform) GetOptions

func (t Transform) GetOptions() map[string]interface{}

type VectorConfig

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