transform

Jan 4, 2023

Changes in this version

type Transformer

+ func New(cfg config.Config) (Transformer, error)

Oct 10, 2022

Changes in this version

+ type Transformer interface

+ Transform func(context.Context, *config.Channel, *config.Channel) error

Sep 1, 2022

Changes in this version

+ type Batch struct

+ Processors []config.Config

+ func (transform *Batch) Transform(ctx context.Context, in <-chan config.Capsule, out chan<- config.Capsule, ...) error

Apr 19, 2022

Changes in this version

+ const TransformInvalidFactoryConfig

+ type Config struct

+ Settings map[string]interface{}

+ Type string

+ type Process struct

+ Processors []process.Config

+ func (transform *Process) Transform(ctx context.Context, in <-chan []byte, out chan<- []byte, kill chan struct{}) error

+ type Transfer struct

+ func (transform *Transfer) Transform(ctx context.Context, in <-chan []byte, out chan<- []byte, kill chan struct{}) error

+ type Transform interface

+ Transform func(context.Context, <-chan []byte, chan<- []byte, chan struct{}) error

+ func Factory(cfg Config) (Transform, error)