Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TraceObserver ¶
type TraceObserver struct { Config // contains filtered or unexported fields }
func NewTraceObserver ¶
func NewTraceObserver(cfg *Config) *TraceObserver
Initialize a connection to a trace observer. This function returns immediately, while trying to establish a connection in the background.
In case no connection can be established, span batches are dropped based on the backpressure handling.
func (*TraceObserver) DumpSupportabilityMetrics ¶
func (to *TraceObserver) DumpSupportabilityMetrics() map[string][6]float64
dumpSupportabilityMetrics reads the current supportability metrics off of the channel and resets them to 0.
func (*TraceObserver) QueueBatch ¶
func (to *TraceObserver) QueueBatch(count uint64, batch []byte)
Add a span batch to the queue.
This should only be called on a single go routine. Concurrent calls might case race conditions due to missing locking around the capacity counter.
Click to show internal directories.
Click to hide internal directories.