viam.gen.app.datapipelines.v1.data_pipelines_grpc

Classes

DataPipelinesServiceBase

Helper class that provides a standard way to create an ABC using

UnimplementedDataPipelinesServiceBase

Helper class that provides a standard way to create an ABC using

DataPipelinesServiceStub

Module Contents

class viam.gen.app.datapipelines.v1.data_pipelines_grpc.DataPipelinesServiceBase[source]

Bases: abc.ABC

Helper class that provides a standard way to create an ABC using inheritance.

abstract GetDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse]) None[source]
Async:

abstract ListDataPipelines(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse]) None[source]
Async:

abstract CreateDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse]) None[source]
Async:

abstract UpdateDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse]) None[source]
Async:

abstract DeleteDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse]) None[source]
Async:

__mapping__() Dict[str, grpclib.const.Handler][source]
class viam.gen.app.datapipelines.v1.data_pipelines_grpc.UnimplementedDataPipelinesServiceBase[source]

Bases: DataPipelinesServiceBase

Helper class that provides a standard way to create an ABC using inheritance.

async GetDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse]) None[source]
async ListDataPipelines(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest, app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse]) None[source]
async CreateDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse]) None[source]
async UpdateDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse]) None[source]
async DeleteDataPipeline(stream: grpclib.server.Stream[app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest, app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse]) None[source]
class viam.gen.app.datapipelines.v1.data_pipelines_grpc.DataPipelinesServiceStub(channel: grpclib.client.Channel)[source]
GetDataPipeline
ListDataPipelines
CreateDataPipeline
UpdateDataPipeline
DeleteDataPipeline