flytekit.interfaces.stats package

Submodules

flytekit.interfaces.stats.client module

class flytekit.interfaces.stats.client.DummyStatsClient(host='localhost', port=8125, prefix=None, maxudpsize=512, ipv6=False)[source]

Bases: statsd.client.udp.StatsClient

A dummy client for statsd.

class flytekit.interfaces.stats.client.ScopeableStatsProxy(client, prefix=None)[source]

Bases: object

A Proxy object for an underlying statsd client. Adds a new call, scope(prefix), which returns a new proxy to the same client which will prefix all calls to underlying methods with the scoped prefix: new_client = client.get_stats(‘a’) new_client.incr(‘b’) # Metric name = a.b This can be nested: newer_client = new_client.get_stats(‘subsystem’) newer_client.incr(‘bad’) # Metric name = a.subsystem.bad

EXTENDABLE_FUNC = ['incr', 'decr', 'timing', 'timer', 'gauge', 'set']
get_stats(name)[source]
pipeline()[source]
class flytekit.interfaces.stats.client.StatsClientProxy(client, prefix=None)[source]

Bases: flytekit.interfaces.stats.client.ScopeableStatsProxy

flytekit.interfaces.stats.client.get_base_stats(prefix)[source]
flytekit.interfaces.stats.client.get_stats(prefix)[source]

flytekit.interfaces.stats.taggable module

class flytekit.interfaces.stats.taggable.TaggableStats(client, full_prefix, prefix=None, tags=None)[source]

Bases: flytekit.interfaces.stats.client.ScopeableStatsProxy

EXTENDABLE_FUNC = ['incr', 'decr', 'timing', 'timer', 'gauge', 'set']
clear_tags()[source]
extend_tags(tags)[source]
property full_prefix
get_stats(name, copy_tags=True)[source]
pipeline()[source]
flytekit.interfaces.stats.taggable.get_stats(prefix, tags=None)[source]
Return type

TaggableStats

Module contents