NewBatcher returns a new Batcher.

NewConsolidator creates a new Consolidator.

NewConsolidatorCache creates a new cache with the given capacity.

NewFakeConsolidator creates a new FakeConsolidator.

Batcher delays concurrent operations for a configurable interval in order to batch them up or otherwise clock their operation to run concurrently.

ConsolidatorCache is a thread-safe object used for counting how often recent queries have been consolidated.

ConsolidatorCacheItem is a wrapper for the items in the consolidator cache.

FakeConsolidator satisfies the Consolidator interface and can be used to mock how Vitess interacts with the Consolidator.

FakeConsolidatorCreateReturn wraps the two return values of a call to FakeConsolidator.Create.

FakePendingResult satisfies the PendingResult interface and can be used to mock how Vitess interacts with the Consolidator.

Consolidator consolidates duplicate queries from executing simulaneously and shares results between them.

PendingResult is a wrapper for result of a query.