processors

package
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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.