class Obsctl::Server::BestEffortLogBroadcast

Overview

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.

#broadcast(entry : JSON::Any) : Bool
Offers a diagnostic log-topic entry for asynchronous delivery.
#capacity : Int32
#dropped_count : UInt64
Number of diagnostic entries dropped because the helper was at capacity.
#outstanding : Int32
Number of diagnostic deliveries currently accepted but not finished.

def self.new(broadcast : Proc(JSON::Any, Nil), capacity : Int32 = DEFAULT_CAPACITY) #

[View source]

def 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.

[View source]

def capacity : Int32 #

[View source]

def dropped_count : UInt64 #

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

[View source]

def outstanding : Int32 #

Number of diagnostic deliveries currently accepted but not finished.

[View source]