EventsToKVs converts a slice of Events to a slice of KeyValue pairs.

MergeKVs merges two sets of KVs into a single set of KVs with at most one KV for any key.

New constructs a Buffer with the provided limit.

RangeFeedValueEventToKV is a function to type assert an Event into a *kvpb.RangeFeedValue and then convert it to a roachpb.KeyValue.

ErrBufferLimitExceeded is returned by the buffer when attempting to add more events than the limit the buffer is configured with.

Buffer provides a thin memory-bounded buffer to sit on top of a rangefeed.

Event is a contract for the unit of what can be added to the buffer.