remotivelabs.broker.generated.sync.network_api_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

GRPC_GENERATED_VERSION = '1.66.2'
GRPC_VERSION = '1.66.2'
class NetworkServiceStub:

/ Signal publish, subscribe and read.

NetworkServiceStub(channel)

Constructor.

Args: channel: A grpc.Channel.

SubscribeToSignals
SubscribeToSignalWithScript
SubscribeToFramesDistribution
PublishSignals
ReadSignals
class NetworkServiceServicer:

/ Signal publish, subscribe and read.

def SubscribeToSignals(self, request, context):

/ Subscribe to signals.

def SubscribeToSignalWithScript(self, request, context):

/ Subscribe to signals with transform provided as a LUA script.

def SubscribeToFramesDistribution(self, request, context):

/ A stream which emits frames distributions of a provided namespace. Useful for diagnostic purposes. Counts are reset every 500 ms.

def PublishSignals(self, request, context):

/ Publish signals with values.

def ReadSignals(self, request, context):

/ Read signals from cache.

def add_NetworkServiceServicer_to_server(servicer, server):
class NetworkService:

/ Signal publish, subscribe and read.

@staticmethod
def SubscribeToSignals( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
@staticmethod
def SubscribeToSignalWithScript( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
@staticmethod
def SubscribeToFramesDistribution( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
@staticmethod
def PublishSignals( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):
@staticmethod
def ReadSignals( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):