translator

Documentation

Index

• Constants
• func DurationFromMicroseconds(micros int64) time.Duration
• func FieldsFromJSONString(jStr string) []jaegerpb.KeyValue
• func GenSpanBatcherBucketID(process *jaegerpb.Process) (bid [32]byte, err error)
• func GetLocalEndpointInfo(sfxSpan *trace.Span, span *jaegerpb.Span)
• func HTTPStatusCodeFromOCStatus(code int32) int32
• func OCStatusCodeFromHTTP(code int32) int32
• func SAPMSpanFromSFXSpan(sfxSpan *trace.Span, sm *spanfilter.Map) (span *jaegerpb.Span)
• func SFXTagsToJaegerTags(tags map[string]string, remoteEndpoint *trace.Endpoint, kind *string) ([]jaegerpb.KeyValue, []jaegerpb.KeyValue)
• func SFXToSAPMPostRequest(spans []*trace.Span) (*gen.PostSpansRequest, *spanfilter.Map)
• func TimeFromMicrosecondsSinceEpoch(micros int64) time.Time
• type SpanBatcher
  • func (b *SpanBatcher) Add(span *jaegerpb.Span)
  • func (b *SpanBatcher) Batches() []*jaegerpb.Batch

Constants

const (
	OCOK                 = 0
	OCCancelled          = 1
	OCUnknown            = 2
	OCInvalidArgument    = 3
	OCDeadlineExceeded   = 4
	OCNotFound           = 5
	OCAlreadyExists      = 6
	OCPermissionDenied   = 7
	OCResourceExhausted  = 8
	OCFailedPrecondition = 9
	OCAborted            = 10
	OCOutOfRange         = 11
	OCUnimplemented      = 12
	OCInternal           = 13
	OCUnavailable        = 14
	OCDataLoss           = 15
	OCUnauthenticated    = 16
)

https://github.com/googleapis/googleapis/blob/bee79fbe03254a35db125dc6d2f1e9b752b390fe/google/rpc/code.proto#L33-L186

Functions

func DurationFromMicroseconds

func DurationFromMicroseconds(micros int64) time.Duration

DurationFromMicroseconds returns the number of microseconds as a duration

func FieldsFromJSONString

func FieldsFromJSONString(jStr string) []jaegerpb.KeyValue

FieldsFromJSONString returns an array of jaeger KeyValues from a json string

func GenSpanBatcherBucketID

func GenSpanBatcherBucketID(process *jaegerpb.Process) (bid [32]byte, err error)

GenSpanBatcherBucketID generates a SpanBatcher bucket id from a jaeger process

func GetLocalEndpointInfo

func GetLocalEndpointInfo(sfxSpan *trace.Span, span *jaegerpb.Span)

GetLocalEndpointInfo sets the jaeger span's local endpoint extracted from the SignalFx span

func HTTPStatusCodeFromOCStatus

func HTTPStatusCodeFromOCStatus(code int32) int32

HTTPStatusCodeFromOCStatus takes an OpenTelemetry status code and return the appropriate HTTP status code See: https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/data-http.md

func OCStatusCodeFromHTTP

func OCStatusCodeFromHTTP(code int32) int32

OCStatusCodeFromHTTP takes an HTTP status code and return the appropriate OpenTelemetry status code See: https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/data-http.md

func SAPMSpanFromSFXSpan

func SAPMSpanFromSFXSpan(sfxSpan *trace.Span, sm *spanfilter.Map) (span *jaegerpb.Span)

SAPMSpanFromSFXSpan converts an individual SignalFx format span to a SAPM span. Can return nil if input span is invalid in some way.

func SFXTagsToJaegerTags

func SFXTagsToJaegerTags(tags map[string]string, remoteEndpoint *trace.Endpoint, kind *string) ([]jaegerpb.KeyValue, []jaegerpb.KeyValue)

SFXTagsToJaegerTags returns process tags and span tags from the SignalFx span tags, endpoint (remote), and kind

func SFXToSAPMPostRequest

func SFXToSAPMPostRequest(spans []*trace.Span) (*gen.PostSpansRequest, *spanfilter.Map)

SFXToSAPMPostRequest takes a slice spans in the SignalFx format and converts it to a SAPM PostSpansRequest

func TimeFromMicrosecondsSinceEpoch

func TimeFromMicrosecondsSinceEpoch(micros int64) time.Time

TimeFromMicrosecondsSinceEpoch returns the number of microseconds since the epoch as a time.Time

Types

type SpanBatcher

type SpanBatcher struct {
	// Buckets are a map of jaeger batches with a key generated from the jaeger process
	Buckets map[[32]byte]*jaegerpb.Batch
}

SpanBatcher is simpler version of OpenTelemetry's Node Batcher. SpanBatcher takes spans and groups them into Jaeger Batches using the Span Process objects.

func (*SpanBatcher) Add

func (b *SpanBatcher) Add(span *jaegerpb.Span)

Add jaeger spans to the batcher

func (*SpanBatcher) Batches

func (b *SpanBatcher) Batches() []*jaegerpb.Batch

Batches returns an array of jaeger batches