Trifle.Stats
v2.5.0

View Source Trifle.Stats.Buffer (Trifle.Stats v2.5.0)

Buffered write layer for Trifle.Stats.

Queues write operations (increment and set) and flushes them either when the queue reaches a configurable size or after a configurable duration. Supports optional aggregation, combining repeated operations on the same key set.

Summary

Types

t()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

flush(buffer)
flush_all()
inc(keys, values, buffer, count \\ 1, tracking_key \\ nil)
init_module()
new(opts)
set(keys, values, buffer, count \\ 1, tracking_key \\ nil)
shutdown(buffer)
start_link(opts)

Types

Link to this type

t()

View Source 
@type t() :: %Trifle.Stats.Buffer{pid: pid()}

Functions

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

flush(buffer)

View Source
Link to this function

flush_all()

View Source
Link to this function

inc(keys, values, buffer, count \\ 1, tracking_key \\ nil)

View Source
Link to this function

init_module()

View Source
Link to this function

new(opts)

View Source 
@spec new(keyword()) :: t()
Link to this function

set(keys, values, buffer, count \\ 1, tracking_key \\ nil)

View Source
Link to this function

shutdown(buffer)

View Source
Link to this function

start_link(opts)

View Source 
@spec start_link(keyword()) :: GenServer.on_start()