processors

package

v0.3.0-rc.2 Latest Latest Go to latest Published: Jul 1, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

const (
	Mapper = "mapper"
	Filter = "filter"
	RPC    = "rpc-plugin"
)

View Source

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

This section is empty.

type CloseableProcessor interface {
	Close() error
}

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

func New(logger *logrus.Logger, cfg config.Processors) (*Processors, error)

func (p *Processors) Close() error

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