Struct zebra_consensus::router::BlockVerifierRouter

struct BlockVerifierRouter<S, V>
where
    S: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static,
    S::Future: Send + 'static,
    V: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static,
    V::Future: Send + 'static,
{
    checkpoint: CheckpointVerifier<S>,
    max_checkpoint_height: Height,
    block: SemanticBlockVerifier<S, V>,
}

The block verifier router routes requests to either the checkpoint verifier or the semantic block verifier, depending on the maximum checkpoint height.

Correctness

Block verification requests should be wrapped in a timeout, so that out-of-order and invalid requests do not hang indefinitely. See the router module documentation for details.

Fields

checkpoint: CheckpointVerifier<S>

The checkpointing block verifier.

Always used for blocks before Canopy, optionally used for the entire checkpoint list.

max_checkpoint_height: Height

The highest permitted checkpoint block.

This height must be in the checkpoint verifier’s checkpoint list.

block: SemanticBlockVerifier<S, V>

The full semantic block verifier, used for blocks after max_checkpoint_height.

Trait Implementations

impl<S, V> Service<Request> for BlockVerifierRouter<S, V>

where S: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, S::Future: Send + 'static, V: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static, V::Future: Send + 'static,

type Response = Hash

Responses given by the service.

type Error = RouterError

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<BlockVerifierRouter<S, V> as Service<Request>>::Response, <BlockVerifierRouter<S, V> as Service<Request>>::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, request: Request) -> Self::Future

Process the request and return the response asynchronously.