Package viam.app.datapipelines.v1

Class DataPipelinesServiceGrpc.DataPipelinesServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

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

viam.app.datapipelines.v1.DataPipelinesServiceGrpc.DataPipelinesServiceBlockingStub

Enclosing class:

DataPipelinesServiceGrpc

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

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.DataPipelinesServiceBlockingStub	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.UpdateDataPipelineResponse	updateDataPipeline(DataPipelines.UpdateDataPipelineRequest request)	UpdateDataPipeline modifies an existing data pipeline's configuration.

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, 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.DataPipelinesServiceBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

getDataPipeline

public DataPipelines.GetDataPipelineResponse getDataPipeline(DataPipelines.GetDataPipelineRequest request)

 GetDataPipeline retrieves a specific data pipeline by its id.
 

listDataPipelines

public DataPipelines.ListDataPipelinesResponse listDataPipelines(DataPipelines.ListDataPipelinesRequest request)

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

createDataPipeline

public DataPipelines.CreateDataPipelineResponse createDataPipeline(DataPipelines.CreateDataPipelineRequest request)

 CreateDataPipeline creates a new data pipeline with the provided configuration.
 

updateDataPipeline

public DataPipelines.UpdateDataPipelineResponse updateDataPipeline(DataPipelines.UpdateDataPipelineRequest request)

 UpdateDataPipeline modifies an existing data pipeline's configuration.
 

deleteDataPipeline

public DataPipelines.DeleteDataPipelineResponse deleteDataPipeline(DataPipelines.DeleteDataPipelineRequest request)

 DeleteDataPipeline deletes a data pipeline from the database.
 

enableDataPipeline

public DataPipelines.EnableDataPipelineResponse enableDataPipeline(DataPipelines.EnableDataPipelineRequest request)

 EnableDataPipeline enables a data pipeline.
 

disableDataPipeline

public DataPipelines.DisableDataPipelineResponse disableDataPipeline(DataPipelines.DisableDataPipelineRequest request)

 DisableDataPipeline disables a data pipeline.
 

listDataPipelineRuns

public DataPipelines.ListDataPipelineRunsResponse listDataPipelineRuns(DataPipelines.ListDataPipelineRunsRequest request)

 ListDataPipelineRuns lists the runs of a data pipeline.