- 3.52.0 (latest)
- 3.50.0
- 3.49.0
- 3.48.0
- 3.47.0
- 3.46.0
- 3.45.0
- 3.44.0
- 3.43.0
- 3.42.0
- 3.41.0
- 3.40.0
- 3.38.0
- 3.37.0
- 3.36.0
- 3.35.0
- 3.34.0
- 3.33.0
- 3.32.0
- 3.31.0
- 3.30.0
- 3.29.0
- 3.28.0
- 3.25.0
- 3.24.0
- 3.23.0
- 3.22.0
- 3.21.0
- 3.20.0
- 3.19.0
- 3.18.0
- 3.17.0
- 3.16.0
- 3.15.0
- 3.14.0
- 3.13.0
- 3.12.0
- 3.11.0
- 3.10.0
- 3.9.0
- 3.8.0
- 3.7.0
- 3.6.0
- 3.5.0
- 3.4.2
- 3.3.0
- 3.2.0
- 3.0.0
- 2.9.8
- 2.8.9
- 2.7.4
- 2.5.3
- 2.4.0
public static final class MetadataServiceGrpc.MetadataServiceStub extends AbstractAsyncStub<MetadataServiceGrpc.MetadataServiceStub>
A stub to allow clients to do asynchronous rpc calls to service MetadataService.
Service for reading and writing metadata entries.
Inheritance
java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > MetadataServiceGrpc.MetadataServiceStubMethods
addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)
public void addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, 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.
Parameters | |
---|---|
Name | Description |
request |
AddContextArtifactsAndExecutionsRequest |
responseObserver |
io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse> |
addContextChildren(AddContextChildrenRequest request, StreamObserver<AddContextChildrenResponse> responseObserver)
public void addContextChildren(AddContextChildrenRequest request, 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.
Parameters | |
---|---|
Name | Description |
request |
AddContextChildrenRequest |
responseObserver |
io.grpc.stub.StreamObserver<AddContextChildrenResponse> |
addExecutionEvents(AddExecutionEventsRequest request, StreamObserver<AddExecutionEventsResponse> responseObserver)
public void addExecutionEvents(AddExecutionEventsRequest request, 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.
Parameters | |
---|---|
Name | Description |
request |
AddExecutionEventsRequest |
responseObserver |
io.grpc.stub.StreamObserver<AddExecutionEventsResponse> |
build(Channel channel, CallOptions callOptions)
protected MetadataServiceGrpc.MetadataServiceStub build(Channel channel, CallOptions callOptions)
Parameters | |
---|---|
Name | Description |
channel |
io.grpc.Channel |
callOptions |
io.grpc.CallOptions |
Returns | |
---|---|
Type | Description |
MetadataServiceGrpc.MetadataServiceStub |
createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)
public void createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)
Creates an Artifact associated with a MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
CreateArtifactRequest |
responseObserver |
io.grpc.stub.StreamObserver<Artifact> |
createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)
public void createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)
Creates a Context associated with a MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
CreateContextRequest |
responseObserver |
io.grpc.stub.StreamObserver<Context> |
createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)
public void createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)
Creates an Execution associated with a MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
CreateExecutionRequest |
responseObserver |
io.grpc.stub.StreamObserver<Execution> |
createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)
public void createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)
Creates a MetadataSchema.
Parameters | |
---|---|
Name | Description |
request |
CreateMetadataSchemaRequest |
responseObserver |
io.grpc.stub.StreamObserver<MetadataSchema> |
createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)
public void createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)
Initializes a MetadataStore, including allocation of resources.
Parameters | |
---|---|
Name | Description |
request |
CreateMetadataStoreRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)
public void deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)
Deletes an Artifact.
Parameters | |
---|---|
Name | Description |
request |
DeleteArtifactRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)
public void deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)
Deletes a stored Context.
Parameters | |
---|---|
Name | Description |
request |
DeleteContextRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)
public void deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)
Deletes an Execution.
Parameters | |
---|---|
Name | Description |
request |
DeleteExecutionRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)
public void deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)
Deletes a single MetadataStore and all its child resources (Artifacts, Executions, and Contexts).
Parameters | |
---|---|
Name | Description |
request |
DeleteMetadataStoreRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)
public void getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)
Retrieves a specific Artifact.
Parameters | |
---|---|
Name | Description |
request |
GetArtifactRequest |
responseObserver |
io.grpc.stub.StreamObserver<Artifact> |
getContext(GetContextRequest request, StreamObserver<Context> responseObserver)
public void getContext(GetContextRequest request, StreamObserver<Context> responseObserver)
Retrieves a specific Context.
Parameters | |
---|---|
Name | Description |
request |
GetContextRequest |
responseObserver |
io.grpc.stub.StreamObserver<Context> |
getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)
public void getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)
Retrieves a specific Execution.
Parameters | |
---|---|
Name | Description |
request |
GetExecutionRequest |
responseObserver |
io.grpc.stub.StreamObserver<Execution> |
getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)
public void getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)
Retrieves a specific MetadataSchema.
Parameters | |
---|---|
Name | Description |
request |
GetMetadataSchemaRequest |
responseObserver |
io.grpc.stub.StreamObserver<MetadataSchema> |
getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)
public void getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)
Retrieves a specific MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
GetMetadataStoreRequest |
responseObserver |
io.grpc.stub.StreamObserver<MetadataStore> |
listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)
public void listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)
Lists Artifacts in the MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
ListArtifactsRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListArtifactsResponse> |
listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)
public void listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)
Lists Contexts on the MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
ListContextsRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListContextsResponse> |
listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)
public void listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)
Lists Executions in the MetadataStore.
Parameters | |
---|---|
Name | Description |
request |
ListExecutionsRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListExecutionsResponse> |
listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)
public void listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)
Lists MetadataSchemas.
Parameters | |
---|---|
Name | Description |
request |
ListMetadataSchemasRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListMetadataSchemasResponse> |
listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)
public void listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)
Lists MetadataStores for a Location.
Parameters | |
---|---|
Name | Description |
request |
ListMetadataStoresRequest |
responseObserver |
io.grpc.stub.StreamObserver<ListMetadataStoresResponse> |
purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)
public void purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)
Purges Artifacts.
Parameters | |
---|---|
Name | Description |
request |
PurgeArtifactsRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)
public void purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)
Purges Contexts.
Parameters | |
---|---|
Name | Description |
request |
PurgeContextsRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)
public void purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)
Purges Executions.
Parameters | |
---|---|
Name | Description |
request |
PurgeExecutionsRequest |
responseObserver |
io.grpc.stub.StreamObserver<Operation> |
queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)
public void queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)
Retrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.
Parameters | |
---|---|
Name | Description |
request |
QueryArtifactLineageSubgraphRequest |
responseObserver |
io.grpc.stub.StreamObserver<LineageSubgraph> |
queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)
public void queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)
Retrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.
Parameters | |
---|---|
Name | Description |
request |
QueryContextLineageSubgraphRequest |
responseObserver |
io.grpc.stub.StreamObserver<LineageSubgraph> |
queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver<LineageSubgraph> responseObserver)
public void queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, 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.
Parameters | |
---|---|
Name | Description |
request |
QueryExecutionInputsAndOutputsRequest |
responseObserver |
io.grpc.stub.StreamObserver<LineageSubgraph> |
removeContextChildren(RemoveContextChildrenRequest request, StreamObserver<RemoveContextChildrenResponse> responseObserver)
public void removeContextChildren(RemoveContextChildrenRequest request, 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.
Parameters | |
---|---|
Name | Description |
request |
RemoveContextChildrenRequest |
responseObserver |
io.grpc.stub.StreamObserver<RemoveContextChildrenResponse> |
updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)
public void updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)
Updates a stored Artifact.
Parameters | |
---|---|
Name | Description |
request |
UpdateArtifactRequest |
responseObserver |
io.grpc.stub.StreamObserver<Artifact> |
updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)
public void updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)
Updates a stored Context.
Parameters | |
---|---|
Name | Description |
request |
UpdateContextRequest |
responseObserver |
io.grpc.stub.StreamObserver<Context> |
updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)
public void updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)
Updates a stored Execution.
Parameters | |
---|---|
Name | Description |
request |
UpdateExecutionRequest |
responseObserver |
io.grpc.stub.StreamObserver<Execution> |