processors

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

type ChainableProcessor interface {
	Interface

	// WithNext sets the next Processor to pass the event.
	WithNext(ChainableProcessor) ChainableProcessor
}

type FakeProcessor struct {
	BaseProcessor

	// AlwaysErr once set will always immediately return error.
	AlwaysErr bool

	// OneTimeErr once set will immediately return an error exactly once.
	OneTimeErr bool

	// BlockUntilCancel will block until context gets cancelled only
	// if no error return is required.
	BlockUntilCancel bool

	// PrevEventsCh records the events from the previous processor.
	PrevEventsCh chan *event.Event

	// InterceptFunc delegates the event modification.
	// If nil, the original event will be passed.
	InterceptFunc func(context.Context, *event.Event) *event.Event

	// WasCancelled records whether the processing was cancelled.
	WasCancelled bool
	// contains filtered or unexported fields
}

type Interface interface {
	// Process processes an event. It may decide to terminate the processing early
	// or it can pass the event to the next Processor for further processing.
	Process(ctx context.Context, e *event.Event) error
	// Next returns the next Processor to process events.
	Next() Interface
}