infinite_tracing

package
v0.0.0-...-4f470da Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 29, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	Host              string
	Port              uint16
	Secure            bool
	License           string
	RunId             string
	QueueSize         uint64
	RequestHeadersMap map[string]string
}

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.

func (*TraceObserver) Shutdown 

func (to *TraceObserver) Shutdown(timeout time.Duration) error

Shut down the trace observer connection. This blocks until the shutdown is complete or until the timeout is hit.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.