Struct pravega_client_shared::StreamSegments

pub struct StreamSegments {
    pub key_segment_map: OrdMap<OrderedFloat<f64>, SegmentWithRange>,
}

Fields

key_segment_map: OrdMap<OrderedFloat<f64>, SegmentWithRange>

Implementations

impl StreamSegments

pub fn new( map_key_segment: BTreeMap<OrderedFloat<f64>, SegmentWithRange> ) -> StreamSegments

pub fn get_segment_for_routing_key( &self, routing_key: &Option<String>, rand_f64: fn() -> f64 ) -> &ScopedSegment

Selects a segment using a routing key.

pub fn get_segment(&self, key: f64) -> &ScopedSegment

pub fn get_segment_for_string(&self, str: &str) -> &ScopedSegment

pub fn get_segments(&self) -> Vec<ScopedSegment>

pub fn apply_replacement_range( &self, segment_replace: &Segment, replacement_ranges: &StreamSegmentsWithPredecessors ) -> Result<StreamSegments, String>

Trait Implementations

impl Clone for StreamSegments

fn clone(&self) -> StreamSegments

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamSegments

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

Formats the value using the given formatter.

impl Hash for StreamSegments

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for StreamSegments

fn eq(&self, other: &StreamSegments) -> 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 Eq for StreamSegments

impl StructuralPartialEq for StreamSegments