transform

Documentation

Index

• type Transformer
  • func (tf *Transformer) ApplyTransformation(inputData []string) error
  • func (tf *Transformer) ApplyTransformationJob(ctx context.Context, jobChannel <-chan *models.Job) <-chan *models.Job
  • func (tf *Transformer) Init()

Types

type Transformer

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

Transformer represents the processing pipeline

func (*Transformer) ApplyTransformation

func (tf *Transformer) ApplyTransformation(inputData []string) error

applyTransformation applies Beam transformations

func (*Transformer) ApplyTransformationJob

func (tf *Transformer) ApplyTransformationJob(ctx context.Context, jobChannel <-chan *models.Job) <-chan *models.Job

func (*Transformer) Init

func (tf *Transformer) Init()