transform

Documentation

Index

• func BuildFromMapSlice(inputName string, trans []impl.LogTransform) ([]impl.LogTransform, error)
• func CreateDefaultCleanUpTransforms(dest v1alpha1.ClusterLogDestination) []impl.LogTransform
• func CreateDefaultTransforms(sourceType string, dest v1alpha1.ClusterLogDestination) []impl.LogTransform
• func CreateLabelFilterTransforms(filters []v1alpha1.Filter) ([]impl.LogTransform, error)
• func CreateLogFilterTransforms(filters []v1alpha1.Filter) ([]impl.LogTransform, error)
• func CreateMultiLineTransforms(multiLineType v1alpha1.MultiLineParserType) []impl.LogTransform
• type CommonTransform
  • func (cs *CommonTransform) GetInputs() []string
  • func (cs *CommonTransform) GetName() string
  • func (cs *CommonTransform) SetInputs(inp []string)
  • func (cs *CommonTransform) SetName(name string)
• type DynamicTransform
  • func CleanUpAfterSourceTransform() *DynamicTransform
  • func CleanUpParsedDataTransform() *DynamicTransform
  • func DataStreamTransform() *DynamicTransform
  • func DeDotTransform() *DynamicTransform
  • func ExtraFieldTransform(extraFields map[string]string) *DynamicTransform
  • func JSONParseTransform() *DynamicTransform
  • func ThrottleTransform(rl v1alpha1.RateLimitSpec) *DynamicTransform
  • func (t *DynamicTransform) MarshalJSON() ([]byte, error)
  • func (t *DynamicTransform) UnmarshalYAML(unmarshal func(interface{}) error) error

Functions

func BuildFromMapSlice

func BuildFromMapSlice(inputName string, trans []impl.LogTransform) ([]impl.LogTransform, error)

func CreateDefaultCleanUpTransforms

func CreateDefaultCleanUpTransforms(dest v1alpha1.ClusterLogDestination) []impl.LogTransform

func CreateDefaultTransforms

func CreateDefaultTransforms(sourceType string, dest v1alpha1.ClusterLogDestination) []impl.LogTransform

func CreateLabelFilterTransforms

func CreateLabelFilterTransforms(filters []v1alpha1.Filter) ([]impl.LogTransform, error)

func CreateLogFilterTransforms

func CreateLogFilterTransforms(filters []v1alpha1.Filter) ([]impl.LogTransform, error)

func CreateMultiLineTransforms

func CreateMultiLineTransforms(multiLineType v1alpha1.MultiLineParserType) []impl.LogTransform

Types

type CommonTransform

type CommonTransform struct {
	Name   string   `json:"-"`
	Type   string   `json:"type"`
	Inputs []string `json:"inputs"`
}

func (*CommonTransform) GetInputs

func (cs *CommonTransform) GetInputs() []string

func (*CommonTransform) GetName

func (cs *CommonTransform) GetName() string

func (*CommonTransform) SetInputs

func (cs *CommonTransform) SetInputs(inp []string)

func (*CommonTransform) SetName

func (cs *CommonTransform) SetName(name string)

type DynamicTransform

type DynamicTransform struct {
	CommonTransform

	DynamicArgsMap map[string]interface{} `json:"-"`
}

func CleanUpAfterSourceTransform

func CleanUpAfterSourceTransform() *DynamicTransform

func CleanUpParsedDataTransform

func CleanUpParsedDataTransform() *DynamicTransform

func DataStreamTransform

func DataStreamTransform() *DynamicTransform

func DeDotTransform

func DeDotTransform() *DynamicTransform

DeDotTransform is the only Lua transform rule. We are going to replace it with corresponding VRL transform once the iteration feature will be implemented for VRL. Related issue https://github.com/timberio/vector/issues/3588

func ExtraFieldTransform

func ExtraFieldTransform(extraFields map[string]string) *DynamicTransform

ExtraFieldTransform converts templated labels to values.

TODO(nabokihms): Honestly, I do not know exactly how this function works.

Only required for Elasticsearch sinks.
It definitely deserves refactoring. My assumption is that it generates VRL rules from extra labels.
Example:
  label_name: {{ values.app }} -> .label_name = .values.app

func JSONParseTransform

func JSONParseTransform() *DynamicTransform

func ThrottleTransform

func ThrottleTransform(rl v1alpha1.RateLimitSpec) *DynamicTransform

ThrottleTransform adds throttling to event's flow.

func (*DynamicTransform) MarshalJSON

func (t *DynamicTransform) MarshalJSON() ([]byte, error)

func (*DynamicTransform) UnmarshalYAML

func (t *DynamicTransform) UnmarshalYAML(unmarshal func(interface{}) error) error