Trait re_protos::v0::storage_node_server::StorageNode

source · 
pub trait StorageNode: Send + Sync + 'static {
    type QueryStream: Stream<Item = Result<QueryResponse, Status>> + Send + 'static;
    type FetchRecordingStream: Stream<Item = Result<FetchRecordingResponse, Status>> + Send + 'static;

    // Required methods
    fn query<'life0, 'async_trait>(
        &'life0 self,
        request: Request<QueryRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::QueryStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn fetch_recording<'life0, 'async_trait>(
        &'life0 self,
        request: Request<FetchRecordingRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::FetchRecordingStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_recordings<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListRecordingsRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListRecordingsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_recording_metadata<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetRecordingMetadataRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetRecordingMetadataResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_recording_metadata<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateRecordingMetadataRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateRecordingMetadataResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn register_recording<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RegisterRecordingRequest>
    ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterRecordingResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

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

Required Associated Types§

source

type QueryStream: Stream<Item = Result<QueryResponse, Status>> + Send + 'static

Server streaming response type for the Query method.

source

type FetchRecordingStream: Stream<Item = Result<FetchRecordingResponse, Status>> + Send + 'static

Server streaming response type for the FetchRecording method.

Required Methods§

source

fn query<'life0, 'async_trait>( &'life0 self, request: Request<QueryRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::QueryStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

data API calls

source

fn fetch_recording<'life0, 'async_trait>( &'life0 self, request: Request<FetchRecordingRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::FetchRecordingStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn list_recordings<'life0, 'async_trait>( &'life0 self, request: Request<ListRecordingsRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ListRecordingsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

metadata API calls

source

fn get_recording_metadata<'life0, 'async_trait>( &'life0 self, request: Request<GetRecordingMetadataRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<GetRecordingMetadataResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn update_recording_metadata<'life0, 'async_trait>( &'life0 self, request: Request<UpdateRecordingMetadataRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateRecordingMetadataResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

source

fn register_recording<'life0, 'async_trait>( &'life0 self, request: Request<RegisterRecordingRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<RegisterRecordingResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§