config

Documentation

Index

• Variables
• func Mapper(c ConfigComponent) (map[string]interface{}, error)
• func ReconcileConfig(ctx context.Context, client client.Client, p pipeline.Pipeline, ...) error
• type Builder
  • func NewBuilder(vaCtrl *vectoragent.Controller, pipelines ...pipeline.Pipeline) *Builder
  • func (b *Builder) GetByteConfig() ([]byte, error)
  • func (b *Builder) GetByteConfigWithValidate() ([]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

Variables

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

var (
	KubernetesSourceType = "kubernetes_logs"
)

Functions

func Mapper

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

func ReconcileConfig

func ReconcileConfig(ctx context.Context, client client.Client, p pipeline.Pipeline, vaCtrl *vectoragent.Controller) error

Types

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)

func (*Builder) GetByteConfigWithValidate

func (b *Builder) GetByteConfigWithValidate() ([]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"`
	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"`
	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        *vectorv1alpha1.ApiSpec `mapstructure:"api"`
	Sources    []*Source               `mapstructure:"sources"`
	Transforms []*Transform            `mapstructure:"transforms"`
	Sinks      []*Sink                 `mapstructure:"sinks"`
}

func New

func New(vector *vectorv1alpha1.Vector) *VectorConfig