Class MetadataServiceGrpc.MetadataServiceStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractAsyncStub<MetadataServiceGrpc.MetadataServiceStub>
-
- com.google.cloud.aiplatform.v1beta1.MetadataServiceGrpc.MetadataServiceStub
-
- Enclosing class:
- MetadataServiceGrpc
public static final class MetadataServiceGrpc.MetadataServiceStub extends io.grpc.stub.AbstractAsyncStub<MetadataServiceGrpc.MetadataServiceStub>
A stub to allow clients to do asynchronous rpc calls to service MetadataService.Service for reading and writing metadata entries.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)
Adds a set of Artifacts and Executions to a Context.void
addContextChildren(AddContextChildrenRequest request, io.grpc.stub.StreamObserver<AddContextChildrenResponse> responseObserver)
Adds a set of Contexts as children to a parent Context.void
addExecutionEvents(AddExecutionEventsRequest request, io.grpc.stub.StreamObserver<AddExecutionEventsResponse> responseObserver)
Adds Events to the specified Execution.protected MetadataServiceGrpc.MetadataServiceStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void
createArtifact(CreateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Creates an Artifact associated with a MetadataStore.void
createContext(CreateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Creates a Context associated with a MetadataStore.void
createExecution(CreateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Creates an Execution associated with a MetadataStore.void
createMetadataSchema(CreateMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Creates a MetadataSchema.void
createMetadataStore(CreateMetadataStoreRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Initializes a MetadataStore, including allocation of resources.void
deleteArtifact(DeleteArtifactRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Artifact.void
deleteContext(DeleteContextRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a stored Context.void
deleteExecution(DeleteExecutionRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Execution.void
deleteMetadataStore(DeleteMetadataStoreRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a single MetadataStore and all its child resources (Artifacts, Executions, and Contexts).void
getArtifact(GetArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Retrieves a specific Artifact.void
getContext(GetContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Retrieves a specific Context.void
getExecution(GetExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Retrieves a specific Execution.void
getMetadataSchema(GetMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Retrieves a specific MetadataSchema.void
getMetadataStore(GetMetadataStoreRequest request, io.grpc.stub.StreamObserver<MetadataStore> responseObserver)
Retrieves a specific MetadataStore.void
listArtifacts(ListArtifactsRequest request, io.grpc.stub.StreamObserver<ListArtifactsResponse> responseObserver)
Lists Artifacts in the MetadataStore.void
listContexts(ListContextsRequest request, io.grpc.stub.StreamObserver<ListContextsResponse> responseObserver)
Lists Contexts on the MetadataStore.void
listExecutions(ListExecutionsRequest request, io.grpc.stub.StreamObserver<ListExecutionsResponse> responseObserver)
Lists Executions in the MetadataStore.void
listMetadataSchemas(ListMetadataSchemasRequest request, io.grpc.stub.StreamObserver<ListMetadataSchemasResponse> responseObserver)
Lists MetadataSchemas.void
listMetadataStores(ListMetadataStoresRequest request, io.grpc.stub.StreamObserver<ListMetadataStoresResponse> responseObserver)
Lists MetadataStores for a Location.void
purgeArtifacts(PurgeArtifactsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Artifacts.void
purgeContexts(PurgeContextsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Contexts.void
purgeExecutions(PurgeExecutionsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Executions.void
queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, io.grpc.stub.StreamObserver<LineageSubgraph> responseObserver)
Retrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.void
queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, io.grpc.stub.StreamObserver<LineageSubgraph> responseObserver)
Retrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.void
queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, io.grpc.stub.StreamObserver<LineageSubgraph> responseObserver)
Obtains the set of input and output Artifacts for this Execution, in the form of LineageSubgraph that also contains the Execution and connecting Events.void
removeContextChildren(RemoveContextChildrenRequest request, io.grpc.stub.StreamObserver<RemoveContextChildrenResponse> responseObserver)
Remove a set of children contexts from a parent Context.void
updateArtifact(UpdateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Updates a stored Artifact.void
updateContext(UpdateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Updates a stored Context.void
updateExecution(UpdateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Updates a stored Execution.
-
-
-
Method Detail
-
build
protected MetadataServiceGrpc.MetadataServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<MetadataServiceGrpc.MetadataServiceStub>
-
createMetadataStore
public void createMetadataStore(CreateMetadataStoreRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Initializes a MetadataStore, including allocation of resources.
-
getMetadataStore
public void getMetadataStore(GetMetadataStoreRequest request, io.grpc.stub.StreamObserver<MetadataStore> responseObserver)
Retrieves a specific MetadataStore.
-
listMetadataStores
public void listMetadataStores(ListMetadataStoresRequest request, io.grpc.stub.StreamObserver<ListMetadataStoresResponse> responseObserver)
Lists MetadataStores for a Location.
-
deleteMetadataStore
public void deleteMetadataStore(DeleteMetadataStoreRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a single MetadataStore and all its child resources (Artifacts, Executions, and Contexts).
-
createArtifact
public void createArtifact(CreateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Creates an Artifact associated with a MetadataStore.
-
getArtifact
public void getArtifact(GetArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Retrieves a specific Artifact.
-
listArtifacts
public void listArtifacts(ListArtifactsRequest request, io.grpc.stub.StreamObserver<ListArtifactsResponse> responseObserver)
Lists Artifacts in the MetadataStore.
-
updateArtifact
public void updateArtifact(UpdateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Updates a stored Artifact.
-
deleteArtifact
public void deleteArtifact(DeleteArtifactRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Artifact.
-
purgeArtifacts
public void purgeArtifacts(PurgeArtifactsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Artifacts.
-
createContext
public void createContext(CreateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Creates a Context associated with a MetadataStore.
-
getContext
public void getContext(GetContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Retrieves a specific Context.
-
listContexts
public void listContexts(ListContextsRequest request, io.grpc.stub.StreamObserver<ListContextsResponse> responseObserver)
Lists Contexts on the MetadataStore.
-
updateContext
public void updateContext(UpdateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Updates a stored Context.
-
deleteContext
public void deleteContext(DeleteContextRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a stored Context.
-
purgeContexts
public void purgeContexts(PurgeContextsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Contexts.
-
addContextArtifactsAndExecutions
public void addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)
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.
-
addContextChildren
public void addContextChildren(AddContextChildrenRequest request, io.grpc.stub.StreamObserver<AddContextChildrenResponse> responseObserver)
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.
-
removeContextChildren
public void removeContextChildren(RemoveContextChildrenRequest request, io.grpc.stub.StreamObserver<RemoveContextChildrenResponse> responseObserver)
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.
-
queryContextLineageSubgraph
public void queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, io.grpc.stub.StreamObserver<LineageSubgraph> responseObserver)
Retrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.
-
createExecution
public void createExecution(CreateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Creates an Execution associated with a MetadataStore.
-
getExecution
public void getExecution(GetExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Retrieves a specific Execution.
-
listExecutions
public void listExecutions(ListExecutionsRequest request, io.grpc.stub.StreamObserver<ListExecutionsResponse> responseObserver)
Lists Executions in the MetadataStore.
-
updateExecution
public void updateExecution(UpdateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Updates a stored Execution.
-
deleteExecution
public void deleteExecution(DeleteExecutionRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Execution.
-
purgeExecutions
public void purgeExecutions(PurgeExecutionsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Executions.
-
addExecutionEvents
public void addExecutionEvents(AddExecutionEventsRequest request, io.grpc.stub.StreamObserver<AddExecutionEventsResponse> responseObserver)
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.
-
queryExecutionInputsAndOutputs
public void queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, io.grpc.stub.StreamObserver<LineageSubgraph> responseObserver)
Obtains the set of input and output Artifacts for this Execution, in the form of LineageSubgraph that also contains the Execution and connecting Events.
-
createMetadataSchema
public void createMetadataSchema(CreateMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Creates a MetadataSchema.
-
getMetadataSchema
public void getMetadataSchema(GetMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Retrieves a specific MetadataSchema.
-
listMetadataSchemas
public void listMetadataSchemas(ListMetadataSchemasRequest request, io.grpc.stub.StreamObserver<ListMetadataSchemasResponse> responseObserver)
Lists MetadataSchemas.
-
queryArtifactLineageSubgraph
public void queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, io.grpc.stub.StreamObserver<LineageSubgraph> responseObserver)
Retrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.
-
-