ProjectionEngine

Creates a bounded hub for live events. Publishing suspends when the hub is full, so a slow consumer slows the producer down instead of losing events.

Creates an engine for the given projections, with the default ProjectionEngineConfig.

It checks the projection names and folders, creates a TransactorCache that is closed with the enclosing Scope, and a SQLite store for each projection: global/.db for a global projection and /.db otherwise. The engine has no event stores, so it has nothing to read; to give it some, use makeWithStores or makeWithStoresVarargs instead.

Fails if a name or folder is invalid.

Like make, with the settings config.

Creates an engine from stores you made yourself, instead of creating them. This is how an engine is given event stores to read from, and how TestEngine wires its in-memory stores.

It neither creates nor opens any store, and stores must have an entry for every projection. An invalid projection name or folder is a defect, not a typed error.

Like makeWithStores in that it takes event stores, but it creates the primary stores itself, the way make does. The projections are passed in a second parameter list.

Unlike makeWithStores, an invalid projection name or folder fails the task.

Checks that a folder path cannot escape the storage directory, and throws IllegalArgumentException if it can. It rejects an empty path, backslashes, .., //, and absolute paths.

Checks that a projection name is safe to use as a file name, and throws IllegalArgumentException if it is not. A name must be non-empty and made of letters, digits, _ and -.