Struct GrpcMemoryService 

pub struct GrpcMemoryService<S> { /* private fields */ }

Implementations

impl<S: MemoryStore> GrpcMemoryService<S>

pub fn new(store: Arc<S>) -> Self

pub fn with_limits(store: Arc<S>, limits: ServerLimits) -> Self

pub fn with_observability( store: Arc<S>, limits: ServerLimits, metrics: Arc<ServerMetrics>, ) -> Self

pub fn with_runtime_config( store: Arc<S>, limits: ServerLimits, metrics: Arc<ServerMetrics>, auth: AuthConfig, ) -> Self

pub fn with_runtime(store: Arc<S>, runtime: ServerRuntime) -> Self

pub fn into_service(self) -> MemoryServiceServer<Self>

where Self: MemoryService,

Trait Implementations

impl<S> Clone for GrpcMemoryService<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S> MemoryService for GrpcMemoryService<S>

where S: MemoryStore + 'static,

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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