Interface MetadataServiceGrpc.AsyncService

    • 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.
         
      • 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.
         
      • 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.
         
      • 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.
         
      • 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.
         
      • 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.
         
      • getMetadataSchema

        default void getMetadataSchema​(GetMetadataSchemaRequest request,
                                       io.grpc.stub.StreamObserver<MetadataSchema> responseObserver)
         Retrieves a specific MetadataSchema.
         
      • 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.