Struct Verifier

pub struct Verifier {
    batch: Verifier<Bls12>,
    vk: &'static BatchVerifyingKey,
    tx: Sender<Option<Result<(), VerificationError>>>,
}

Groth16 signature verifier implementation

This is the core implementation for the batch verification logic of the groth verifier. It handles batching incoming requests, driving batches to completion, and reporting results.

Fields

batch: Verifier<Bls12>

A batch verifier for groth16 proofs.

vk: &'static BatchVerifyingKey

The proof verification key.

Making this ’static makes managing lifetimes much easier.

tx: Sender<Option<Result<(), VerificationError>>>

A channel for broadcasting the result of a batch to the futures for each batch item.

Each batch gets a newly created channel, so there is only ever one result sent per channel. Tokio doesn’t have a oneshot multi-consumer channel, so we use a watch channel.

Implementations

impl Verifier

fn new(vk: &'static BatchVerifyingKey) -> Self

Create and return a new verifier using the verification key vk.

fn take( &mut self, ) -> (Verifier<Bls12>, &'static BatchVerifyingKey, Sender<Option<Result<(), VerificationError>>>)

Returns the batch verifier and channel sender from self, replacing them with a new empty batch.

fn verify( batch: Verifier<Bls12>, vk: &'static BatchVerifyingKey, tx: Sender<Option<Result<(), VerificationError>>>, )

Synchronously process the batch, and send the result using the channel sender. This function blocks until the batch is completed.

fn flush_blocking(&mut self)

Flush the batch using a thread pool, and return the result via the channel. This returns immediately, usually before the batch is completed.

async fn flush_spawning( batch: Verifier<Bls12>, vk: &'static BatchVerifyingKey, tx: Sender<Option<Result<(), VerificationError>>>, )

Flush the batch using a thread pool, and return the result via the channel. This function returns a future that becomes ready when the batch is completed.

async fn verify_single_spawning( item: Item, pvk: &'static ItemVerifyingKey, ) -> Result<(), BoxError>

Verify a single item using a thread pool, and return the result.

Trait Implementations

impl Debug for Verifier

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

Formats the value using the given formatter.

impl Drop for Verifier

fn drop(&mut self)

Executes the destructor for this type.

impl Service<BatchControl<Item<Bls12>>> for Verifier

type Response = ()

Responses given by the service.

type Error = Box<dyn Error + Sync + Send>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Sync + Send>>> + 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: BatchControl<Item>) -> Self::Future

Process the request and return the response asynchronously.