processors

package
Version: v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 24, 2020 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL