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.

class DummyStatsClient(
    host,
    port,
    prefix,
    maxudpsize,
    ipv6,
)

Create a new client.

Methods

close()

def close()

Used to close and clean up any underlying resources.

decr()

def decr(
    stat,
    count,
    rate,
)

Decrement a stat by count.

gauge()

def gauge(
    stat,
    value,
    rate,
    delta,
)

Set a gauge value.

incr()

def incr(
    stat,
    count,
    rate,
)

Increment a stat by count.

pipeline()

def pipeline()

set()

def set(
    stat,
    value,
    rate,
)

Set a set value.

timer()

def timer(
    stat,
    rate,
)

timing()

def timing(
    stat,
    delta,
    rate,
)

Send new timing information.

delta can be either a number of milliseconds or a timedelta.

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

class ScopeableStatsProxy(
    client,
    prefix,
)

Methods

get_stats()

def get_stats(
    name,
)

pipeline()

def pipeline()

flytekit.interfaces.stats.client.StatsClientProxy

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

class StatsClientProxy(
    client,
    prefix,
)

Methods

get_stats()

def get_stats(
    name,
)

pipeline()

def pipeline()