multilineparser

Documentation

Index

• type MultilineParser
  • func (in *MultilineParser) DeepCopy() *MultilineParser
  • func (in *MultilineParser) DeepCopyInto(out *MultilineParser)
  • func (_ *MultilineParser) Name() string
  • func (m *MultilineParser) Params(_ plugins.SecretLoader) (*params.KVs, error)
• type Rule

Types

type MultilineParser

type MultilineParser struct {
	// Set the multiline mode, for now, we support the type regex.
	// +kubebuilder:validation:Enum:=regex
	// +kubebuilder:default:=regex
	Type string `json:"type,omitempty"`
	// Name of a pre-defined parser that must be applied to the incoming content before applying the regex rule. If no parser is defined, it's assumed that's a raw text and not a structured message.
	Parser string `json:"parser,omitempty"`
	// For an incoming structured message, specify the key that contains the data that should be processed by the regular expression and possibly concatenated.
	KeyContent string `json:"keyContent,omitempty"`
	// Timeout in milliseconds to flush a non-terminated multiline buffer. Default is set to 5 seconds.
	// +kubebuilder:default:=5000
	FlushTimeout int `json:"flushTimeout,omitempty"`
	// Configure a rule to match a multiline pattern. The rule has a specific format described below. Multiple rules can be defined.
	Rules []Rule `json:"rules,omitempty"`
}

**For full documentation, refer to https://docs.fluentbit.io/manual/administration/configuring-fluent-bit/multiline-parsing**

func (*MultilineParser) DeepCopy

func (in *MultilineParser) DeepCopy() *MultilineParser

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MultilineParser.

func (*MultilineParser) DeepCopyInto

func (in *MultilineParser) DeepCopyInto(out *MultilineParser)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*MultilineParser) Name

func (_ *MultilineParser) Name() string

func (*MultilineParser) Params

func (m *MultilineParser) Params(_ plugins.SecretLoader) (*params.KVs, error)

type Rule

type Rule struct {
	Start string `json:"start"`
	Regex string `json:"regex"`
	Next  string `json:"next"`
}