Package viam.app.datapipelines.v1
Interface DataPipelinesServiceGrpc.AsyncService
- All Known Implementing Classes:
DataPipelinesServiceGrpc.DataPipelinesServiceImplBase
- Enclosing class:
- DataPipelinesServiceGrpc
public static interface DataPipelinesServiceGrpc.AsyncService
DataPipelinesService is used to manage data pipelines.
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidcreateDataPipeline(DataPipelines.CreateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.CreateDataPipelineResponse> responseObserver) CreateDataPipeline creates a new data pipeline with the provided configuration.default voiddeleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DeleteDataPipelineResponse> responseObserver) DeleteDataPipeline deletes a data pipeline from the database.default voiddisableDataPipeline(DataPipelines.DisableDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DisableDataPipelineResponse> responseObserver) DisableDataPipeline disables a data pipeline.default voidenableDataPipeline(DataPipelines.EnableDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.EnableDataPipelineResponse> responseObserver) EnableDataPipeline enables a data pipeline.default voidgetDataPipeline(DataPipelines.GetDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.GetDataPipelineResponse> responseObserver) GetDataPipeline retrieves a specific data pipeline by its id.default voidlistDataPipelineRuns(DataPipelines.ListDataPipelineRunsRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelineRunsResponse> responseObserver) ListDataPipelineRuns lists the runs of a data pipeline.default voidlistDataPipelines(DataPipelines.ListDataPipelinesRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelinesResponse> responseObserver) ListDataPipelines returns a list of data pipelines based on organization id.default voidupdateDataPipeline(DataPipelines.UpdateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.UpdateDataPipelineResponse> responseObserver) UpdateDataPipeline modifies an existing data pipeline's configuration.
-
Method Details
-
getDataPipeline
default void getDataPipeline(DataPipelines.GetDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.GetDataPipelineResponse> responseObserver) GetDataPipeline retrieves a specific data pipeline by its id.
-
listDataPipelines
default void listDataPipelines(DataPipelines.ListDataPipelinesRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelinesResponse> responseObserver) ListDataPipelines returns a list of data pipelines based on organization id.
-
createDataPipeline
default void createDataPipeline(DataPipelines.CreateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.CreateDataPipelineResponse> responseObserver) CreateDataPipeline creates a new data pipeline with the provided configuration.
-
updateDataPipeline
default void updateDataPipeline(DataPipelines.UpdateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.UpdateDataPipelineResponse> responseObserver) UpdateDataPipeline modifies an existing data pipeline's configuration.
-
deleteDataPipeline
default void deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DeleteDataPipelineResponse> responseObserver) DeleteDataPipeline deletes a data pipeline from the database.
-
enableDataPipeline
default void enableDataPipeline(DataPipelines.EnableDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.EnableDataPipelineResponse> responseObserver) EnableDataPipeline enables a data pipeline.
-
disableDataPipeline
default void disableDataPipeline(DataPipelines.DisableDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DisableDataPipelineResponse> responseObserver) DisableDataPipeline disables a data pipeline.
-
listDataPipelineRuns
default void listDataPipelineRuns(DataPipelines.ListDataPipelineRunsRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelineRunsResponse> responseObserver) ListDataPipelineRuns lists the runs of a data pipeline.
-