processor

type ErrorKeyMissing struct {
	Key string // Key that was not found in the event.
}

type Event interface {
	Put(key string, v *event.Value) (*event.Value, error)
	TryPut(key string, v *event.Value) (*event.Value, error)
	Get(key string) *event.Value
	Delete(key string) *event.Value

	// Cancel any further processing by the pipeline for this event.
	Cancel()

	// Drop the event.
	Drop()
}

type Processor interface {
	Process(event Event) error
}