flytekit.interfaces.stats.client

Directory

Classes

flytekit.interfaces.stats.client.DummyStatsClient

A dummy client for statsd.

def 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

def 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

def StatsClientProxy(
    client,
    prefix,
):

Methods

get_stats()

def get_stats(
    name,
):

pipeline()

def pipeline()

flytekit.interfaces.stats.client.StatsConfig

Configuration for sending statsd.

def StatsConfig(
    host: str,
    port: int,
    disabled: bool,
    disabled_tags: bool,
):

Methods

auto()

def auto(
    config_file: typing.Union[str, ConfigFile],
):

Reads from environment variable, followed by ConfigFile provided