viam.proto.stream

@generated by Viam. Do not edit manually!

Classes

StreamServiceBase

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

StreamServiceStub

UnimplementedStreamServiceBase

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

AddStreamRequest

A AddStreamRequest requests the given stream be added to the connection.

AddStreamResponse

AddStreamResponse is returned after a successful AddStreamRequest.

ListStreamsRequest

ListStreamsRequest requests all streams registered.

ListStreamsResponse

A ListStreamsResponse details streams registered.

RemoveStreamRequest

A RemoveStreamRequest requests the given stream be removed from the connection.

RemoveStreamResponse

RemoveStreamResponse is returned after a successful RemoveStreamRequest.

Package Contents

class viam.proto.stream.StreamServiceBase[source]

Bases: abc.ABC

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

abstract ListStreams(stream: grpclib.server.Stream[stream.v1.stream_pb2.ListStreamsRequest, stream.v1.stream_pb2.ListStreamsResponse]) None[source]
Async:

abstract AddStream(stream: grpclib.server.Stream[stream.v1.stream_pb2.AddStreamRequest, stream.v1.stream_pb2.AddStreamResponse]) None[source]
Async:

abstract RemoveStream(stream: grpclib.server.Stream[stream.v1.stream_pb2.RemoveStreamRequest, stream.v1.stream_pb2.RemoveStreamResponse]) None[source]
Async:

__mapping__() Dict[str, grpclib.const.Handler][source]
class viam.proto.stream.StreamServiceStub(channel: grpclib.client.Channel)[source]
class viam.proto.stream.UnimplementedStreamServiceBase[source]

Bases: StreamServiceBase

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

async ListStreams(stream: grpclib.server.Stream[stream.v1.stream_pb2.ListStreamsRequest, stream.v1.stream_pb2.ListStreamsResponse]) None[source]
async AddStream(stream: grpclib.server.Stream[stream.v1.stream_pb2.AddStreamRequest, stream.v1.stream_pb2.AddStreamResponse]) None[source]
async RemoveStream(stream: grpclib.server.Stream[stream.v1.stream_pb2.RemoveStreamRequest, stream.v1.stream_pb2.RemoveStreamResponse]) None[source]
class viam.proto.stream.AddStreamRequest(*, name: str = ...)

Bases: google.protobuf.message.Message

A AddStreamRequest requests the given stream be added to the connection.

name: str
class viam.proto.stream.AddStreamResponse

Bases: google.protobuf.message.Message

AddStreamResponse is returned after a successful AddStreamRequest.

class viam.proto.stream.ListStreamsRequest

Bases: google.protobuf.message.Message

ListStreamsRequest requests all streams registered.

class viam.proto.stream.ListStreamsResponse(*, names: collections.abc.Iterable[str] | None = ...)

Bases: google.protobuf.message.Message

A ListStreamsResponse details streams registered.

property names: google.protobuf.internal.containers.RepeatedScalarFieldContainer[str]
class viam.proto.stream.RemoveStreamRequest(*, name: str = ...)

Bases: google.protobuf.message.Message

A RemoveStreamRequest requests the given stream be removed from the connection.

name: str
class viam.proto.stream.RemoveStreamResponse

Bases: google.protobuf.message.Message

RemoveStreamResponse is returned after a successful RemoveStreamRequest.