processors

Documentation

Index

• type Filter
  • func (f *Filter) AddChild(node topology.Node)
  • func (f *Filter) AddChildBuilder(builder topology.NodeBuilder)
  • func (f *Filter) Build() (topology.Node, error)
  • func (f *Filter) ChildBuilders() []topology.NodeBuilder
  • func (f *Filter) Childs() []topology.Node
  • func (f *Filter) ID() int32
  • func (f *Filter) Name() string
  • func (f *Filter) Next() bool
  • func (f *Filter) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, next bool, err error)
  • func (f *Filter) Type() topology.Type
• type FilterFunc
• type KeySelector
  • func (ks *KeySelector) AddChild(node topology.Node)
  • func (ks *KeySelector) AddChildBuilder(builder topology.NodeBuilder)
  • func (ks *KeySelector) Build() (topology.Node, error)
  • func (ks *KeySelector) ChildBuilders() []topology.NodeBuilder
  • func (ks *KeySelector) Childs() []topology.Node
  • func (ks *KeySelector) ID() int32
  • func (ks *KeySelector) Next() bool
  • func (ks *KeySelector) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)
  • func (ks *KeySelector) Type() topology.Type
• type ProcessFunc
• type Processor
  • func (p *Processor) AddChild(node topology.Node)
  • func (p *Processor) AddChildBuilder(builder topology.NodeBuilder)
  • func (p *Processor) Build() (topology.Node, error)
  • func (p *Processor) ChildBuilders() []topology.NodeBuilder
  • func (p *Processor) Childs() []topology.Node
  • func (p *Processor) ID() int32
  • func (p *Processor) Name() string
  • func (p *Processor) Next() bool
  • func (p *Processor) Run(ctx context.Context, kIn, vIn interface{}) (interface{}, interface{}, bool, error)
  • func (p *Processor) Type() topology.Type
• type SelectKeyFunc
• type TransFunc
• type Transformer
  • func (t *Transformer) AddChild(node topology.Node)
  • func (t *Transformer) AddChildBuilder(builder topology.NodeBuilder)
  • func (t *Transformer) Build() (topology.Node, error)
  • func (t *Transformer) ChildBuilders() []topology.NodeBuilder
  • func (t *Transformer) Childs() []topology.Node
  • func (t *Transformer) ID() int32
  • func (t *Transformer) Name() string
  • func (t *Transformer) Next() bool
  • func (t *Transformer) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, next bool, err error)
  • func (t *Transformer) Type() topology.Type
• type ValueTransformFunc
• type ValueTransformer
  • func (vt *ValueTransformer) AddChild(node topology.Node)
  • func (vt *ValueTransformer) AddChildBuilder(builder topology.NodeBuilder)
  • func (vt *ValueTransformer) Build() (topology.Node, error)
  • func (vt *ValueTransformer) ChildBuilders() []topology.NodeBuilder
  • func (vt *ValueTransformer) Childs() []topology.Node
  • func (vt *ValueTransformer) ID() int32
  • func (vt *ValueTransformer) Next() bool
  • func (vt *ValueTransformer) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)
  • func (vt *ValueTransformer) Type() topology.Type

Types

type Filter

type Filter struct {
	Id         int32
	FilterFunc FilterFunc
	// contains filtered or unexported fields
}

func (*Filter) AddChild

func (f *Filter) AddChild(node topology.Node)

func (*Filter) AddChildBuilder

func (f *Filter) AddChildBuilder(builder topology.NodeBuilder)

func (*Filter) Build

func (f *Filter) Build() (topology.Node, error)

func (*Filter) ChildBuilders

func (f *Filter) ChildBuilders() []topology.NodeBuilder

func (*Filter) Childs

func (f *Filter) Childs() []topology.Node

func (*Filter) ID

func (f *Filter) ID() int32

func (*Filter) Name

func (f *Filter) Name() string

func (*Filter) Next

func (f *Filter) Next() bool

func (*Filter) Run

func (f *Filter) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, next bool, err error)

func (*Filter) Type

func (f *Filter) Type() topology.Type

type FilterFunc

type FilterFunc func(ctx context.Context, key, value interface{}) (bool, error)

type KeySelector

type KeySelector struct {
	Id            int32
	SelectKeyFunc SelectKeyFunc
	// contains filtered or unexported fields
}

func (*KeySelector) AddChild

