Struct MemoryServiceClient

pub struct MemoryServiceClient<T> { /* private fields */ }

Implementations§

Attempt to create a new client by connecting to a given endpoint.

Compress requests with the given encoding.

This requires the server to support it otherwise it might respond with an error.

Enable decompressing responses.

Limits the maximum size of a decoded message.

Default: 4MB

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

Converts to this type from a reference to the input type.

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Wrap the input message T in a tonic::Request

Applies the layer to a service and wraps it in Layered.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct MemoryServiceClient Copy item path

Implementations§

impl MemoryServiceClient<Channel>

pub async fn connect<D>(dst: D) -> Result<Self, Error>where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> MemoryServiceClient<T>where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

pub fn new(inner: T) -> Self

pub fn with_origin(inner: T, origin: Uri) -> Self

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

pub fn max_decoding_message_size(self, limit: usize) -> Self

pub fn max_encoding_message_size(self, limit: usize) -> Self

pub async fn upsert_memory_record( &mut self, request: impl IntoRequest<UpsertMemoryRecordRequest>, ) -> Result<Response<UpsertMemoryRecordReply>, Status>

pub async fn batch_upsert_memory_records( &mut self, request: impl IntoRequest<BatchUpsertMemoryRecordsRequest>, ) -> Result<Response<BatchUpsertMemoryRecordsReply>, Status>

pub async fn recall( &mut self, request: impl IntoRequest<RecallRequest>, ) -> Result<Response<RecallReply>, Status>

pub async fn compact( &mut self, request: impl IntoRequest<CompactRequest>, ) -> Result<Response<CompactReply>, Status>

pub async fn snapshot( &mut self, request: impl IntoRequest<SnapshotRequest>, ) -> Result<Response<SnapshotReply>, Status>

pub async fn delete( &mut self, request: impl IntoRequest<DeleteRequest>, ) -> Result<Response<DeleteReply>, Status>

pub async fn archive( &mut self, request: impl IntoRequest<ArchiveRequest>, ) -> Result<Response<ArchiveReply>, Status>

pub async fn suppress( &mut self, request: impl IntoRequest<SuppressRequest>, ) -> Result<Response<SuppressReply>, Status>

pub async fn recover( &mut self, request: impl IntoRequest<RecoverRequest>, ) -> Result<Response<RecoverReply>, Status>

pub async fn stats( &mut self, request: impl IntoRequest<StoreStatsRequest>, ) -> Result<Response<StoreStatsReply>, Status>

pub async fn integrity_check( &mut self, request: impl IntoRequest<IntegrityCheckRequest>, ) -> Result<Response<IntegrityCheckReply>, Status>

pub async fn repair( &mut self, request: impl IntoRequest<RepairRequest>, ) -> Result<Response<RepairReply>, Status>

pub async fn list_traces( &mut self, request: impl IntoRequest<ListTracesRequest>, ) -> Result<Response<ListTracesReply>, Status>

pub async fn get_trace( &mut self, request: impl IntoRequest<GetTraceRequest>, ) -> Result<Response<OperationTrace>, Status>

pub async fn export( &mut self, request: impl IntoRequest<ExportRequest>, ) -> Result<Response<ExportReply>, Status>

pub async fn import( &mut self, request: impl IntoRequest<ImportRequest>, ) -> Result<Response<ImportReply>, Status>

Trait Implementations§

impl<T: Clone> Clone for MemoryServiceClient<T>

fn clone(&self) -> MemoryServiceClient<T>

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

impl<T: Debug> Debug for MemoryServiceClient<T>

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

Auto Trait Implementations§

impl<T> !Freeze for MemoryServiceClient<T>

impl<T> RefUnwindSafe for MemoryServiceClient<T>where T: RefUnwindSafe,

impl<T> Send for MemoryServiceClient<T>where T: Send,

impl<T> Sync for MemoryServiceClient<T>where T: Sync,

impl<T> Unpin for MemoryServiceClient<T>where T: Unpin,

impl<T> UnsafeUnpin for MemoryServiceClient<T>where T: UnsafeUnpin,

impl<T> UnwindSafe for MemoryServiceClient<T>where T: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct MemoryServiceClient

pub async fn connect<D>(dst: D) -> Result<Self, Error>
where D: TryInto<Endpoint>, D::Error: Into<StdError>,

impl<T> MemoryServiceClient<T>
where T: GrpcService<Body>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,

impl<T> RefUnwindSafe for MemoryServiceClient<T>
where T: RefUnwindSafe,

impl<T> Send for MemoryServiceClient<T>
where T: Send,

impl<T> Sync for MemoryServiceClient<T>
where T: Sync,

impl<T> Unpin for MemoryServiceClient<T>
where T: Unpin,

impl<T> UnsafeUnpin for MemoryServiceClient<T>
where T: UnsafeUnpin,

impl<T> UnwindSafe for MemoryServiceClient<T>
where T: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,