Package viam.app.datapipelines.v1

Class DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub>

io.grpc.stub.AbstractBlockingStub<DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub>

viam.app.datapipelines.v1.DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub

Enclosing class:

DataPipelinesServiceGrpc

public static final class DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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 Type	Method	Description
protected DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
DataPipelines.CreateDataPipelineResponse	createDataPipeline(DataPipelines.CreateDataPipelineRequest request)	CreateDataPipeline creates a new data pipeline with the provided configuration.
DataPipelines.DeleteDataPipelineResponse	deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request)	DeleteDataPipeline deletes a data pipeline from the database.
DataPipelines.DisableDataPipelineResponse	disableDataPipeline(DataPipelines.DisableDataPipelineRequest request)	DisableDataPipeline disables a data pipeline.
DataPipelines.EnableDataPipelineResponse	enableDataPipeline(DataPipelines.EnableDataPipelineRequest request)	EnableDataPipeline enables a data pipeline.
DataPipelines.GetDataPipelineResponse	getDataPipeline(DataPipelines.GetDataPipelineRequest request)	GetDataPipeline retrieves a specific data pipeline by its id.
DataPipelines.ListDataPipelineRunsResponse	listDataPipelineRuns(DataPipelines.ListDataPipelineRunsRequest request)	ListDataPipelineRuns lists the runs of a data pipeline.
DataPipelines.ListDataPipelinesResponse	listDataPipelines(DataPipelines.ListDataPipelinesRequest request)	ListDataPipelines returns a list of data pipelines based on organization id.
DataPipelines.RenameDataPipelineResponse	renameDataPipeline(DataPipelines.RenameDataPipelineRequest request)	RenameDataPipeline changes a data pipeline's name.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

build

protected DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<DataPipelinesServiceGrpc.DataPipelinesServiceBlockingV2Stub>

getDataPipeline

public DataPipelines.GetDataPipelineResponse getDataPipeline(DataPipelines.GetDataPipelineRequest request)
                                                      throws io.grpc.StatusException

 GetDataPipeline retrieves a specific data pipeline by its id.
 

Throws:

io.grpc.StatusException

listDataPipelines

public DataPipelines.ListDataPipelinesResponse listDataPipelines(DataPipelines.ListDataPipelinesRequest request)
                                                          throws io.grpc.StatusException

 ListDataPipelines returns a list of data pipelines based on organization id.
 

Throws:

io.grpc.StatusException

createDataPipeline

public DataPipelines.CreateDataPipelineResponse createDataPipeline(DataPipelines.CreateDataPipelineRequest request)
                                                            throws io.grpc.StatusException

 CreateDataPipeline creates a new data pipeline with the provided configuration.
 

Throws:

io.grpc.StatusException

renameDataPipeline

public DataPipelines.RenameDataPipelineResponse renameDataPipeline(DataPipelines.RenameDataPipelineRequest request)
                                                            throws io.grpc.StatusException

 RenameDataPipeline changes a data pipeline's name.
 

Throws:

io.grpc.StatusException

deleteDataPipeline

public DataPipelines.DeleteDataPipelineResponse deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request)
                                                            throws io.grpc.StatusException

 DeleteDataPipeline deletes a data pipeline from the database.
 

Throws:

io.grpc.StatusException

enableDataPipeline

public DataPipelines.EnableDataPipelineResponse enableDataPipeline(DataPipelines.EnableDataPipelineRequest request)
                                                            throws io.grpc.StatusException

 EnableDataPipeline enables a data pipeline.
 

Throws:

io.grpc.StatusException

disableDataPipeline

public DataPipelines.DisableDataPipelineResponse disableDataPipeline(DataPipelines.DisableDataPipelineRequest request)
                                                              throws io.grpc.StatusException

 DisableDataPipeline disables a data pipeline.
 

Throws:

io.grpc.StatusException

listDataPipelineRuns

public DataPipelines.ListDataPipelineRunsResponse listDataPipelineRuns(DataPipelines.ListDataPipelineRunsRequest request)
                                                                throws io.grpc.StatusException

 ListDataPipelineRuns lists the runs of a data pipeline.
 

Throws:

io.grpc.StatusException