heka.client.
HekaClient
(stream, logger, severity=6, disabled_timers=None, filters=None, encoder='heka.encoders.ProtobufEncoder', hmc=None)[source]¶Client class encapsulating heka API, and providing storage for default values for various heka call settings.
add_method
(method, override=False)[source]¶Add a custom method to the HekaClient instance.
Parameters: |
|
---|
env_version
= '0.8'¶gauge
(name, value, logger=None, severity=None, fields=None, rate=1.0)[source]¶Sends an ‘current gauge measurement’ message.
Parameters: |
|
---|
heka
(type, logger=None, severity=None, payload='', fields=None, timestamp=None)[source]¶Create a single message and pass it to the sender for delivery.
Parameters: |
|
---|
incr
(name, count=1, logger=None, severity=None, fields=None, rate=1.0)[source]¶Sends an ‘increment counter’ message.
Parameters: |
|
---|
is_active
¶setup
(stream, encoder, hmc, logger='', severity=6, disabled_timers=None, filters=None)[source]¶Setup the HekaClient
Parameters: |
|
---|
timer
(name, logger=None, severity=None, fields=None, rate=1.0)[source]¶Return a timer object that can be used as a context manager or a decorator, generating a heka ‘timer’ message upon exit.
Parameters: |
|
---|
timer_send
(name, elapsed, logger=None, severity=None, fields=None, rate=1.0)[source]¶Converts timing data into a heka message for delivery.
Parameters: |
|
---|