Struct ElasticQueue 

pub struct ElasticQueue { /* private fields */ }

The per-route elastic overflow buffer. Reserved for system use — the route manager drives it; do not use directly in application code (Java carries the same warning on ServiceQueue).

Implementations

impl ElasticQueue

pub fn new(id: &str) -> Self

id is the service route path.

pub fn id(&self) -> &str

pub fn read_counter(&self) -> u64

pub fn write_counter(&self) -> u64

pub fn is_closed(&self) -> bool

The queue is closed when the counters are reset (Java isClosed).

pub fn write(&mut self, event: &[u8]) -> Result<(), AppError>

Append one serialized event: memory tier first, then disk spill (Java write). Empty payloads are ignored.

pub fn peek(&mut self) -> Result<Vec<u8>, AppError>

Look at the next event without consuming it (Java peek).

pub fn read(&mut self) -> Result<Vec<u8>, AppError>

Consume the next event in FIFO order; an empty vec means the queue has caught up with writes (and the counters were reset — Java read).

pub fn close(&mut self)

Reset the queue once drained (Java close → resetCounter).

pub fn destroy(&mut self)

Final clean-up when the route leaves service (Java destroy): close and remove any stray segment files for this route across generations.

Trait Implementations

impl Drop for ElasticQueue

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.