Class MetadataServiceGrpc.MetadataServiceFutureStub

  • Enclosing class:
    MetadataServiceGrpc

    public static final class MetadataServiceGrpc.MetadataServiceFutureStub
    extends io.grpc.stub.AbstractFutureStub<MetadataServiceGrpc.MetadataServiceFutureStub>
    A stub to allow clients to do ListenableFuture-style rpc calls to service MetadataService.
     Service for reading and writing metadata entries.
     
    • Method Detail

      • createMetadataStore

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> createMetadataStore​(CreateMetadataStoreRequest request)
         Initializes a MetadataStore, including allocation of resources.
         
      • getMetadataStore

        public com.google.common.util.concurrent.ListenableFuture<MetadataStore> getMetadataStore​(GetMetadataStoreRequest request)
         Retrieves a specific MetadataStore.
         
      • deleteMetadataStore

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> deleteMetadataStore​(DeleteMetadataStoreRequest request)
         Deletes a single MetadataStore and all its child resources (Artifacts,
         Executions, and Contexts).
         
      • createArtifact

        public com.google.common.util.concurrent.ListenableFuture<Artifact> createArtifact​(CreateArtifactRequest request)
         Creates an Artifact associated with a MetadataStore.
         
      • getArtifact

        public com.google.common.util.concurrent.ListenableFuture<Artifact> getArtifact​(GetArtifactRequest request)
         Retrieves a specific Artifact.
         
      • updateArtifact

        public com.google.common.util.concurrent.ListenableFuture<Artifact> updateArtifact​(UpdateArtifactRequest request)
         Updates a stored Artifact.
         
      • deleteArtifact

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> deleteArtifact​(DeleteArtifactRequest request)
         Deletes an Artifact.
         
      • purgeArtifacts

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> purgeArtifacts​(PurgeArtifactsRequest request)
         Purges Artifacts.
         
      • createContext

        public com.google.common.util.concurrent.ListenableFuture<Context> createContext​(CreateContextRequest request)
         Creates a Context associated with a MetadataStore.
         
      • getContext

        public com.google.common.util.concurrent.ListenableFuture<Context> getContext​(GetContextRequest request)
         Retrieves a specific Context.
         
      • updateContext

        public com.google.common.util.concurrent.ListenableFuture<Context> updateContext​(UpdateContextRequest request)
         Updates a stored Context.
         
      • deleteContext

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> deleteContext​(DeleteContextRequest request)
         Deletes a stored Context.
         
      • purgeContexts

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> purgeContexts​(PurgeContextsRequest request)
         Purges Contexts.
         
      • addContextChildren

        public com.google.common.util.concurrent.ListenableFuture<AddContextChildrenResponse> addContextChildren​(AddContextChildrenRequest request)
         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 com.google.common.util.concurrent.ListenableFuture<RemoveContextChildrenResponse> removeContextChildren​(RemoveContextChildrenRequest request)
         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 com.google.common.util.concurrent.ListenableFuture<LineageSubgraph> queryContextLineageSubgraph​(QueryContextLineageSubgraphRequest request)
         Retrieves Artifacts and Executions within the specified Context, connected
         by Event edges and returned as a LineageSubgraph.
         
      • createExecution

        public com.google.common.util.concurrent.ListenableFuture<Execution> createExecution​(CreateExecutionRequest request)
         Creates an Execution associated with a MetadataStore.
         
      • getExecution

        public com.google.common.util.concurrent.ListenableFuture<Execution> getExecution​(GetExecutionRequest request)
         Retrieves a specific Execution.
         
      • updateExecution

        public com.google.common.util.concurrent.ListenableFuture<Execution> updateExecution​(UpdateExecutionRequest request)
         Updates a stored Execution.
         
      • deleteExecution

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> deleteExecution​(DeleteExecutionRequest request)
         Deletes an Execution.
         
      • purgeExecutions

        public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> purgeExecutions​(PurgeExecutionsRequest request)
         Purges Executions.
         
      • addExecutionEvents

        public com.google.common.util.concurrent.ListenableFuture<AddExecutionEventsResponse> addExecutionEvents​(AddExecutionEventsRequest request)
         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 com.google.common.util.concurrent.ListenableFuture<LineageSubgraph> queryExecutionInputsAndOutputs​(QueryExecutionInputsAndOutputsRequest request)
         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 com.google.common.util.concurrent.ListenableFuture<LineageSubgraph> queryArtifactLineageSubgraph​(QueryArtifactLineageSubgraphRequest request)
         Retrieves lineage of an Artifact represented through Artifacts and
         Executions connected by Event edges and returned as a LineageSubgraph.