transformer

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Projector 

type Projector struct {
	// contains filtered or unexported fields
}

Projector will project kafka message to kafka topic or somewhere else

func NewProjector 

func NewProjector(log logger.Log, projector pkg.Projector, collector instrument.Collector) Projector

NewProjector is the constructor for a Projector

func (*Projector) Run 

func (p *Projector) Run(wg *sync.WaitGroup, inChan chan *confluent.Message)

Run starts the projector goroutine

type Transformer 

type Transformer struct {
	// contains filtered or unexported fields
}

Transformer represents the transformer which will perform the custom transformation

func NewTransformer 

func NewTransformer(log logger.Log, transformer transformer.Transformer, bufferSize int, workerTimeout time.Duration, collector instrument.Collector) Transformer

NewTransformer constructor for Transformer, bufferSize is the size of the buffered channel

func (*Transformer) Run 

func (t *Transformer) Run(wg *sync.WaitGroup, inChan chan *confluent.Message) chan *confluent.Message

Run will start the transformer process

type Workers 

type Workers struct {
	// contains filtered or unexported fields
}

Workers is a pool of goroutines used for parallel transformation

func (Workers) Run 

func (w Workers) Run(resultChan chan *confluent.Message)

Run starts parallel processing of messages

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.