klio.metrics
Subpackage for transform-level metrics.
MetricsRegistry
Main client to create and emit metrics.
MetricsRegistry.counter
Get or create a counter.
MetricsRegistry.gauge
Get or create a gauge.
MetricsRegistry.timer
Get or create a timer.
MetricsRegistry.marshal
Create a dictionary-representation of a given metric.
MetricsRegistry.unmarshal
Create a metric instance based off of a dictionary.
NativeMetricsClient
Metrics client for Beam-native metrics collection.
NativeMetricsClient.counter
Create a NativeCounter object.
NativeCounter
NativeMetricsClient.gauge
Create a NativeGauge object.
NativeGauge
NativeMetricsClient.timer
Create a NativeTimer object.
NativeTimer
Counter metric using Beam’s counter-type metric.
Gauge metric using Beam’s gauge-type metric.
Timer metric using Beam’s distribution-type metric.
MetricsLoggerClient
Logging client for transform metrics.
MetricsLoggerClient.logger
Python logger associated with the job which this client will use to emit metrics.
MetricsLoggerClient.unmarshal
Return a dict-representation of a given metric.
MetricsLoggerClient.emit
Log a given metric.
MetricsLoggerClient.counter
Create a LoggerCounter object.
LoggerCounter
MetricsLoggerClient.gauge
Create a LoggerGauge object.
LoggerGauge
MetricsLoggerClient.timer
Create a LoggerTimer object.
LoggerTimer
LoggerMetric
Base metric type for loggers.
Log-based counter metric.
Log-based gauge metric.
Log-based timer metric.
ShumwayMetricsClient
Metrics client for FFWD metrics reporting via the shumway library.
ShumwayMetricsClient.unmarshal
ShumwayMetricsClient.emit
Emit a metric to the FFWD agent.
ShumwayMetricsClient.counter
Create a ShumwayCounter object.
ShumwayCounter
ShumwayMetricsClient.gauge
Create a ShumwayGauge object.
ShumwayGauge
ShumwayMetricsClient.timer
Create a ShumwayTimer object.
ShumwayTimer
BaseShumwayMetric
Base metric type for shumway.
Shumway counter metric.
Shumway gauge metric.
Shumway timer metric.
BaseMetricDispatcher
Base class for metric-specific dispatching.
BaseMetricDispatcher.logger
Python logger associated with metric dispatcher.
BaseMetricDispatcher.submit
Emit metrics via a threadpool.
CounterDispatcher.inc
Increment counter.
GaugeDispatcher.set
Set gauge to a given value.
TimerDispatcher.start
Start the timer.
TimerDispatcher.stop
Stop the timer.
AbstractRelayClient
Abstract base class for all metric consumer relay clients.
AbstractRelayClient.unmarshal
Returns a dictionary-representation of the metric object
metric
AbstractRelayClient.emit
Emit the given metric object to the particular consumer.
AbstractRelayClient.counter
Return a newly instantiated counter-type metric specific for the particular consumer.
AbstractRelayClient.gauge
Return a newly instantiated gauge-type metric specific for the particular consumer.
AbstractRelayClient.timer
Return a newly instantiated timer-type metric specific for the particular consumer.
BaseMetric
Base class for all metric types.
abstract_attr
Set an attribute or a property as abstract.