gotools/internal/event/export/ocagent/ocagent.go

type Config …

var connectMu …

var exporters …

// Discover finds the local agent to export to, it will return nil if there
// is not one running.
// TODO: Actually implement a discovery protocol rather than a hard coded address
func Discover() *Config { … }

type Exporter …

// Connect creates a process specific exporter with the specified
// serviceName and the address of the ocagent to which it will upload
// its telemetry.
func Connect(config *Config) *Exporter { … }

func (e *Exporter) ProcessEvent(ctx context.Context, ev core.Event, lm label.Map) context.Context { … }

func (e *Exporter) Flush() { … }

func (cfg *Config) buildNode() *wire.Node { … }

func (e *Exporter) send(endpoint string, message interface{ … }

func errorInExport(message string, args ...interface{ … }

func convertTimestamp(t time.Time) wire.Timestamp { … }

func toTruncatableString(s string) *wire.TruncatableString { … }

func convertSpan(span *export.Span) *wire.Span { … }

func convertMetric(data metric.Data, start time.Time) *wire.Metric { … }

func skipToValidLabel(list label.List, index int) (int, label.Label) { … }

func convertAttributes(list label.List, index int) *wire.Attributes { … }

func convertAttribute(l label.Label) wire.Attribute { … }

func convertEvents(events []core.Event) *wire.TimeEvents { … }

func convertEvent(ev core.Event) wire.TimeEvent { … }

func getAnnotationDescription(ev core.Event) (string, int) { … }

func convertAnnotation(ev core.Event) *wire.Annotation { … }