miden-validator 0.16.0-alpha.1

Miden validator
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

use std::sync::atomic::Ordering;

use miden_node_proto::generated as grpc;

use super::ValidatorService;

#[tonic::async_trait]
impl grpc::server::validator_api::Status for ValidatorService {
    type Input = ();
    type Output = ();

    async fn full(
        &self,
        _request: tonic::Request<()>,
    ) -> tonic::Result<grpc::validator::ValidatorStatus> {
        // Unlike the other RPCs, status stays available during a backup so operators can observe
        // the validator. A failed read means a backup subscription holds the exclusive lock.
        let status = match self.serve_lock.try_read() {
            Ok(_guard) => "OK",
            Err(_) => "BACKUP",
        };

        Ok(grpc::validator::ValidatorStatus {
            version: env!("CARGO_PKG_VERSION").to_string(),
            status: status.to_string(),
            chain_tip: self.committed_tip.borrow().as_u32(),
            validated_transactions_count: self.validated_transactions_count.load(Ordering::Relaxed),
            signed_blocks_count: self.signed_blocks_count.load(Ordering::Relaxed),
        })
    }

    async fn handle(
        &self,
        _input: Self::Input,
        _metadata: &tonic::metadata::MetadataMap,
        _extensions: &tonic::codegen::http::Extensions,
    ) -> tonic::Result<Self::Output> {
        unimplemented!()
    }

    fn decode(_request: ()) -> tonic::Result<Self::Input> {
        unimplemented!()
    }

    fn encode(_output: Self::Output) -> tonic::Result<grpc::validator::ValidatorStatus> {
        unimplemented!()
    }
}