Enum SequencerRequest

pub enum SequencerRequest {
    ReserveFlow {
        source: Resource,
        destination: Resource,
    },
    ReleaseFlow {
        destination: Resource,
    },
}

Sequencer service request types.

Internal API for the sequencer service, which manages resource reservations and flow coordination to prevent race conditions and ensure consistent ordering of operations across the distributed system.

Variants

ReserveFlow

Reserve exclusive access for a data flow from source to destination.

Prevents concurrent modifications to the destination resource while a flow is being processed, ensuring data consistency and atomic operations.

Fields

source: Resource

Source resource providing data

destination: Resource

Destination resource receiving data

ReleaseFlow

Release a previously reserved flow to allow subsequent operations.

Must be called after flow completion to free the destination resource for other operations and maintain system throughput.

Fields

destination: Resource

Destination resource to release from reservation

Trait Implementations

impl Clone for SequencerRequest

fn clone(&self) -> SequencerRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SequencerRequest

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

Formats the value using the given formatter.

impl Service<SequencerRequest> for SequencerService

type Response = SequencerResponse

Responses given by the service.

type Error = TraceabilityError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<SequencerService as Service<SequencerRequest>>::Response, <SequencerService as Service<SequencerRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, request: SequencerRequest) -> Self::Future

Process the request and return the response asynchronously.

impl<T> Service<SequencerRequest> for WaitingQueueService<T>

where T: Service<SequencerRequest, Response = SequencerResponse, Error = TraceabilityError> + Clone + Sync + Send + 'static, T::Future: Send,

type Response = <T as Service<SequencerRequest>>::Response

Responses given by the service.

type Error = <T as Service<SequencerRequest>>::Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<WaitingQueueService<T> as Service<SequencerRequest>>::Response, <WaitingQueueService<T> as Service<SequencerRequest>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: SequencerRequest) -> Self::Future

Process the request and return the response asynchronously.