config

Documentation

Index

• Constants
• type BufferConfig
  • func (c *BufferConfig) GetName() string
  • func (c *BufferConfig) GetSize() uint
• type Config
  • func LoadConfig(fs afero.Fs, cfgFile string) (*Config, error)
  • func NewConfig() *Config
• type OutputGroupConfig

Constants

const DefaultInputBufferSize = 10000

const DefaultInputFilterWorkerNum = 1

const DefaultOutputBufferSize = 10000

Types

type BufferConfig

type BufferConfig struct {
	Size uint
	// contains filtered or unexported fields
}

func (*BufferConfig) GetName

func (c *BufferConfig) GetName() string

func (*BufferConfig) GetSize

func (c *BufferConfig) GetSize() uint

type Config

type Config struct {
	// number of workers that moves msg from input buffer to output buffer with msg filtering.
	InputFilterWorkerNum uint
	LogLevel             string
	MetricsListen        string
	InputBufferConfig    *BufferConfig
	Inputs               plugin.InputPlugins
	Filters              plugin.FilterPlugins
	OutputGroups         []OutputGroupConfig
}

func LoadConfig

func LoadConfig(fs afero.Fs, cfgFile string) (*Config, error)

func NewConfig

func NewConfig() *Config

type OutputGroupConfig

type OutputGroupConfig struct {
	Name         string
	BufferConfig *BufferConfig
	Filters      plugin.FilterPlugins
	Outputs      plugin.OutputPlugins
}