HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.  2.0.0-chaika
Hierarchical Cluster Engine Python language binding
transport.ConnectionBuilderLight.ConnectionBuilderLight Class Reference

Class hides routines of bulding connection objects. More...

Inheritance diagram for transport.ConnectionBuilderLight.ConnectionBuilderLight:
Collaboration diagram for transport.ConnectionBuilderLight.ConnectionBuilderLight:

Public Member Functions

def __init__ (self)
 
def build (self, connect_type, connect_endpoint, protocol_type=consts.INPROC_TYPE, real_connect=True)
 build a connection More...
 

Public Attributes

 zmq_context
 
 zmq_poller
 

Static Private Attributes

 __metaclass__ = Singleton
 

Detailed Description

Class hides routines of bulding connection objects.

Definition at line 24 of file ConnectionBuilderLight.py.

Constructor & Destructor Documentation

◆ __init__()

def transport.ConnectionBuilderLight.ConnectionBuilderLight.__init__ (   self)
Constructor

Definition at line 27 of file ConnectionBuilderLight.py.

27  def __init__(self):
28  '''
29  Constructor
30  '''
31  try:
32  self.zmq_context = zmq.Context() # pylint: disable=E1101
33  #for Poller object
34  self.zmq_poller = zmq.Poller() # pylint: disable=E1101
35  except Exception as err:
36  ExceptionLog.handler(logger, err, 'Error:')
37  except:
38  ExceptionLog.handler(logger, None, 'Unknown error:')
39 
40 
def __init__(self)
constructor
Definition: UIDGenerator.py:19

Member Function Documentation

◆ build()

def transport.ConnectionBuilderLight.ConnectionBuilderLight.build (   self,
  connect_type,
  connect_endpoint,
  protocol_type = consts.INPROC_TYPE,
  real_connect = True 
)

build a connection

Parameters
connect_typetype of connection(CLIENT_CONNECT, SERVER_CONNECT)
connect_paramsan instance of ConnectionParams
Returns
Connection

Definition at line 46 of file ConnectionBuilderLight.py.

46  def build(self, connect_type, connect_endpoint, protocol_type=consts.INPROC_TYPE, real_connect=True):
47  try:
48  sock = None
49  if protocol_type == consts.TCP_TYPE:
50  protocol = "tcp://"
51  else:
52  protocol = "inproc://"
53  addr = protocol + connect_endpoint
54  if connect_type == consts.CLIENT_CONNECT:
55  sock = self.zmq_context.socket(zmq.DEALER) # pylint: disable=E1101
56  if real_connect:
57  sock.connect(addr)
58  if connect_type == consts.SERVER_CONNECT:
59  sock = self.zmq_context.socket(zmq.ROUTER) # pylint: disable=E1101
60  sock.bind(addr)
61  return ConnectionLight(sock, connect_type, addr, real_connect)
62  except Exception as err:
63  ExceptionLog.handler(logger, err, 'Error:')
64  except:
65  ExceptionLog.handler(logger, None, 'Unknown error:')
66 
67 

Member Data Documentation

◆ __metaclass__

transport.ConnectionBuilderLight.ConnectionBuilderLight.__metaclass__ = Singleton
staticprivate

Definition at line 25 of file ConnectionBuilderLight.py.

◆ zmq_context

transport.ConnectionBuilderLight.ConnectionBuilderLight.zmq_context

Definition at line 32 of file ConnectionBuilderLight.py.

◆ zmq_poller

transport.ConnectionBuilderLight.ConnectionBuilderLight.zmq_poller

Definition at line 34 of file ConnectionBuilderLight.py.


The documentation for this class was generated from the following file: