processor

Documentation

Index

• func Pipeline(ctx context.Context, logger logrus.FieldLogger, processors []Processor, ...) (*email.Message, error)
• type Processor

Functions

func Pipeline

func Pipeline(ctx context.Context, logger logrus.FieldLogger, processors []Processor, msg *email.Message, metricsData *metrics.Metrics) (*email.Message, error)

Types

type Processor

type Processor interface {
	Name() string
	Process(ctx context.Context, logger logrus.FieldLogger, msg *email.Message, metricsData *metrics.Metrics) (consumed bool, updated *email.Message, err error)
}