Struct ElementBuffer

pub struct ElementBuffer { /* private fields */ }

Implementations

impl ElementBuffer

pub fn new(max_retries: usize) -> Self

pub async fn add_element( &self, element_id: LocalElementId, element_registration: ElementRegistration, )

Adds an element to the pending queue.

pub async fn get_pending_elements(&self) -> Vec<BufferEntry>

Retrieves and removes all pending elements.

pub async fn mark_failed(&self, element: BufferEntry)

Marks an element as failed and handles retries. Returns true if the element will be retried, false otherwise.

pub async fn mark_succeeded(&self, element_id: &LocalElementId)

Marks an element as successfully registered.