Module Expr Str Import alias ImportFrom alias alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str Expr Call NameLoad NameLoad FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str BinOpMod Str AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign NameStore Call NameLoad Dict Str ListLoad NameLoad Assign NameStore Yield Call AttributeLoad NameLoad attr Str NameLoad NameLoad If AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad Assign NameStore Yield NameLoad Assign NameStore Call AttributeLoad NameLoad attr orelse Assign NameStore Str Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults body Assign NameStore Yield Call AttributeLoad NameLoad attr Assign NameStore BinOpDiv SubscriptLoad NameLoad Index Str Num Assign NameStore BinOpDiv SubscriptLoad NameLoad Index Str Num Expr Call AttributeLoad NameLoad attr ListLoad Call AttributeLoad NameLoad attr Str Str NameLoad keyword Str Call AttributeLoad NameLoad attr Str Str NameLoad keyword Str decorator_list AttributeLoad NameLoad attr decorator_list
N/A N/A 
.. module:: riak
   :platform: Any
   :synopsis: A source module for Riak metrics

.. moduleauthor:: Jeremy Thurgood <firxen@gmail.com>
 N/A json twisted.internet defer reactor twisted.web.client Agent twisted.web.http_headers Headers zope.interface implements tensor.interfaces ITensorSource tensor.objects Source tensor.utils BodyReceiver RiakStats N/A Source N/A N/A Returns GET/PUT rates for a Riak node

    **Configuration arguments:**

    :param url: Riak stats URL
    :type url: str.
    :param useragent: User-Agent header to use
    :type useragent: str.

    **Metrics:**

    :(service name).latency: Time to complete request
     N/A N/A implements ITensorSource _get_stats_from_node N/A N/A self N/A N/A N/A agent N/A Agent reactor N/A url N/A N/A N/A self config get url N/A http://%s:8098/stats N/A self hostname N/A ua N/A N/A N/A self config get useragent Tensor Riak stats checker N/A headers N/A Headers N/A User-Agent N/A ua N/A request N/A N/A N/A agent request GET url headers N/A N/A request length N/A N/A d N/A N/A defer Deferred N/A N/A N/A request deliverBody N/A BodyReceiver d N/A b N/A d N/A body N/A N/A b read N/A N/A body N/A N/A N/A defer returnValue N/A N/A json loads body N/A N/A defer inlineCallbacks get N/A N/A self N/A N/A N/A stats N/A N/A N/A self _get_stats_from_node N/A get_rate N/A N/A stats N/A node_gets 60.0 N/A put_rate N/A N/A stats N/A node_puts 60.0 N/A N/A N/A defer returnValue N/A N/A N/A self createEvent ok GETs per second for past minute get_rate prefix gets_per_second N/A N/A self createEvent ok PUTs per second for past minute put_rate prefix puts_per_second N/A N/A defer inlineCallbacks N/A