Skip to main content

Crate ferogram_mtsender

Crate ferogram_mtsender 

Source

Re-exports§

pub use mtp_sender::MtpSender;
pub use sender_task::FrameEvent;
pub use sender_task::ReconnectRequest;
pub use sender_task::RpcEnqueue;
pub use sender_task::SenderHandle;
pub use sender_task::spawn_sender_task;

Modules§

mtp_sender
Single-task MTProto sender.
sender_task
The sender task: a single tokio::spawn-ed loop that owns MtpSender and is the only entity that touches the TCP socket.

Structs§

AutoSleep
Automatically sleep on FLOOD_WAIT and retry once on transient I/O errors.
CircuitBreaker
A RetryPolicy that stops retrying after threshold consecutive failures and stays silent for a cooldown window before resetting.
ConnSlot
One slot in the per-DC connection pool.
DcConnection
DcPool
Pool of per-DC authenticated connections. Each DC holds up to MAX_CONNS_PER_DC slots. The pool lock is dropped before any network I/O so concurrent callers don’t serialize on it.
NoRetries
Never retry: propagate every error immediately.
RetryContext
Context passed to RetryPolicy::should_retry on each failure.
RetryLoop
Drives the retry loop for a single RPC call.
RpcError
An error returned by Telegram’s servers in response to an RPC call.

Enums§

InvocationError
The error type returned from any Client method that talks to Telegram.

Traits§

RetryPolicy
Controls how the client reacts when an RPC call fails.