View Source EchoPubSub.Producer.Telemetry (EchoPubSub v0.2.3)

The producer's telemetry events and its throttled buffer-capacity warning.

Summary

Functions

expired(group, node, missed)

[:echo_pubsub, :buffer, :expired]: node was told it missed missed messages.

flush(group, buffer_size, buffer_capacity)

[:echo_pubsub, :buffer, :flush]: unacked messages vs. buffer capacity.

maybe_warn_capacity(group, buffer_size, buffer_capacity, threshold, interval, last_at)

Logs and emits [:echo_pubsub, :buffer, :capacity_warning] when the fill ratio reaches threshold and interval seconds passed since last_at. Returns the new last_at.

retry_scheduled(group)

[:echo_pubsub, :retry, :scheduled]: a retry flush was scheduled.

sync_failure(group, node, batch_size)

[:echo_pubsub, :sync, :failure]: a batch of batch_size to node failed.

Functions

expired(group, node, missed)

@spec expired(atom(), node(), pos_integer()) :: :ok

[:echo_pubsub, :buffer, :expired]: node was told it missed missed messages.

flush(group, buffer_size, buffer_capacity)

@spec flush(atom(), non_neg_integer(), pos_integer()) :: :ok

[:echo_pubsub, :buffer, :flush]: unacked messages vs. buffer capacity.

maybe_warn_capacity(group, buffer_size, buffer_capacity, threshold, interval, last_at)

@spec maybe_warn_capacity(
  atom(),
  non_neg_integer(),
  non_neg_integer(),
  number(),
  non_neg_integer(),
  integer() | nil
) :: integer() | nil

Logs and emits [:echo_pubsub, :buffer, :capacity_warning] when the fill ratio reaches threshold and interval seconds passed since last_at. Returns the new last_at.

retry_scheduled(group)

@spec retry_scheduled(atom()) :: :ok

[:echo_pubsub, :retry, :scheduled]: a retry flush was scheduled.

sync_failure(group, node, batch_size)

@spec sync_failure(atom(), node(), pos_integer()) :: :ok

[:echo_pubsub, :sync, :failure]: a batch of batch_size to node failed.