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 Type	Method	Description
default void	createDataPipeline(DataPipelines.CreateDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.CreateDataPipelineResponse> responseObserver)	CreateDataPipeline creates a new data pipeline with the provided configuration.
default void	deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.DeleteDataPipelineResponse> responseObserver)	DeleteDataPipeline deletes a data pipeline from the database.
default void	getDataPipeline(DataPipelines.GetDataPipelineRequest request, io.grpc.stub.StreamObserver<DataPipelines.GetDataPipelineResponse> responseObserver)	GetDataPipeline retrieves a specific data pipeline by its id.
default void	listDataPipelines(DataPipelines.ListDataPipelinesRequest request, io.grpc.stub.StreamObserver<DataPipelines.ListDataPipelinesResponse> responseObserver)	ListDataPipelines returns a list of data pipelines based on organization id.
default void	updateDataPipeline(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.