New create new Server with provided store and bus.

NewGoroutinePoolHandler creates new event processor.

NewHTTP returns HTTP server.

NewRequestHandler factory for new RequestHandler.

Config represent application configuration.

GoroutinePoolHandler submit events to goroutine pool for process them.

RequestHandler for handling incoming request.

Server handle HTTP request.

Iter provides iterator over events from eventstore or eventbus.

ErrFunc used by handler to report error from observation.

GoroutinePoolGoFunc processes actions via provided function.