Versions in this module Expand all Collapse all v1 v1.0.0 Mar 18, 2020 Changes in this version + type Filter struct + FilterFunc FilterFunc + Id int32 + 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 func(ctx context.Context, key, value interface{}) (bool, error) + type KeySelector struct + Id int32 + SelectKeyFunc SelectKeyFunc + 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 func(ctx context.Context, key, value interface{}) error + type Processor struct + Id int32 + ProcessFunc ProcessFunc + 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 func(ctx context.Context, key, value interface{}) (kOut interface{}, err error) + type TransFunc func(ctx context.Context, key, value interface{}) (kOut, vOut interface{}, err error) + type Transformer struct + Id int32 + TransFunc TransFunc + 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 func(ctx context.Context, key, value interface{}) (vOut interface{}, err error) + type ValueTransformer struct + Id int32 + ValueTransformFunc ValueTransformFunc + 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
Go to main page