rsb.transport.local¶
This package contains a highly efficient in-process transport implementation which allows participants inside one python process to communicate without serialization overhead.
Code author: jwienke
Functions
RLock (*args, **kwargs) |
Factory function that returns a new reentrant lock. |
initialize () |
Classes
Bus () |
Singleton-like representation of the local bus. |
InConnector ([bus, converters, options]) |
InConnector for the local transport. |
OutConnector ([bus, converters, options]) |
In-process OutConnector. |
TransportFactory |
TransportFactory implementation for the local transport. |
-
class
rsb.transport.local.
Bus
¶ Bases:
object
Singleton-like representation of the local bus.
Code author: jwienke
-
addSink
(sink)¶ Adds a sink for events pushed to the Bus.
Parameters: sink – the sink to add
-
getTransportURL
()¶
-
handle
(event)¶ Dispatches the provided event to all sinks of the appropriate scope.
Parameters: event (rsb.Event) – event to dispatch
-
removeSink
(sink)¶ Removes a sink to not be notified anymore.
Parameters: sink – sink to remove
-
-
class
rsb.transport.local.
InConnector
(bus=<rsb.transport.local.Bus object>, converters=None, options=None, **kwargs)¶ Bases:
rsb.transport.InConnector
InConnector for the local transport.
Code author: jwienke
-
activate
()¶
-
deactivate
()¶
-
filterNotify
(filter, action)¶
-
getScope
()¶
-
getTransportURL
()¶
-
getWireType
()¶ Returns the serialization type used for this connector.
Returns: python serialization type
-
handle
(event)¶
-
setObserverAction
(action)¶
-
setQualityOfServiceSpec
(qos)¶
-
setScope
(scope)¶
-
scope
¶
-
wireType
¶ Returns the serialization type used for this connector.
Returns: python serialization type
-
-
class
rsb.transport.local.
OutConnector
(bus=<rsb.transport.local.Bus object>, converters=None, options=None, **kwargs)¶ Bases:
rsb.transport.OutConnector
In-process OutConnector.
Code author: jwienke
-
activate
()¶
-
deactivate
()¶
-
getScope
()¶
-
getTransportURL
()¶
-
getWireType
()¶ Returns the serialization type used for this connector.
Returns: python serialization type
-
handle
(event)¶
-
setQualityOfServiceSpec
(qos)¶
-
setScope
(newValue)¶ Sets the scope this connector will receive events from to
newValue
. Called before #activate.Parameters: newValue (rsb.Scope) – scope of the connector
-
scope
¶
-
wireType
¶ Returns the serialization type used for this connector.
Returns: python serialization type
-
-
class
rsb.transport.local.
TransportFactory
¶ Bases:
rsb.transport.TransportFactory
TransportFactory
implementation for the local transport.Code author: jwienke
-
createInPushConnector
(converters, options)¶
-
createOutConnector
(converters, options)¶
-
getName
()¶
-
isRemote
()¶
-
-
rsb.transport.local.
initialize
()¶