Module pravega_client::event::reader_group

source ·

Structs§

  • A collection of readers that collectively read all the events in the stream.
  • Specifies the ReaderGroupConfig. ReaderGroupConfig::default() ensures the group refresh interval is set to 3 seconds.
  • Builder used to build the ReaderGroup Config. The reader group refresh time is 3 seconds.
  • A set of segment/offset pairs for a single stream that represent a consistent position in the stream. (IE: Segment 1 and 2 will not both appear in the set if 2 succeeds 1, and if 0 appears and is responsible for keyspace 0-0.5 then other segments covering the range 0.5-1.0 will also be included.)

Enums§