Package viam.app.datapipelines.v1
Class DataPipelinesServiceGrpc.DataPipelinesServiceStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<DataPipelinesServiceGrpc.DataPipelinesServiceStub>
viam.app.datapipelines.v1.DataPipelinesServiceGrpc.DataPipelinesServiceStub
- Enclosing class:
- DataPipelinesServiceGrpc
public static final class DataPipelinesServiceGrpc.DataPipelinesServiceStub
extends io.grpc.stub.AbstractAsyncStub<DataPipelinesServiceGrpc.DataPipelinesServiceStub>
A stub to allow clients to do asynchronous 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) void
createDataPipeline
(DataPipelines.CreateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.CreateDataPipelineResponse> responseObserver) CreateDataPipeline creates a new data pipeline with the provided configuration.void
deleteDataPipeline
(DataPipelines.DeleteDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DeleteDataPipelineResponse> responseObserver) DeleteDataPipeline deletes a data pipeline from the database.void
getDataPipeline
(DataPipelines.GetDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.GetDataPipelineResponse> responseObserver) GetDataPipeline retrieves a specific data pipeline by its id.void
listDataPipelines
(DataPipelines.ListDataPipelinesRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelinesResponse> responseObserver) ListDataPipelines returns a list of data pipelines based on organization id.void
updateDataPipeline
(DataPipelines.UpdateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.UpdateDataPipelineResponse> responseObserver) UpdateDataPipeline modifies an existing data pipeline's configuration.Methods inherited from class io.grpc.stub.AbstractAsyncStub
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.DataPipelinesServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
build
in classio.grpc.stub.AbstractStub<DataPipelinesServiceGrpc.DataPipelinesServiceStub>
-
getDataPipeline
public void getDataPipeline(DataPipelines.GetDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.GetDataPipelineResponse> responseObserver) GetDataPipeline retrieves a specific data pipeline by its id.
-
listDataPipelines
public void listDataPipelines(DataPipelines.ListDataPipelinesRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelinesResponse> responseObserver) ListDataPipelines returns a list of data pipelines based on organization id.
-
createDataPipeline
public void createDataPipeline(DataPipelines.CreateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.CreateDataPipelineResponse> responseObserver) CreateDataPipeline creates a new data pipeline with the provided configuration.
-
updateDataPipeline
public void updateDataPipeline(DataPipelines.UpdateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.UpdateDataPipelineResponse> responseObserver) UpdateDataPipeline modifies an existing data pipeline's configuration.
-
deleteDataPipeline
public void deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DeleteDataPipelineResponse> responseObserver) DeleteDataPipeline deletes a data pipeline from the database.
-