Struct pravega_client::event::reader_group::StreamCutV1

pub struct StreamCutV1 { /* private fields */ }

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.)

Implementations

impl StreamCutV1

pub fn new(stream: ScopedStream, positions: HashMap<ScopedSegment, i64>) -> Self

pub fn get_stream(&self) -> ScopedStream

gets a clone of the internal scoped stream

pub fn get_positions(&self) -> HashMap<ScopedSegment, i64>

gets a clone of the internal positions

Trait Implementations

impl Clone for StreamCutV1

fn clone(&self) -> StreamCutV1

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamCutV1

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamCutV1

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StreamCutV1

fn eq(&self, other: &StreamCutV1) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for StreamCutV1

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for StreamCutV1