class

Obsctl::Server::BestEffortLogBroadcast

Bounded best-effort fanout for secondary diagnostic log-topic delivery.

Runtime logging is intentionally outside this helper. Callers should write durable diagnostics before offering entries here.

Constants

DEFAULT_CAPACITY = 4

new(broadcast : Proc(JSON::Any, Nil), capacity : Int32 = DEFAULT_CAPACITY)

broadcast(entry : JSON::Any) : Bool

Offers a diagnostic log-topic entry for asynchronous delivery.

Returns false without spawning work when the outstanding delivery bound has already been reached.

capacity

dropped_count

Number of diagnostic entries dropped because the helper was at capacity.

outstanding

Number of diagnostic deliveries currently accepted but not finished.