Interface MetadataServiceGrpc.AsyncService
-
- All Known Implementing Classes:
MetadataServiceGrpc.MetadataServiceImplBase
- Enclosing class:
- MetadataServiceGrpc
public static interface MetadataServiceGrpc.AsyncService
Service for reading and writing metadata entries.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default void
addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)
Adds a set of Artifacts and Executions to a Context.default void
addContextChildren(AddContextChildrenRequest request, io.grpc.stub.StreamObserver<AddContextChildrenResponse> responseObserver)
Adds a set of Contexts as children to a parent Context.default void
addExecutionEvents(AddExecutionEventsRequest request, io.grpc.stub.StreamObserver<AddExecutionEventsResponse> responseObserver)
Adds Events to the specified Execution.default void
createArtifact(CreateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Creates an Artifact associated with a MetadataStore.default void
createContext(CreateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Creates a Context associated with a MetadataStore.default void
createExecution(CreateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Creates an Execution associated with a MetadataStore.default void
createMetadataSchema(CreateMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Creates a MetadataSchema.default void
createMetadataStore(CreateMetadataStoreRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Initializes a MetadataStore, including allocation of resources.default void
deleteArtifact(DeleteArtifactRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Artifact.default void
deleteContext(DeleteContextRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a stored Context.default void
deleteExecution(DeleteExecutionRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Execution.default 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).default void
getArtifact(GetArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Retrieves a specific Artifact.default void
getContext(GetContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Retrieves a specific Context.default void
getExecution(GetExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Retrieves a specific Execution.default void
getMetadataSchema(GetMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Retrieves a specific MetadataSchema.default void
getMetadataStore(GetMetadataStoreRequest request, io.grpc.stub.StreamObserver<MetadataStore> responseObserver)
Retrieves a specific MetadataStore.default void
listArtifacts(ListArtifactsRequest request, io.grpc.stub.StreamObserver<ListArtifactsResponse> responseObserver)
Lists Artifacts in the MetadataStore.default void
listContexts(ListContextsRequest request, io.grpc.stub.StreamObserver<ListContextsResponse> responseObserver)
Lists Contexts on the MetadataStore.default void
listExecutions(ListExecutionsRequest request, io.grpc.stub.StreamObserver<ListExecutionsResponse> responseObserver)
Lists Executions in the MetadataStore.default void
listMetadataSchemas(ListMetadataSchemasRequest request, io.grpc.stub.StreamObserver<ListMetadataSchemasResponse> responseObserver)
Lists MetadataSchemas.default void
listMetadataStores(ListMetadataStoresRequest request, io.grpc.stub.StreamObserver<ListMetadataStoresResponse> responseObserver)
Lists MetadataStores for a Location.default void
purgeArtifacts(PurgeArtifactsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Artifacts.default void
purgeContexts(PurgeContextsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Contexts.default void
purgeExecutions(PurgeExecutionsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Executions.default 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.default 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.default 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.default void
removeContextChildren(RemoveContextChildrenRequest request, io.grpc.stub.StreamObserver<RemoveContextChildrenResponse> responseObserver)
Remove a set of children contexts from a parent Context.default void
updateArtifact(UpdateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Updates a stored Artifact.default void
updateContext(UpdateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Updates a stored Context.default void
updateExecution(UpdateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Updates a stored Execution.
-
-
-
Method Detail
-
createMetadataStore
default void createMetadataStore(CreateMetadataStoreRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Initializes a MetadataStore, including allocation of resources.
-
getMetadataStore
default void getMetadataStore(GetMetadataStoreRequest request, io.grpc.stub.StreamObserver<MetadataStore> responseObserver)
Retrieves a specific MetadataStore.
-
listMetadataStores
default void listMetadataStores(ListMetadataStoresRequest request, io.grpc.stub.StreamObserver<ListMetadataStoresResponse> responseObserver)
Lists MetadataStores for a Location.
-
deleteMetadataStore
default 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
default void createArtifact(CreateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Creates an Artifact associated with a MetadataStore.
-
getArtifact
default void getArtifact(GetArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Retrieves a specific Artifact.
-
listArtifacts
default void listArtifacts(ListArtifactsRequest request, io.grpc.stub.StreamObserver<ListArtifactsResponse> responseObserver)
Lists Artifacts in the MetadataStore.
-
updateArtifact
default void updateArtifact(UpdateArtifactRequest request, io.grpc.stub.StreamObserver<Artifact> responseObserver)
Updates a stored Artifact.
-
deleteArtifact
default void deleteArtifact(DeleteArtifactRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Artifact.
-
purgeArtifacts
default void purgeArtifacts(PurgeArtifactsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Artifacts.
-
createContext
default void createContext(CreateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Creates a Context associated with a MetadataStore.
-
getContext
default void getContext(GetContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Retrieves a specific Context.
-
listContexts
default void listContexts(ListContextsRequest request, io.grpc.stub.StreamObserver<ListContextsResponse> responseObserver)
Lists Contexts on the MetadataStore.
-
updateContext
default void updateContext(UpdateContextRequest request, io.grpc.stub.StreamObserver<Context> responseObserver)
Updates a stored Context.
-
deleteContext
default void deleteContext(DeleteContextRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes a stored Context.
-
purgeContexts
default void purgeContexts(PurgeContextsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Contexts.
-
addContextArtifactsAndExecutions
default 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
default 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
default 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
default 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
default void createExecution(CreateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Creates an Execution associated with a MetadataStore.
-
getExecution
default void getExecution(GetExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Retrieves a specific Execution.
-
listExecutions
default void listExecutions(ListExecutionsRequest request, io.grpc.stub.StreamObserver<ListExecutionsResponse> responseObserver)
Lists Executions in the MetadataStore.
-
updateExecution
default void updateExecution(UpdateExecutionRequest request, io.grpc.stub.StreamObserver<Execution> responseObserver)
Updates a stored Execution.
-
deleteExecution
default void deleteExecution(DeleteExecutionRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Deletes an Execution.
-
purgeExecutions
default void purgeExecutions(PurgeExecutionsRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
Purges Executions.
-
addExecutionEvents
default 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
default 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
default void createMetadataSchema(CreateMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Creates a MetadataSchema.
-
getMetadataSchema
default void getMetadataSchema(GetMetadataSchemaRequest request, io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
Retrieves a specific MetadataSchema.
-
listMetadataSchemas
default void listMetadataSchemas(ListMetadataSchemasRequest request, io.grpc.stub.StreamObserver<ListMetadataSchemasResponse> responseObserver)
Lists MetadataSchemas.
-
queryArtifactLineageSubgraph
default 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.
-
-