router

Documentation

Index

• type Config
  • func NewConfig(operatorID string) *Config
  • func (c Config) Build(logger *zap.SugaredLogger) (operator.Operator, error)
• type Route
• type RouteConfig
• type Transformer
  • func (p *Transformer) CanOutput() bool
  • func (p *Transformer) CanProcess() bool
  • func (p *Transformer) GetOutputIDs() []string
  • func (p *Transformer) Outputs() []operator.Operator
  • func (p *Transformer) Process(ctx context.Context, entry *entry.Entry) error
  • func (p *Transformer) SetOutputIDs(opIDs []string)
  • func (p *Transformer) SetOutputs(operators []operator.Operator) error

Types

type Config

type Config struct {
	helper.BasicConfig `mapstructure:",squash" yaml:",inline"`
	Routes             []*RouteConfig   `mapstructure:"routes" json:"routes" yaml:"routes"`
	Default            helper.OutputIDs `mapstructure:"default" json:"default" yaml:"default"`
}

Config is the configuration of a router operator

func NewConfig

func NewConfig(operatorID string) *Config

NewConfig config creates a new router operator config with default values

func (Config) Build

func (c Config) Build(logger *zap.SugaredLogger) (operator.Operator, error)

Build will build a router operator from the supplied configuration

type Route

type Route struct {
	helper.Attributer
	Expression      *vm.Program
	OutputIDs       helper.OutputIDs
	OutputOperators []operator.Operator
}

Route is a route on a router operator

type RouteConfig

type RouteConfig struct {
	helper.AttributerConfig `mapstructure:",squash" yaml:",inline"`
	Expression              string           `mapstructure:"expr" json:"expr"   yaml:"expr"`
	OutputIDs               helper.OutputIDs `mapstructure:"output" json:"output" yaml:"output"`
}

RouteConfig is the configuration of a route on a router operator

type Transformer

type Transformer struct {
	helper.BasicOperator
	// contains filtered or unexported fields
}

Transformer is an operator that routes entries based on matching expressions

func (*Transformer) CanOutput

func (p *Transformer) CanOutput() bool

CanOutput will always return true for a router operator

func (*Transformer) CanProcess

func (p *Transformer) CanProcess() bool

CanProcess will always return true for a router operator

func (*Transformer) GetOutputIDs

func (p *Transformer) GetOutputIDs() []string

GetOutputIDs will return all connected operators.

func (*Transformer) Outputs

func (p *Transformer) Outputs() []operator.Operator

Outputs will return all connected operators.

func (*Transformer) Process

func (p *Transformer) Process(ctx context.Context, entry *entry.Entry) error

Process will route incoming entries based on matching expressions

func (*Transformer) SetOutputIDs

func (p *Transformer) SetOutputIDs(opIDs []string)

SetOutputIDs will do nothing.

func (*Transformer) SetOutputs

func (p *Transformer) SetOutputs(operators []operator.Operator) error

SetOutputs will set the outputs of the router operator.