NewEchoFilter creates a new EchoFilter.

NewEventsBatcher creates a new EventsBatcher.

NewSelectiveRootsFilter creates a new SelectiveRootsFilter and starts listening to events.

EchoFilter tries to detect events that are linked to an operation that has just been performed by a processor.

EventsBatcher will batch incoming events and process them after a certain idle time.

SelectiveRootsFilter is a Pipe filtering events that are outside of the selective roots.