Struct gapi_grpc::google::cloud::aiplatform::v1beta1::featurestore_service_client::FeaturestoreServiceClient

pub struct FeaturestoreServiceClient<T> { /* fields omitted */ }

The service that handles CRUD and List for resources for Featurestore.

Implementations

impl FeaturestoreServiceClient<Channel>

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

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

impl<T> FeaturestoreServiceClient<T> where
    T: GrpcService<BoxBody>,
    T::ResponseBody: Body + HttpBody + Send + 'static,
    T::Error: Into<StdError>,
    <T::ResponseBody as HttpBody>::Error: Into<StdError> + Send, 

pub fn new(inner: T) -> Self

pub fn with_interceptor(inner: T, interceptor: impl Into<Interceptor>) -> Self

pub async fn create_featurestore(
    &mut self,
    request: impl IntoRequest<CreateFeaturestoreRequest>
) -> Result<Response<Operation>, Status>

Creates a new Featurestore in a given project and location.

pub async fn get_featurestore(
    &mut self,
    request: impl IntoRequest<GetFeaturestoreRequest>
) -> Result<Response<Featurestore>, Status>

Gets details of a single Featurestore.

pub async fn list_featurestores(
    &mut self,
    request: impl IntoRequest<ListFeaturestoresRequest>
) -> Result<Response<ListFeaturestoresResponse>, Status>

Lists Featurestores in a given project and location.

pub async fn update_featurestore(
    &mut self,
    request: impl IntoRequest<UpdateFeaturestoreRequest>
) -> Result<Response<Operation>, Status>

Updates the parameters of a single Featurestore.

pub async fn delete_featurestore(
    &mut self,
    request: impl IntoRequest<DeleteFeaturestoreRequest>
) -> Result<Response<Operation>, Status>

Deletes a single Featurestore. The Featurestore must not contain any EntityTypes or force must be set to true for the request to succeed.

pub async fn create_entity_type(
    &mut self,
    request: impl IntoRequest<CreateEntityTypeRequest>
) -> Result<Response<Operation>, Status>

Creates a new EntityType in a given Featurestore.

pub async fn get_entity_type(
    &mut self,
    request: impl IntoRequest<GetEntityTypeRequest>
) -> Result<Response<EntityType>, Status>

Gets details of a single EntityType.

pub async fn list_entity_types(
    &mut self,
    request: impl IntoRequest<ListEntityTypesRequest>
) -> Result<Response<ListEntityTypesResponse>, Status>

Lists EntityTypes in a given Featurestore.

pub async fn update_entity_type(
    &mut self,
    request: impl IntoRequest<UpdateEntityTypeRequest>
) -> Result<Response<EntityType>, Status>

Updates the parameters of a single EntityType.

pub async fn delete_entity_type(
    &mut self,
    request: impl IntoRequest<DeleteEntityTypeRequest>
) -> Result<Response<Operation>, Status>

Deletes a single EntityType. The EntityType must not have any Features or force must be set to true for the request to succeed.

pub async fn create_feature(
    &mut self,
    request: impl IntoRequest<CreateFeatureRequest>
) -> Result<Response<Operation>, Status>

Creates a new Feature in a given EntityType.

pub async fn batch_create_features(
    &mut self,
    request: impl IntoRequest<BatchCreateFeaturesRequest>
) -> Result<Response<Operation>, Status>

Creates a batch of Features in a given EntityType.

pub async fn get_feature(
    &mut self,
    request: impl IntoRequest<GetFeatureRequest>
) -> Result<Response<Feature>, Status>

Gets details of a single Feature.

pub async fn list_features(
    &mut self,
    request: impl IntoRequest<ListFeaturesRequest>
) -> Result<Response<ListFeaturesResponse>, Status>

Lists Features in a given EntityType.

pub async fn update_feature(
    &mut self,
    request: impl IntoRequest<UpdateFeatureRequest>
) -> Result<Response<Feature>, Status>

Updates the parameters of a single Feature.

pub async fn delete_feature(
    &mut self,
    request: impl IntoRequest<DeleteFeatureRequest>
) -> Result<Response<Operation>, Status>

Deletes a single Feature.

pub async fn import_feature_values(
    &mut self,
    request: impl IntoRequest<ImportFeatureValuesRequest>
) -> Result<Response<Operation>, Status>

Imports Feature values into the Featurestore from a source storage.

The progress of the import is tracked by the returned operation. The imported features are guaranteed to be visible to subsequent read operations after the operation is marked as successfully done.

If an import operation fails, the Feature values returned from reads and exports may be inconsistent. If consistency is required, the caller must retry the same import request again and wait till the new operation returned is marked as successfully done.

There are also scenarios where the caller can cause inconsistency.

• Source data for import contains multiple distinct Feature values for the same entity ID and timestamp.
• Source is modified during an import. This includes adding, updating, or removing source data and/or metadata. Examples of updating metadata include but are not limited to changing storage location, storage class, or retention policy.
• Online serving cluster is under-provisioned.

pub async fn batch_read_feature_values(
    &mut self,
    request: impl IntoRequest<BatchReadFeatureValuesRequest>
) -> Result<Response<Operation>, Status>

Batch reads Feature values from a Featurestore.

This API enables batch reading Feature values, where each read instance in the batch may read Feature values of entities from one or more EntityTypes. Point-in-time correctness is guaranteed for Feature values of each read instance as of each instance’s read timestamp.

pub async fn export_feature_values(
    &mut self,
    request: impl IntoRequest<ExportFeatureValuesRequest>
) -> Result<Response<Operation>, Status>

Exports Feature values from all the entities of a target EntityType.

pub async fn search_features(
    &mut self,
    request: impl IntoRequest<SearchFeaturesRequest>
) -> Result<Response<SearchFeaturesResponse>, Status>

Searches Features matching a query in a given project.

Trait Implementations

impl<T: Clone> Clone for FeaturestoreServiceClient<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for FeaturestoreServiceClient<T>

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

Formats the value using the given formatter.