Struct PulsarSeeker 

pub struct PulsarSeeker { /* private fields */ }

Repositions a subscription while its stream runs; minted by Seekable::seeker.

A seek covers every topic (and partition) of the subscription’s consumer, and the broker redelivers from the new position; per-message acknowledgement state needs no reset.

One type serves both transports, so a service that repositions itself reads the same SeekHandle key whether it runs against a server or in process under the test harness.

Trait Implementations

impl Clone for PulsarSeeker

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PulsarSeeker

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

Formats the value using the given formatter.

impl Seeker for PulsarSeeker

type Position = PulsarPosition

The broker’s own position type (Kafka partition offsets, a Redis entry id, a byte offset), constructed by the broker crate or captured from a delivered message via Positioned::position.

type Error = PulsarError

The error returned when the broker rejects the reposition.

async fn seek(&self, to: PulsarPosition) -> Result<(), PulsarError>

Moves the subscription to to; subsequent deliveries resume from there.