Module Expr Str Import alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias ClassDef bases AttributeLoad NameLoad attr body Expr Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad For NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Expr Call NameLoad NameLoad FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Pass decorator_list decorator_list
N/A N/A 
.. module:: riemann
   :platform: Unix
   :synopsis: A source module which provides Riemann servers

.. moduleauthor:: Colin Alston <colin@imcol.in>
 N/A time twisted.internet defer reactor twisted.names client twisted.internet.protocol Factory zope.interface implements tensor.interfaces ITensorSource tensor.objects Source Event tensor utils tensor.protocol riemann RiemannTCPServer N/A N/A riemann RiemannProtocol N/A N/A 
    Server implementation of the Riemann protocol
     __init__ N/A N/A self source N/A N/A N/A N/A N/A N/A riemann RiemannProtocol __init__ self N/A N/A self source source N/A stringReceived N/A N/A self string N/A N/A N/A message N/A N/A self decodeMessage string N/A event N/A message events N/A N/A N/A N/A N/A self source queueBack N/A Event N/A event state N/A event service N/A event description N/A event metric_f N/A event ttl hostname N/A event host evtime N/A event time N/A N/A RiemannTCPFactory N/A Factory N/A __init__ N/A N/A self source N/A N/A N/A N/A self source source N/A buildProtocol N/A N/A self addr N/A N/A N/A N/A RiemannTCPServer N/A self source N/A N/A RiemannTCP N/A Source N/A N/A Provides a listening server which accepts Riemann metrics
    and proxies them to our queue.

    **Configuration arguments:**

    :param port: Port to listen on (default 5555)
    :type port: int.

     N/A N/A implements ITensorSource startTimer N/A N/A self N/A N/A N/A Creates a Riemann TCP server instead of a timer
         N/A N/A N/A reactor listenTCP N/A int N/A N/A N/A self config get port 5555 N/A RiemannTCPFactory self N/A get N/A N/A self N/A N/A N/A N/A N/A