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):