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 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,
pub fence_state: Arc<FenceState>,
}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>§journal_path: PathBuf§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§fence_state: Arc<FenceState>Node fencing state. Read to stamp the primary’s epoch onto each
StreamStart, and to self-demote when a replica handshakes with a
higher epoch (this primary has been superseded). See crate::fence.
Auto Trait Implementations§
impl !RefUnwindSafe for Sender
impl !UnwindSafe for Sender
impl Freeze for Sender
impl Send for Sender
impl Sync for Sender
impl Unpin for Sender
impl UnsafeUnpin for Sender
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more