FeedConfigParams return the list of configuration params supported by a feed.

NewEngine creates a new engine instance for `uuid`.

NewFakeBuckets returns a reference to new FakeBucket.

NewFeed creates a new topic feed.

NewKVData create a new data-path instance.

NewProjector creates a news projector instance and starts a corresponding adminport.

NewVbucket creates a new routine to handle this vbucket stream.

NewVbucketWorker creates a new routine to handle this vbucket stream.

OpenBucketFeed opens feed for bucket.

BucketSeqnosLocal return list of {{vbno,seqno}..} for vbuckets belonging to the KV node where this projector is running.

Engine is immutable structure defined for each index, or any other entity that wants projection and routing over kv-mutations.

FakeBucket fot unit testing.

FakeStream fot unit testing.

Feed is mutation stream - for maintenance, initial-load, catchup etc...

KVData captures an instance of data-path for single kv-node from upstream connection.

Projector data structure, a projector is connected to one or more upstream kv-nodes.

Vbucket is immutable structure defined for each vbucket.

VbucketWorker is immutable structure defined for each vbucket.

BucketAccess interface manage a subset of vbucket streams with mutiple KV nodes.

BucketFeeder interface from a BucketAccess object.

Subscriber interface abstracts engines (aka instances) that can supply `evaluators`, to transform mutations into custom-messages, and `routers`, to supply distribution topology for custom-messages.