Struct TokioEngine 

pub struct TokioEngine;

Zero-sized marker for the tokio production engine. Default E on crate::PulsarClient<E>.

Available behind the tokio feature (default-on).

Trait Implementations

impl Clone for TokioEngine

fn clone(&self) -> TokioEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TokioEngine

impl Debug for TokioEngine

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

Formats the value using the given formatter.

impl Default for TokioEngine

fn default() -> TokioEngine

Returns the “default value” for a type.

impl Engine for TokioEngine

type ClientState = Client

Per-engine state stored inside crate::PulsarClient<E>. The tokio engine plugs in magnetar_runtime_tokio::Client; the moonpool engine plugs in (Arc<moonpool::ConnectionShared>, moonpool::DriverHandle). Both bundles are 'static + Send + Sync so the façade can be moved across spawn boundaries unchanged.

type TaskHandle = JoinHandle<()>

Opaque, cancel-safe handle to a background task spawned via Self::spawn. Dropping the handle aborts the task on the tokio engine; explicit Self::abort_task is the happens-before-Drop path the façade uses on shutdown.

type Interval = Interval

Opaque periodic timer created via Self::new_interval. The façade drives ticks via Self::interval_tick.

fn name() -> &'static str

Human-readable engine name, surfaced in logs / panics / errors. Default returns the Rust type name — engines override to e.g. "tokio" / "moonpool".

fn spawn<F>(fut: F) -> Self::TaskHandle

where F: Future<Output = ()> + Send + 'static,

Spawn an async future on the engine’s executor. Returns a cancel- safe Self::TaskHandle. Tokio wraps ::tokio::spawn; moonpool delegates through its Providers::TaskProvider (moonpool_core).

fn abort_task(handle: &mut Self::TaskHandle)

Abort a spawned task. Idempotent: calling on an already-completed or already-aborted handle is a no-op.

fn new_interval(period: Duration) -> Self::Interval

Create a periodic timer with period between ticks. The first tick fires immediately (matches tokio::time::interval).

fn interval_tick<'a>( interval: &'a mut Self::Interval, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'a>>

Await the next tick. The returned future is Send and boxed so the caller can .await from a generic context without exposing the engine-specific timer shape.

fn random_subscription_suffix() -> String

Engine-injected id provider for the façade’s auto-generated subscription names (Reader, TableView) and for the opt-in ProducerBuilder::unique_name_suffix policy (issue #406). Tokio plugs in Uuid::new_v4().simple() (RFC 4122 random); moonpool plugs in a process-global atomic counter so deterministic-simulation runs produce stable, reproducible names. Callers that need fully deterministic names across processes should always pass an explicit subscription / reader / producer name through the builder and leave the suffix policy off.

impl MessageDecryptorApi for TokioEngine

type Decryptor = Arc<dyn MessageDecryptor>

Concrete per-engine decryptor type. Clone + Send + Sync + 'static.

impl MessageEncryptorApi for TokioEngine

type Encryptor = Arc<dyn MessageEncryptor>

Concrete per-engine encryptor type. Clone + Send + Sync + 'static so it survives spawn boundaries and fan-out into child producers.