remotivelabs.broker.generated.sync.restbus_api_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

GRPC_GENERATED_VERSION = '1.66.2'

GRPC_VERSION = '1.66.2'

class RestbusServiceStub:

Missing associated documentation comment in .proto file.

RestbusServiceStub(channel)

Constructor.

Args: channel: A grpc.Channel.

Add

Remove

Update

Start

Stop

Reset

class RestbusServiceServicer:

Missing associated documentation comment in .proto file.

def Add(self, request, context):

Add starts the Restbus if the startOption is START_AFTER_INIT. Add removes any previous configuration before applying the new one.

def Remove(self, request, context):

Remove

def Update(self, request, context):

Update updates the values of signals configured in the Restbus. The values are updated and the Restbus will emit the new values at the next cycle after the update.

def Start(self, request, context):

Start starts the Restbus

def Stop(self, request, context):

Stop stops the Restbus

def Reset(self, request, context):

Reset resets signals configured in the Restbus or the whole Restbus depending on the request. Signals are reset to their default values as configured by the Configure request.

def add_RestbusServiceServicer_to_server(servicer, server):

class RestbusService:

Missing associated documentation comment in .proto file.

@staticmethod

def Add( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):

@staticmethod

def Remove( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):

@staticmethod

def Update( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):

@staticmethod

def Start( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):

@staticmethod

def Stop( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):

@staticmethod

def Reset( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None):