transform

Documentation

Index

• func BuildFromMapSlice(prefix, inputName string, transforms []apis.LogTransform) ([]apis.LogTransform, error)
• func CreateLabelFilterTransforms(filters []v1alpha1.Filter) ([]apis.LogTransform, error)
• func CreateLogDestinationTransforms(name string, dest v1alpha1.ClusterLogDestination) ([]apis.LogTransform, error)
• func CreateLogFilterTransforms(filters []v1alpha1.Filter) ([]apis.LogTransform, error)
• func CreateLogSourceTransforms(name string, cfg *LogSourceConfig) ([]apis.LogTransform, error)
• func CreateMultiLineTransforms(multiLineType v1alpha1.MultiLineParserType, ...) ([]apis.LogTransform, error)
• func ThrottleTransform(rl v1alpha1.RateLimitSpec) (apis.LogTransform, error)
• 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 CreateParseDataTransforms() *DynamicTransform
  • func DataStreamTransform() *DynamicTransform
  • func DateTime() *DynamicTransform
  • func DeDotTransform() *DynamicTransform
  • func ExtraFieldTransform(extraFields map[string]string) *DynamicTransform
  • func LocalTimezoneAfterSourceTransform() *DynamicTransform
  • func OwnerReferenceSourceTransform() *DynamicTransform
  • func (t *DynamicTransform) MarshalJSON() ([]byte, error)
• type LogSourceConfig

Functions

func BuildFromMapSlice

func BuildFromMapSlice(prefix, inputName string, transforms []apis.LogTransform) ([]apis.LogTransform, error)

func CreateLabelFilterTransforms

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

func CreateLogDestinationTransforms

func CreateLogDestinationTransforms(name string, dest v1alpha1.ClusterLogDestination) ([]apis.LogTransform, error)

func CreateLogFilterTransforms

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

func CreateLogSourceTransforms

func CreateLogSourceTransforms(name string, cfg *LogSourceConfig) ([]apis.LogTransform, error)

func CreateMultiLineTransforms

func CreateMultiLineTransforms(multiLineType v1alpha1.MultiLineParserType, multilineCustomConfig v1alpha1.MultilineParserCustom) ([]apis.LogTransform, error)

func ThrottleTransform

func ThrottleTransform(rl v1alpha1.RateLimitSpec) (apis.LogTransform, error)

ThrottleTransform adds throttling to event's flow.

Types

type CommonTransform

type CommonTransform struct {
	Name   string  `json:"-"`
	Type   string  `json:"type"`
	Inputs set.Set `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 CreateParseDataTransforms

func CreateParseDataTransforms() *DynamicTransform

func DataStreamTransform

func DataStreamTransform() *DynamicTransform

func DateTime

func DateTime() *DynamicTransform

func DeDotTransform

func DeDotTransform() *DynamicTransform

func ExtraFieldTransform

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

ExtraFieldTransform converts templated labels to values. It generates valid VRL remaps from key-value pairs

Only required for Elasticsearch sinks.
Example:
  label_name: {{ values.app }} -> .label_name = .values.app

func LocalTimezoneAfterSourceTransform

func LocalTimezoneAfterSourceTransform() *DynamicTransform

func OwnerReferenceSourceTransform

func OwnerReferenceSourceTransform() *DynamicTransform

func (*DynamicTransform) MarshalJSON

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

type LogSourceConfig

type LogSourceConfig struct {
	SourceType string

	MultilineType         v1alpha1.MultiLineParserType
	MultilineCustomConfig v1alpha1.MultilineParserCustom
	LabelFilter           []v1alpha1.Filter
	LogFilter             []v1alpha1.Filter
}