Struct ChannelDebugSnapshot 

pub struct ChannelDebugSnapshot {

    pub connection_id: ConnectionId,
    pub channel_id: ChannelId,
    pub direction: ChannelDirection,
    pub debug: Option<ChannelDebugContext>,
    pub initial_credit: u32,
    pub available_send_credit: Option<u32>,
    pub inbound_queue_len: Option<usize>,
    pub inbound_queue_capacity: Option<usize>,
    pub outbound_runtime_queue_len: Option<usize>,
    pub outbound_runtime_queue_capacity: Option<usize>,
    pub send_waiters_count: Option<usize>,
    pub receiver_state: ChannelReceiverState,
    pub last_item_sent_at: Option<Instant>,
    pub last_item_received_at: Option<Instant>,
    pub last_item_consumed_at: Option<Instant>,
    pub last_credit_granted_at: Option<Instant>,
    pub last_credit_received_at: Option<Instant>,
    pub last_credit_granted_amount: Option<u32>,
    pub last_credit_received_amount: Option<u32>,
    pub pending_local_grant_credit: u32,
    pub total_credit_granted: u64,
    pub total_credit_received: u64,
    pub current_permit_count: Option<u32>,
    pub zero_credit_with_blocked_senders: bool,
    pub sent: u64,
    pub sends_started: u64,
    pub sends_completed: u64,
    pub sends_waited_for_credit: u64,
    pub try_send_full_credit: u64,
    pub try_send_full_runtime_queue: u64,
    pub closed: u64,
    pub reset: u64,
    pub dropped: u64,
    pub items_received: u64,
    pub items_consumed: u64,
    pub credit_granted: u64,
    pub credit_received: u64,
    pub close_reason: Option<ChannelCloseReason>,
    pub reset_reason: Option<ChannelResetReason>,
}

Fields

connection_id: ConnectionId

channel_id: ChannelId

direction: ChannelDirection

debug: Option<ChannelDebugContext>

initial_credit: u32

available_send_credit: Option<u32>

inbound_queue_len: Option<usize>

inbound_queue_capacity: Option<usize>

outbound_runtime_queue_len: Option<usize>

outbound_runtime_queue_capacity: Option<usize>

send_waiters_count: Option<usize>

receiver_state: ChannelReceiverState

last_item_sent_at: Option<Instant>

last_item_received_at: Option<Instant>

last_item_consumed_at: Option<Instant>

last_credit_granted_at: Option<Instant>

last_credit_received_at: Option<Instant>

last_credit_granted_amount: Option<u32>

last_credit_received_amount: Option<u32>

pending_local_grant_credit: u32

total_credit_granted: u64

total_credit_received: u64

current_permit_count: Option<u32>

zero_credit_with_blocked_senders: bool

sent: u64

sends_started: u64

sends_completed: u64

sends_waited_for_credit: u64

try_send_full_credit: u64

try_send_full_runtime_queue: u64

closed: u64

reset: u64

dropped: u64

items_received: u64

items_consumed: u64

credit_granted: u64

credit_received: u64

close_reason: Option<ChannelCloseReason>

reset_reason: Option<ChannelResetReason>

Trait Implementations

impl Clone for ChannelDebugSnapshot

fn clone(&self) -> ChannelDebugSnapshot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelDebugSnapshot

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

Formats the value using the given formatter.