Package viam.app.datapipelines.v1
Class DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub>
viam.app.datapipelines.v1.DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub
- Enclosing class:
- DataPipelinesServiceGrpc
public static final class DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service DataPipelinesService.
DataPipelinesService is used to manage data pipelines.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>
-
Method Summary
Modifier and TypeMethodDescriptionbuild
(io.grpc.Channel channel, io.grpc.CallOptions callOptions) com.google.common.util.concurrent.ListenableFuture<DataPipelines.CreateDataPipelineResponse>
CreateDataPipeline creates a new data pipeline with the provided configuration.com.google.common.util.concurrent.ListenableFuture<DataPipelines.DeleteDataPipelineResponse>
DeleteDataPipeline deletes a data pipeline from the database.com.google.common.util.concurrent.ListenableFuture<DataPipelines.GetDataPipelineResponse>
GetDataPipeline retrieves a specific data pipeline by its id.com.google.common.util.concurrent.ListenableFuture<DataPipelines.ListDataPipelinesResponse>
ListDataPipelines returns a list of data pipelines based on organization id.com.google.common.util.concurrent.ListenableFuture<DataPipelines.UpdateDataPipelineResponse>
UpdateDataPipeline modifies an existing data pipeline's configuration.Methods inherited from class io.grpc.stub.AbstractFutureStub
newStub, newStub
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<DataPipelinesServiceGrpc.DataPipelinesServiceFutureStub>
-
getDataPipeline
public com.google.common.util.concurrent.ListenableFuture<DataPipelines.GetDataPipelineResponse> getDataPipeline(DataPipelines.GetDataPipelineRequest request) GetDataPipeline retrieves a specific data pipeline by its id.
-
listDataPipelines
public com.google.common.util.concurrent.ListenableFuture<DataPipelines.ListDataPipelinesResponse> listDataPipelines(DataPipelines.ListDataPipelinesRequest request) ListDataPipelines returns a list of data pipelines based on organization id.
-
createDataPipeline
public com.google.common.util.concurrent.ListenableFuture<DataPipelines.CreateDataPipelineResponse> createDataPipeline(DataPipelines.CreateDataPipelineRequest request) CreateDataPipeline creates a new data pipeline with the provided configuration.
-
updateDataPipeline
public com.google.common.util.concurrent.ListenableFuture<DataPipelines.UpdateDataPipelineResponse> updateDataPipeline(DataPipelines.UpdateDataPipelineRequest request) UpdateDataPipeline modifies an existing data pipeline's configuration.
-
deleteDataPipeline
public com.google.common.util.concurrent.ListenableFuture<DataPipelines.DeleteDataPipelineResponse> deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request) DeleteDataPipeline deletes a data pipeline from the database.
-