types

type Converter func(interface{}) (string, error)

type Directive interface {
	GetPluginMeta() *PluginMeta
	GetParams() Params
	GetSections() []Directive
}

type Filter interface {
	Directive
}

type Flow struct {
	PluginMeta

	//Flow id for metrics
	FlowID string
	// Chain of Filters that will process the event. Can be zero or more.
	Filters []Filter `json:"filters,omitempty"`
	// List of Outputs that will emit the event, at least one output is required.
	Outputs []Output `json:"outputs"`

	// Matches for select or exclude
	Matches []FlowMatch `json:"matches,omitempty"`

	// Fluentd label
	FlowLabel string `json:"-"`

	// Flag whether to add the label to the main event router
	AddRoute bool
}

type FlowMatch struct {
	// Optional set of kubernetes labels
	Labels map[string]string `json:"labels,omitempty"`
	// Optional namespace
	Namespaces []string `json:"namespaces,omitempty"`
	// ContainerNames
	ContainerNames []string `json:"container_names,omitempty"`
	// Hosts
	Hosts []string `json:"hosts,omitempty"`
	// Negate
	Negate bool `json:"negate,omitempty"`
}

type FlowRoute struct {
	PluginMeta
	Params  Params
	Matches []Directive
}

type FluentConfig interface {
	GetDirectives() []Directive
}

type GenericDirective struct {
	PluginMeta
	Params        Params      `json:"params,omitempty"`
	SubDirectives []Directive `json:"sections,omitempty"`
}

type Input interface {
	Directive
}

type Output interface {
	Directive
}

type OutputPlugin = GenericDirective

type Params = map[string]string

type PluginMeta struct {
	Type      string `json:"type,omitempty"`
	Id        string `json:"id,omitempty"`
	LogLevel  string `json:"log_level,omitempty"`
	Directive string `json:"directive"`
	Label     string `json:"label,omitempty"`
	Tag       string `json:"tag,omitempty"`
}

type PluginParam struct {
	Description string
	Default     string
	Value       string
	Required    bool
}

type PluginParams map[string]*PluginParam

type Router struct {
	PluginMeta
	Routes []Directive `json:"routes"`
	Params Params
}

type StructToStringMapper struct {
	TagName         string
	PluginTagName   string
	ConversionHooks map[string]Converter
	SecretLoader    secret.SecretLoader
}

type System struct {
	Input         Input    `json:"input"`
	GlobalFilters []Filter `json:"globalFilters"`
	Router        *Router  `json:"router"`
	Flows         []*Flow  `json:"flows"`
}

type SystemBuilder struct {
	// contains filtered or unexported fields
}