transform

Documentation

Index

• type Definition
• type Definitions
• type Filter
  • func (f *Filter) Transform(entry config.GenericMap) (config.GenericMap, bool)
• type Generic
  • func (g *Generic) Transform(entry config.GenericMap) (config.GenericMap, bool)
• type Network
  • func (n *Network) Transform(inputEntry config.GenericMap) (config.GenericMap, bool)
• type Transformer
  • func NewTransformFilter(params config.StageParam) (Transformer, error)
  • func NewTransformGeneric(params config.StageParam) (Transformer, error)
  • func NewTransformNetwork(params config.StageParam) (Transformer, error)
  • func NewTransformNone() (Transformer, error)

Types

type Definition

type Definition struct {
	Type    string
	Generic api.TransformGeneric
	Network api.TransformNetwork
}

type Definitions

type Definitions []Definition

type Filter

type Filter struct {
	Rules []api.TransformFilterRule
}

func (*Filter) Transform

func (f *Filter) Transform(entry config.GenericMap) (config.GenericMap, bool)

Transform transforms a flow

type Generic

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

func (*Generic) Transform

func (g *Generic) Transform(entry config.GenericMap) (config.GenericMap, bool)

Transform transforms a flow to a new set of keys

type Network

type Network struct {
	api.TransformNetwork
	// contains filtered or unexported fields
}

func (*Network) Transform

func (n *Network) Transform(inputEntry config.GenericMap) (config.GenericMap, bool)

type Transformer

type Transformer interface {
	Transform(in config.GenericMap) (config.GenericMap, bool)
}

func NewTransformFilter

func NewTransformFilter(params config.StageParam) (Transformer, error)

NewTransformFilter create a new filter transform

func NewTransformGeneric

func NewTransformGeneric(params config.StageParam) (Transformer, error)

NewTransformGeneric create a new transform

func NewTransformNetwork

func NewTransformNetwork(params config.StageParam) (Transformer, error)

NewTransformNetwork create a new transform

func NewTransformNone

func NewTransformNone() (Transformer, error)

NewTransformNone create a new transform