Trait Geyser

pub trait Geyser:
    Send
    + Sync
    + 'static {
    type SubscribeStream: Stream<Item = Result<SubscribeUpdate, Status>> + Send + 'static;

    // Required methods
    fn subscribe<'life0, 'async_trait>(
        &'life0 self,
        request: Request<Streaming<SubscribeRequest>>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe_replay_info<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SubscribeReplayInfoRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<SubscribeReplayInfoResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn ping<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PingRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<PongResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_latest_blockhash<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetLatestBlockhashRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetLatestBlockhashResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_block_height<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetBlockHeightRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetBlockHeightResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_slot<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetSlotRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetSlotResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn is_blockhash_valid<'life0, 'async_trait>(
        &'life0 self,
        request: Request<IsBlockhashValidRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<IsBlockhashValidResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_version<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetVersionRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetVersionResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Generated trait containing gRPC methods that should be implemented for use with GeyserServer.

Required Associated Types

type SubscribeStream: Stream<Item = Result<SubscribeUpdate, Status>> + Send + 'static

Server streaming response type for the Subscribe method.

Required Methods

fn subscribe<'life0, 'async_trait>( &'life0 self, request: Request<Streaming<SubscribeRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeStream>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_replay_info<'life0, 'async_trait>( &'life0 self, request: Request<SubscribeReplayInfoRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SubscribeReplayInfoResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn ping<'life0, 'async_trait>( &'life0 self, request: Request<PingRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PongResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_latest_blockhash<'life0, 'async_trait>( &'life0 self, request: Request<GetLatestBlockhashRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetLatestBlockhashResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_block_height<'life0, 'async_trait>( &'life0 self, request: Request<GetBlockHeightRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetBlockHeightResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_slot<'life0, 'async_trait>( &'life0 self, request: Request<GetSlotRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetSlotResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn is_blockhash_valid<'life0, 'async_trait>( &'life0 self, request: Request<IsBlockhashValidRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<IsBlockhashValidResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_version<'life0, 'async_trait>( &'life0 self, request: Request<GetVersionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetVersionResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors