Repository URL to install this package:
|
Version:
3.3.30 ▾
|
ó
čEYc @ s d e f d YZ d S( t Targetc B sY e Z d Z d d d d d d d d Z d Z d Z d Z d Z d Z RS( s%
Identifies the destination of messages.
A Target encapsulates all the information to identify where a message
should be sent or what messages a server is listening for.
Different subsets of the information encapsulated in a Target object is
relevant to various aspects of the API:
an RPC Server's target:
topic and server is required; exchange is optional
an RPC endpoint's target:
namespace and version is optional
an RPC client sending a message:
topic is required, all other attributes optional
a Notification Server's target:
topic is required, exchange is optional; all other attributes ignored
a Notifier's target:
topic is required, exchange is optional; all other attributes ignored
Its attributes are:
:param exchange: A scope for topics. Leave unspecified to default to the
control_exchange configuration option.
:type exchange: str
:param topic: A name which identifies the set of interfaces exposed by a
server. Multiple servers may listen on a topic and messages will be
dispatched to one of the servers selected in a best-effort round-robin
fashion (unless fanout is ``True``).
:type topic: str
:param namespace: Identifies a particular RPC interface (i.e. set of
methods) exposed by a server. The default interface has no namespace
identifier and is referred to as the null namespace.
:type namespace: str
:param version: RPC interfaces have a major.minor version number associated
with them. A minor number increment indicates a backwards compatible
change and an incompatible change is indicated by a major number bump.
Servers may implement multiple major versions and clients may require
indicate that their message requires a particular minimum minor version.
:type version: str
:param server: RPC Clients can request that a message be directed to a
specific server, rather than just one of a pool of servers listening on
the topic.
:type server: str
:param fanout: Clients may request that a copy of the message be delivered
to all servers listening on a topic by setting fanout to ``True``, rather
than just one of them.
:type fanout: bool
:param legacy_namespaces: A server always accepts messages specified via
the 'namespace' parameter, and may also accept messages defined via
this parameter. This option should be used to switch namespaces safely
during rolling upgrades.
:type legacy_namespaces: list of strings
c C sP | | _ | | _ | | _ | | _ | | _ | | _ | g | pE g | _ d S( N( t exchanget topict namespacet versiont servert fanoutt accepted_namespaces( t selfR R R R R R t legacy_namespaces( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt __init__I s c K s4 x' d D] } | j | t | | q Wt | S( NR R R R R R ( s exchanges topics namespaces versions servers fanout( t
setdefaultt getattrR ( R t kwargst a( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt __call__T s
c C s t | t | k S( N( t vars( R t other( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt __eq__Z s c C s | | k S( N( ( R R ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt __ne__] s c C s g } xK d d d d d d g D]1 } t | | } | r | j | | f q q Wd j g | D] } d | ^ qa } d | d
S( NR R R R R R s , s %s=%ss <Target t >( R t appendt join( R t attrsR t vt it values( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt __repr__` s &c C s
t | S( N( t id( R ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt __hash__j s N(
t __name__t
__module__t __doc__t NoneR
R R R R R ( ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyR s 6
N( t objectR ( ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/oslo_messaging/target.pyt <module> s