Struct Sender

Source

pub struct Sender {Show 15 fields
    pub bind_addr: SocketAddr,
    pub repl_consumer_1: ReplicationConsumer,
    pub repl_consumer_2: ReplicationConsumer,
    pub replication_cursor: Arc<AtomicU64>,
    pub fastest_replica_cursor: Arc<AtomicU64>,
    pub genesis_entry: Vec<u8>,
    pub journal_path: PathBuf,
    pub authorized_keys: Arc<AuthorizedKeys>,
    pub evict_flags: [Arc<AtomicBool>; 2],
    pub active_flags: [Arc<AtomicBool>; 2],
    pub metrics: Arc<ReplicationMetrics>,
    pub handler_cores: [usize; 2],
    pub batch_size: usize,
    pub heartbeat_secs: u64,
    pub busy_spin: bool,
}

Expand description

Owned state for the replication sender thread.

Fields§

§bind_addr: SocketAddr§repl_consumer_1: ReplicationConsumer§repl_consumer_2: ReplicationConsumer§replication_cursor: Arc<AtomicU64>§fastest_replica_cursor: Arc<AtomicU64>§genesis_entry: Vec<u8>

Raw genesis entry bytes (encoded GenesisHash journal entry), sent to replicas in StreamStart so they write a byte-identical genesis.

§journal_path: PathBuf§authorized_keys: Arc<AuthorizedKeys>§evict_flags: [Arc<AtomicBool>; 2]§active_flags: [Arc<AtomicBool>; 2]§metrics: Arc<ReplicationMetrics>§handler_cores: [usize; 2]§batch_size: usize§heartbeat_secs: u64§busy_spin: bool

Auto Trait Implementations§

§

Sender

Struct Sender Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for Sender

impl !RefUnwindSafe for Sender

impl Send for Sender

impl Sync for Sender

impl Unpin for Sender

impl UnsafeUnpin for Sender

impl !UnwindSafe for Sender

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct Sender

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,