tracedb

Documentation

Index

• Constants
• Variables
• type CauseType
• type FactoryFunc
  • func Factory(tg traceGetter) FactoryFunc
• type FlattenOptions
• type HttpTempoTraceByIDResponse
• type OTLPTraceDB
  • func (tdb *OTLPTraceDB) Close() error
  • func (tdb *OTLPTraceDB) Connect(ctx context.Context) error
  • func (tdb *OTLPTraceDB) GetEndpoints() string
  • func (tdb *OTLPTraceDB) GetTraceByID(ctx context.Context, id string) (traces.Trace, error)
  • func (db *OTLPTraceDB) GetTraceID() trace.TraceID
  • func (tdb *OTLPTraceDB) Ready() bool
  • func (db *OTLPTraceDB) ShouldRetry() bool
• type TestableTraceDB
• type TraceDB
  • func NewAwsXRayDB(cfg *datastore.AWSXRayConfig) (TraceDB, error)
  • func NewAzureAppInsightsDB(config *datastore.AzureAppInsightsConfig) (TraceDB, error)

Constants

const (
	AWSOperationAttribute = "aws.operation"
	AWSAccountAttribute   = "aws.account_id"
	AWSRegionAttribute    = "aws.region"
	AWSRequestIDAttribute = "aws.request_id"
	// Currently different instrumentation uses different tag formats.
	// TODO(anuraaga): Find current instrumentation and consolidate.
	AWSRequestIDAttribute2 = "aws.requestId"
	AWSQueueURLAttribute   = "aws.queue_url"
	AWSQueueURLAttribute2  = "aws.queue.url"
	AWSServiceAttribute    = "aws.service"
	AWSTableNameAttribute  = "aws.table_name"
	AWSTableNameAttribute2 = "aws.table.name"

	// AWSXRayInProgressAttribute is the `in_progress` flag in an X-Ray segment
	AWSXRayInProgressAttribute = "aws.xray.inprogress"

	// AWSXRayXForwardedForAttribute is the `x_forwarded_for` flag in an X-Ray segment
	AWSXRayXForwardedForAttribute = "aws.xray.x_forwarded_for"

	// AWSXRayResourceARNAttribute is the `resource_arn` field in an X-Ray segment
	AWSXRayResourceARNAttribute = "aws.xray.resource_arn"

	// AWSXRayTracedAttribute is the `traced` field in an X-Ray subsegment
	AWSXRayTracedAttribute = "aws.xray.traced"

	// AWSXraySegmentAnnotationsAttribute is the attribute that
	// will be treated by the X-Ray exporter as the annotation keys.
	AWSXraySegmentAnnotationsAttribute = "aws.xray.annotations"

	// AWSXraySegmentMetadataAttributePrefix is the prefix of the attribute that
	// will be treated by the X-Ray exporter as metadata. The key of a metadata
	// will be AWSXraySegmentMetadataAttributePrefix + <metadata_key>.
	AWSXraySegmentMetadataAttributePrefix = "aws.xray.metadata."

	// AWSXrayRetriesAttribute is the `retries` field in an X-Ray (sub)segment.
	AWSXrayRetriesAttribute = "aws.xray.retries"

	// AWSXrayExceptionIDAttribute is the `id` field in an exception
	AWSXrayExceptionIDAttribute = "aws.xray.exception.id"
	// AWSXrayExceptionRemoteAttribute is the `remote` field in an exception
	AWSXrayExceptionRemoteAttribute = "aws.xray.exception.remote"
	// AWSXrayExceptionTruncatedAttribute is the `truncated` field in an exception
	AWSXrayExceptionTruncatedAttribute = "aws.xray.exception.truncated"
	// AWSXrayExceptionSkippedAttribute is the `skipped` field in an exception
	AWSXrayExceptionSkippedAttribute = "aws.xray.exception.skipped"
	// AWSXrayExceptionCauseAttribute is the `cause` field in an exception
	AWSXrayExceptionCauseAttribute = "aws.xray.exception.cause"
)

const (
	// TypeStr is the type and ingest format of this receiver
	TypeStr = "awsxray"
)

Variables

var IDGen = id.NewRandGenerator()

Types

type CauseType

type CauseType int

const (
	CauseTypeExceptionID CauseType = iota + 1
	CauseTypeObject
)

type FactoryFunc

type FactoryFunc func(ds datastore.DataStore) (TraceDB, error)

func Factory

func Factory(tg traceGetter) FactoryFunc

type FlattenOptions

type FlattenOptions struct {
	Prefix    string
	Delimiter string
	Safe      bool
	MaxDepth  int
}

type HttpTempoTraceByIDResponse

type HttpTempoTraceByIDResponse struct {
	Batches []*traces.HttpResourceSpans `json:"batches"`
}

type OTLPTraceDB

type OTLPTraceDB struct {
	// contains filtered or unexported fields
}

func (*OTLPTraceDB) Close

func (tdb *OTLPTraceDB) Close() error

func (*OTLPTraceDB) Connect

func (tdb *OTLPTraceDB) Connect(ctx context.Context) error

func (*OTLPTraceDB) GetEndpoints

func (tdb *OTLPTraceDB) GetEndpoints() string

func (*OTLPTraceDB) GetTraceByID

func (tdb *OTLPTraceDB) GetTraceByID(ctx context.Context, id string) (traces.Trace, error)

GetTraceByID implements TraceDB

func (*OTLPTraceDB) GetTraceID

func (db *OTLPTraceDB) GetTraceID() trace.TraceID

func (*OTLPTraceDB) Ready

func (tdb *OTLPTraceDB) Ready() bool

func (*OTLPTraceDB) ShouldRetry

func (db *OTLPTraceDB) ShouldRetry() bool

type TestableTraceDB

type TestableTraceDB interface {
	TraceDB
	TestConnection(ctx context.Context) model.ConnectionResult
}

type TraceDB

type TraceDB interface {
	Connect(ctx context.Context) error
	Ready() bool
	ShouldRetry() bool
	GetTraceID() trace.TraceID
	GetTraceByID(ctx context.Context, traceID string) (traces.Trace, error)
	Close() error
	GetEndpoints() string
}

func NewAwsXRayDB

func NewAwsXRayDB(cfg *datastore.AWSXRayConfig) (TraceDB, error)

func NewAzureAppInsightsDB

func NewAzureAppInsightsDB(config *datastore.AzureAppInsightsConfig) (TraceDB, error)