mirror of
https://github.com/open-telemetry/opentelemetry-go.git
synced 2025-03-25 21:28:58 +02:00
9f03360a84
* Add golint to linters and resolve issues. I decided to remove constructors for some of the propagation types because the constructors can be reduced to either using the zero value or a single, non optional member. * Enable gofmt and commit fixes
116 lines
2.3 KiB
Go
116 lines
2.3 KiB
Go
package exporter
|
|
|
|
import (
|
|
"context"
|
|
"sync/atomic"
|
|
"time"
|
|
|
|
"google.golang.org/grpc/codes"
|
|
|
|
"go.opentelemetry.io/api/core"
|
|
"go.opentelemetry.io/api/distributedcontext"
|
|
"go.opentelemetry.io/api/metric"
|
|
)
|
|
|
|
type EventType int
|
|
|
|
type EventID uint64
|
|
|
|
type ScopeID struct {
|
|
EventID
|
|
core.SpanContext
|
|
}
|
|
|
|
type Event struct {
|
|
// Automatic fields
|
|
Sequence EventID // Auto-filled
|
|
Time time.Time // Auto-filled
|
|
|
|
// Type, Scope, Context
|
|
Type EventType // All events
|
|
Scope ScopeID // All events
|
|
Context context.Context // core.FromContext() and scope.Active()
|
|
|
|
// Arguments (type-specific)
|
|
Attribute core.KeyValue // SET_ATTRIBUTE
|
|
Attributes []core.KeyValue // SET_ATTRIBUTES
|
|
Mutator distributedcontext.Mutator // SET_ATTRIBUTE
|
|
Mutators []distributedcontext.Mutator // SET_ATTRIBUTES
|
|
Recovered interface{} // END_SPAN
|
|
Status codes.Code // SET_STATUS
|
|
|
|
// Values
|
|
String string // START_SPAN, EVENT, SET_NAME, ...
|
|
Parent ScopeID // START_SPAN
|
|
Measurement metric.Measurement
|
|
Measurements []metric.Measurement
|
|
}
|
|
|
|
type Observer interface {
|
|
Observe(data Event)
|
|
}
|
|
|
|
//go:generate stringer -type=EventType
|
|
// nolint:golint
|
|
const (
|
|
INVALID EventType = iota
|
|
START_SPAN
|
|
END_SPAN
|
|
ADD_EVENT
|
|
NEW_SCOPE
|
|
MODIFY_ATTR
|
|
SET_STATUS
|
|
SET_NAME
|
|
SINGLE_METRIC // A metric Set(), Add(), Record()
|
|
BATCH_METRIC // A RecordBatch()
|
|
)
|
|
|
|
type Exporter struct {
|
|
sequence uint64
|
|
observers []Observer
|
|
}
|
|
|
|
func NewExporter(observers ...Observer) *Exporter {
|
|
return &Exporter{
|
|
observers: observers,
|
|
}
|
|
}
|
|
|
|
func (e *Exporter) NextEventID() EventID {
|
|
return EventID(atomic.AddUint64(&e.sequence, 1))
|
|
}
|
|
|
|
func (e *Exporter) Record(event Event) EventID {
|
|
if event.Sequence == 0 {
|
|
event.Sequence = e.NextEventID()
|
|
}
|
|
if event.Time.IsZero() {
|
|
event.Time = time.Now()
|
|
}
|
|
for _, observer := range e.observers {
|
|
observer.Observe(event)
|
|
}
|
|
return event.Sequence
|
|
}
|
|
|
|
func (e *Exporter) Foreach(f func(Observer)) {
|
|
for _, observer := range e.observers {
|
|
f(observer)
|
|
}
|
|
}
|
|
|
|
func (e *Exporter) NewScope(parent ScopeID, attributes ...core.KeyValue) ScopeID {
|
|
if len(attributes) == 0 {
|
|
return parent
|
|
}
|
|
eventID := e.Record(Event{
|
|
Type: NEW_SCOPE,
|
|
Scope: parent,
|
|
Attributes: attributes,
|
|
})
|
|
return ScopeID{
|
|
EventID: eventID,
|
|
SpanContext: parent.SpanContext,
|
|
}
|
|
}
|