Struct PubsubSchedulerConfig 

pub struct PubsubSchedulerConfig {
    pub policy: PubsubSchedulingPolicy,
    pub fanout: usize,
    pub anonymous_free_credit_bytes: u64,
    pub reciprocal_credit_multiplier: f64,
    pub aging_credit_bytes: u64,
}

Fields

policy: PubsubSchedulingPolicy

fanout: usize

anonymous_free_credit_bytes: u64

reciprocal_credit_multiplier: f64

aging_credit_bytes: u64

Implementations

impl PubsubSchedulerConfig

pub fn select( &self, stream_id: &str, seq: u64, parent_id: &str, message_bytes: u64, candidates: &[PubsubCandidate], ) -> PubsubSelection

pub fn virtual_finish( &self, candidate: &PubsubCandidate, message_bytes: u64, ) -> f64

Trait Implementations

impl Clone for PubsubSchedulerConfig

fn clone(&self) -> PubsubSchedulerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PubsubSchedulerConfig

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

Formats the value using the given formatter.

impl Default for PubsubSchedulerConfig

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for PubsubSchedulerConfig

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for PubsubSchedulerConfig