# Functions
AssertNoMoreResultsInIterator asserts no more rangedb.Record exist in the rangedb.RecordIterator.
AssertRecordsInIterator asserts all expected rangedb.Record exist in the rangedb.RecordIterator.
No description provided by the author
BlockingSaveEvents helper to save events, ensuring the broadcaster has processed every record.
DummyRecord returns a dummy rangedb.Record.
DummyRecordFromEvent returns a dummy rangedb.Record.
LoadIterator returns a rangedb.RecordIterator filled with the supplied records.
NewBlockingSubscriber constructs a RecordSubscriber that blocks on Accept into Records.
NewCountSubscriber constructs a projection for counting events in a test context.
NewEventThatWillFailUnmarshal returns an event that will fail a json unmarshal.
NewFailingDeserializer constructs a failing rangedb.RecordSerializer.
NewFailingEventStore constructs a failing event store for testing.
NewFailingSerializer constructs a failing rangedb.RecordSerializer.
NewFailingSubscribeEventStore constructs a failing event store for testing.
No description provided by the author
NewTotalEventsSubscriber constructs a projection to count total events received.
ReadRecord helper to read a record or timeout.
RecordIoStreamBenchmark benchmarks the rangedb.RecordIoStream interface.
RecordSerializerBenchmark benchmarks the rangedb.RecordSerializer interface.
SaveEvents helper to save events with a timeout.
No description provided by the author
StoreBenchmark benchmarks the rangedb.Store interface.
TimeoutContext returns a context that will timeout.
VerifyRecordIoStream verifies the RecordIoStream interface.
VerifyRecordSerializer verifies the RecordSerializer interface.
VerifyStore verifies the rangedb.Store interface.
# Structs
AnotherWasComplete is an event used for testing.
FloatWasDone is an event used for testing.
StringWasDone is an event used for testing.
ThatWasDone is an event used for testing.
ThingWasDone is an event used for testing.
# Type aliases
EventSaver a function that accepts eventRecords for saving.