Class 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 Detail

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