Struct google_api_proto::google::cloud::aiplatform::v1::metadata_service_client::MetadataServiceClient

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

Service for reading and writing metadata entries.

Implementations

impl<T> MetadataServiceClient<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, ) -> MetadataServiceClient<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,

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.

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

Enable decompressing responses.

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

Limits the maximum size of a decoded message.

Default: 4MB

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

Limits the maximum size of an encoded message.

Default: usize::MAX

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

Initializes a MetadataStore, including allocation of resources.

pub async fn get_metadata_store( &mut self, request: impl IntoRequest<GetMetadataStoreRequest>, ) -> Result<Response<MetadataStore>, Status>

Retrieves a specific MetadataStore.

pub async fn list_metadata_stores( &mut self, request: impl IntoRequest<ListMetadataStoresRequest>, ) -> Result<Response<ListMetadataStoresResponse>, Status>

Lists MetadataStores for a Location.

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

Deletes a single MetadataStore and all its child resources (Artifacts, Executions, and Contexts).

pub async fn create_artifact( &mut self, request: impl IntoRequest<CreateArtifactRequest>, ) -> Result<Response<Artifact>, Status>

Creates an Artifact associated with a MetadataStore.

pub async fn get_artifact( &mut self, request: impl IntoRequest<GetArtifactRequest>, ) -> Result<Response<Artifact>, Status>

Retrieves a specific Artifact.

pub async fn list_artifacts( &mut self, request: impl IntoRequest<ListArtifactsRequest>, ) -> Result<Response<ListArtifactsResponse>, Status>

Lists Artifacts in the MetadataStore.

pub async fn update_artifact( &mut self, request: impl IntoRequest<UpdateArtifactRequest>, ) -> Result<Response<Artifact>, Status>

Updates a stored Artifact.

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

Deletes an Artifact.

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

Purges Artifacts.

pub async fn create_context( &mut self, request: impl IntoRequest<CreateContextRequest>, ) -> Result<Response<Context>, Status>

Creates a Context associated with a MetadataStore.

pub async fn get_context( &mut self, request: impl IntoRequest<GetContextRequest>, ) -> Result<Response<Context>, Status>

Retrieves a specific Context.

pub async fn list_contexts( &mut self, request: impl IntoRequest<ListContextsRequest>, ) -> Result<Response<ListContextsResponse>, Status>

Lists Contexts on the MetadataStore.

pub async fn update_context( &mut self, request: impl IntoRequest<UpdateContextRequest>, ) -> Result<Response<Context>, Status>

Updates a stored Context.

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

Deletes a stored Context.

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

Purges Contexts.

pub async fn add_context_artifacts_and_executions( &mut self, request: impl IntoRequest<AddContextArtifactsAndExecutionsRequest>, ) -> Result<Response<AddContextArtifactsAndExecutionsResponse>, Status>

Adds a set of Artifacts and Executions to a Context. If any of the Artifacts or Executions have already been added to a Context, they are simply skipped.

pub async fn add_context_children( &mut self, request: impl IntoRequest<AddContextChildrenRequest>, ) -> Result<Response<AddContextChildrenResponse>, Status>

Adds a set of Contexts as children to a parent Context. If any of the child Contexts have already been added to the parent Context, they are simply skipped. If this call would create a cycle or cause any Context to have more than 10 parents, the request will fail with an INVALID_ARGUMENT error.

pub async fn remove_context_children( &mut self, request: impl IntoRequest<RemoveContextChildrenRequest>, ) -> Result<Response<RemoveContextChildrenResponse>, Status>

Remove a set of children contexts from a parent Context. If any of the child Contexts were NOT added to the parent Context, they are simply skipped.

pub async fn query_context_lineage_subgraph( &mut self, request: impl IntoRequest<QueryContextLineageSubgraphRequest>, ) -> Result<Response<LineageSubgraph>, Status>

Retrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.

pub async fn create_execution( &mut self, request: impl IntoRequest<CreateExecutionRequest>, ) -> Result<Response<Execution>, Status>

Creates an Execution associated with a MetadataStore.

pub async fn get_execution( &mut self, request: impl IntoRequest<GetExecutionRequest>, ) -> Result<Response<Execution>, Status>

Retrieves a specific Execution.

pub async fn list_executions( &mut self, request: impl IntoRequest<ListExecutionsRequest>, ) -> Result<Response<ListExecutionsResponse>, Status>

Lists Executions in the MetadataStore.

pub async fn update_execution( &mut self, request: impl IntoRequest<UpdateExecutionRequest>, ) -> Result<Response<Execution>, Status>

Updates a stored Execution.

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

Deletes an Execution.

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

Purges Executions.

pub async fn add_execution_events( &mut self, request: impl IntoRequest<AddExecutionEventsRequest>, ) -> Result<Response<AddExecutionEventsResponse>, Status>

Adds Events to the specified Execution. An Event indicates whether an Artifact was used as an input or output for an Execution. If an Event already exists between the Execution and the Artifact, the Event is skipped.

pub async fn query_execution_inputs_and_outputs( &mut self, request: impl IntoRequest<QueryExecutionInputsAndOutputsRequest>, ) -> Result<Response<LineageSubgraph>, Status>

Obtains the set of input and output Artifacts for this Execution, in the form of LineageSubgraph that also contains the Execution and connecting Events.

pub async fn create_metadata_schema( &mut self, request: impl IntoRequest<CreateMetadataSchemaRequest>, ) -> Result<Response<MetadataSchema>, Status>

Creates a MetadataSchema.

pub async fn get_metadata_schema( &mut self, request: impl IntoRequest<GetMetadataSchemaRequest>, ) -> Result<Response<MetadataSchema>, Status>

Retrieves a specific MetadataSchema.

pub async fn list_metadata_schemas( &mut self, request: impl IntoRequest<ListMetadataSchemasRequest>, ) -> Result<Response<ListMetadataSchemasResponse>, Status>

Lists MetadataSchemas.

pub async fn query_artifact_lineage_subgraph( &mut self, request: impl IntoRequest<QueryArtifactLineageSubgraphRequest>, ) -> Result<Response<LineageSubgraph>, Status>

Retrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.

Trait Implementations

impl<T: Clone> Clone for MetadataServiceClient<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MetadataServiceClient<T>

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

Formats the value using the given formatter.