pub struct zbq_join_payload {
pub ring_capacity: u64,
pub join_baseline: u64,
pub initial_head: u64,
pub producer_pid: i32,
pub slot_index: u32,
pub wakeup_mode: u32,
/* private fields */
}Expand description
Payload sent from producer to consumer during the join handshake.
Fields§
§ring_capacity: u64Size of the data ring.
join_baseline: u64Baseline timestamp used for progress measurements.
initial_head: u64Initial head offset (consumer starts reading from here).
producer_pid: i32PID of the producer process.
slot_index: u32Slot index assigned to this consumer.
wakeup_mode: u32Wakeup mode (ZBQ_WAKEUP_PUSH or ZBQ_WAKEUP_PULL).
Auto Trait Implementations§
impl Freeze for zbq_join_payload
impl RefUnwindSafe for zbq_join_payload
impl Send for zbq_join_payload
impl Sync for zbq_join_payload
impl Unpin for zbq_join_payload
impl UnsafeUnpin for zbq_join_payload
impl UnwindSafe for zbq_join_payload
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