Struct google_api_proto::google::cloud::aiplatform::v1::featurestore_online_serving_service_client::FeaturestoreOnlineServingServiceClient
source · pub struct FeaturestoreOnlineServingServiceClient<T> { /* private fields */ }
Expand description
A service for serving online feature values.
Implementations§
source§impl<T> FeaturestoreOnlineServingServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> FeaturestoreOnlineServingServiceClient<T>where
T: GrpcService<BoxBody>,
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 with_interceptor<F>(
inner: T,
interceptor: F
) -> FeaturestoreOnlineServingServiceClient<InterceptedService<T, F>>where
F: Interceptor,
T::ResponseBody: Default,
T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>,
<T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
sourcepub fn send_compressed(self, encoding: CompressionEncoding) -> Self
pub fn send_compressed(self, encoding: CompressionEncoding) -> Self
Compress requests with the given encoding.
This requires the server to support it otherwise it might respond with an error.
sourcepub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self
Enable decompressing responses.
sourcepub fn max_decoding_message_size(self, limit: usize) -> Self
pub fn max_decoding_message_size(self, limit: usize) -> Self
Limits the maximum size of a decoded message.
Default: 4MB
sourcepub fn max_encoding_message_size(self, limit: usize) -> Self
pub fn max_encoding_message_size(self, limit: usize) -> Self
Limits the maximum size of an encoded message.
Default: usize::MAX
sourcepub async fn read_feature_values(
&mut self,
request: impl IntoRequest<ReadFeatureValuesRequest>
) -> Result<Response<ReadFeatureValuesResponse>, Status>
pub async fn read_feature_values( &mut self, request: impl IntoRequest<ReadFeatureValuesRequest> ) -> Result<Response<ReadFeatureValuesResponse>, Status>
Reads Feature values of a specific entity of an EntityType. For reading feature values of multiple entities of an EntityType, please use StreamingReadFeatureValues.
sourcepub async fn streaming_read_feature_values(
&mut self,
request: impl IntoRequest<StreamingReadFeatureValuesRequest>
) -> Result<Response<Streaming<ReadFeatureValuesResponse>>, Status>
pub async fn streaming_read_feature_values( &mut self, request: impl IntoRequest<StreamingReadFeatureValuesRequest> ) -> Result<Response<Streaming<ReadFeatureValuesResponse>>, Status>
Reads Feature values for multiple entities. Depending on their size, data for different entities may be broken up across multiple responses.
sourcepub async fn write_feature_values(
&mut self,
request: impl IntoRequest<WriteFeatureValuesRequest>
) -> Result<Response<WriteFeatureValuesResponse>, Status>
pub async fn write_feature_values( &mut self, request: impl IntoRequest<WriteFeatureValuesRequest> ) -> Result<Response<WriteFeatureValuesResponse>, Status>
Writes Feature values of one or more entities of an EntityType.
The Feature values are merged into existing entities if any. The Feature values to be written must have timestamp within the online storage retention.
Trait Implementations§
source§impl<T: Clone> Clone for FeaturestoreOnlineServingServiceClient<T>
impl<T: Clone> Clone for FeaturestoreOnlineServingServiceClient<T>
source§fn clone(&self) -> FeaturestoreOnlineServingServiceClient<T>
fn clone(&self) -> FeaturestoreOnlineServingServiceClient<T>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl<T> !Freeze for FeaturestoreOnlineServingServiceClient<T>
impl<T> RefUnwindSafe for FeaturestoreOnlineServingServiceClient<T>where
T: RefUnwindSafe,
impl<T> Send for FeaturestoreOnlineServingServiceClient<T>where
T: Send,
impl<T> Sync for FeaturestoreOnlineServingServiceClient<T>where
T: Sync,
impl<T> Unpin for FeaturestoreOnlineServingServiceClient<T>where
T: Unpin,
impl<T> UnwindSafe for FeaturestoreOnlineServingServiceClient<T>where
T: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request