processors

package
Version: v1.3.2 Latest Latest
Warning

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

Go to latest
Published: Aug 16, 2021 License: MIT Imports: 4 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 MaterializeOption added in v1.3.0

type MaterializeOption func(sink *Materializer)

func WithVersionExtractor added in v1.3.0

func WithVersionExtractor(ve RecordVersionExtractor) MaterializeOption

func WithVersionWriter added in v1.3.0

func WithVersionWriter(vi RecordVersionWriter) MaterializeOption

type Materializer added in v1.3.0

type Materializer struct {
	Topic            string
	Id               int32
	Store            string
	VersionExtractor RecordVersionExtractor
	VersionWriter    RecordVersionWriter

	Registry store.Registry
	// contains filtered or unexported fields
}

func NewMaterializeBuilder added in v1.3.0

func NewMaterializeBuilder(topic, store string, registry store.Registry, id int32, options ...MaterializeOption) *Materializer

func (*Materializer) AddChild added in v1.3.0

func (m *Materializer) AddChild(node topology.Node)

func (*Materializer) AddChildBuilder added in v1.3.0

func (m *Materializer) AddChildBuilder(builder topology.NodeBuilder)

func (*Materializer) Build added in v1.3.0

func (m *Materializer) Build() (topology.Node, error)

func (*Materializer) ChildBuilders added in v1.3.0

func (m *Materializer) ChildBuilders() []topology.NodeBuilder

func (*Materializer) Childs added in v1.3.0

func (m *Materializer) Childs() []topology.Node

func (*Materializer) Run added in v1.3.0

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

func (*Materializer) Type added in v1.3.0

func (m *Materializer) 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 RecordVersionExtractor added in v1.3.0

type RecordVersionExtractor func(ctx context.Context, key, value interface{}) (version int64, err error)

type RecordVersionWriter added in v1.3.0

type RecordVersionWriter func(ctx context.Context, version int64, vIn interface{}) (vOut interface{}, err error)

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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