processors

Documentation

Index

• Constants
• Variables
• type Processor
• type Processors
  • func New(cfg config.Processors) (*Processors, error)
  • func (p *Processors) Process(_ context.Context, message entities.PipelineEvent) (entities.PipelineEvent, error)

Constants

const (
	Mapper = "mapper"
	Filter = "filter"
)

Variables

var (
	ErrProcessorNotSupported = fmt.Errorf("processor not supported")
)

Types

type Processor

type Processor interface {
	Process(data entities.PipelineEvent) (entities.PipelineEvent, error)
}

type Processors

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

func New

func New(cfg config.Processors) (*Processors, error)

func (*Processors) Process

func (p *Processors) Process(_ context.Context, message entities.PipelineEvent) (entities.PipelineEvent, error)