flytekit.interfaces.stats.client

Directory

Classes

Methods

Variables

Methods

get_base_stats()

def get_base_stats(
    cfg: flytekit.configuration.StatsConfig,
    prefix: str,
)

get_stats()

def get_stats(
    cfg: flytekit.configuration.StatsConfig,
    prefix: str,
)

flytekit.interfaces.stats.client.DummyStatsClient

A dummy client for statsd.

Parameters

class DummyStatsClient(
    host = 'localhost',
    port = 8125,
    prefix = None,
    maxudpsize = 512,
    ipv6 = False,
)

Create a new client.

flytekit.interfaces.stats.client.ScopeableStatsProxy

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

Parameters

class ScopeableStatsProxy(
    client,
    prefix = None,
)

Methods

get_stats()

def get_stats(
    name,
)

pipeline()

def pipeline()

flytekit.interfaces.stats.client.StatsClientProxy

Parameters

class StatsClientProxy(
    client,
    prefix = None,
)

Methods

get_stats()

def get_stats(
    name,
)

pipeline()

def pipeline()