func (ks *KeySelector) AddChild(node topology.Node)

func (*KeySelector) AddChildBuilder

func (ks *KeySelector) AddChildBuilder(builder topology.NodeBuilder)

func (*KeySelector) Build

func (ks *KeySelector) Build() (topology.Node, error)

func (*KeySelector) ChildBuilders

func (ks *KeySelector) ChildBuilders() []topology.NodeBuilder

func (*KeySelector) Childs

func (ks *KeySelector) Childs() []topology.Node

func (*KeySelector) ID

func (ks *KeySelector) ID() int32

func (*KeySelector) Next

func (ks *KeySelector) Next() bool

func (*KeySelector) Run

func (ks *KeySelector) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)

func (*KeySelector) Type

func (ks *KeySelector) Type() topology.Type

type ProcessFunc

type ProcessFunc func(ctx context.Context, key, value interface{}) error

type Processor

type Processor struct {
	Id          int32
	ProcessFunc ProcessFunc
	// contains filtered or unexported fields
}

func (*Processor) AddChild

func (p *Processor) AddChild(node topology.Node)

func (*Processor) AddChildBuilder

func (p *Processor) AddChildBuilder(builder topology.NodeBuilder)

func (*Processor) Build

func (p *Processor) Build() (topology.Node, error)

func (*Processor) ChildBuilders

func (p *Processor) ChildBuilders() []topology.NodeBuilder

func (*Processor) Childs

func (p *Processor) Childs() []topology.Node

func (*Processor) ID

func (p *Processor) ID() int32

func (*Processor) Name

func (p *Processor) Name() string

func (*Processor) Next

func (p *Processor) Next() bool

func (*Processor) Run

func (p *Processor) Run(ctx context.Context, kIn, vIn interface{}) (interface{}, interface{}, bool, error)

func (*Processor) Type

func (p *Processor) Type() topology.Type

type SelectKeyFunc

type SelectKeyFunc func(ctx context.Context, key, value interface{}) (kOut interface{}, err error)

type TransFunc

type TransFunc func(ctx context.Context, key, value interface{}) (kOut, vOut interface{}, err error)

type Transformer

type Transformer struct {
	Id        int32
	TransFunc TransFunc
	// contains filtered or unexported fields
}

func (*Transformer) AddChild

func (t *Transformer) AddChild(node topology.Node)

func (*Transformer) AddChildBuilder

func (t *Transformer) AddChildBuilder(builder topology.NodeBuilder)

func (*Transformer) Build

func (t *Transformer) Build() (topology.Node, error)

func (*Transformer) ChildBuilders

func (t *Transformer) ChildBuilders() []topology.NodeBuilder

func (*Transformer) Childs

func (t *Transformer) Childs() []topology.Node

func (*Transformer) ID

func (t *Transformer) ID() int32

func (*Transformer) Name

func (t *Transformer) Name() string

func (*Transformer) Next

func (t *Transformer) Next() bool

func (*Transformer) Run

func (t *Transformer) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, next bool, err error)

func (*Transformer) Type

func (t *Transformer) Type() topology.Type

type ValueTransformFunc

type ValueTransformFunc func(ctx context.Context, key, value interface{}) (vOut interface{}, err error)

type ValueTransformer

type ValueTransformer struct {
	Id                 int32
	ValueTransformFunc ValueTransformFunc
	// contains filtered or unexported fields
}

func (*ValueTransformer) AddChild

func (vt *ValueTransformer) AddChild(node topology.Node)

func (*ValueTransformer) AddChildBuilder

func (vt *ValueTransformer) AddChildBuilder(builder topology.NodeBuilder)

func (*ValueTransformer) Build

func (vt *ValueTransformer) Build() (topology.Node, error)

func (*ValueTransformer) ChildBuilders

func (vt *ValueTransformer) ChildBuilders() []topology.NodeBuilder

func (*ValueTransformer) Childs

func (vt *ValueTransformer) Childs() []topology.Node

func (*ValueTransformer) ID

func (vt *ValueTransformer) ID() int32

func (*ValueTransformer) Next

func (vt *ValueTransformer) Next() bool

func (*ValueTransformer) Run

func (vt *ValueTransformer) Run(ctx context.Context, kIn, vIn interface{}) (kOut, vOut interface{}, cont bool, err error)

func (*ValueTransformer) Type

func (vt *ValueTransformer) Type() topology.Type