traces

Documentation

Index

• Constants
• Variables
• func Matches(body string) ([]string, error)
• type BufferedSpans
  • func NewBufferedSpanStore(maxAllowedSpans int) (*BufferedSpans, error)
  • func (s *BufferedSpans) Count() (int, error)
  • func (s *BufferedSpans) Delete(ctx context.Context, id string) error
  • func (s *BufferedSpans) DeleteAll(ctx context.Context) error
  • func (s *BufferedSpans) Get(ctx context.Context, tracer opentracing.Tracer, id string) (*StoreEntry, error)
  • func (s *BufferedSpans) Monitor(ctx context.Context, interval time.Duration, name string)
  • func (s *BufferedSpans) Set(ctx context.Context, id string, entry StoreEntry) error
• type SpanMissingError
  • func (s SpanMissingError) Error() string
• type SpanMissingIDError
  • func (s SpanMissingIDError) Error() string
• type SpanStore
• type Spans
  • func NewMemoryUnboundedSpanStore() *Spans
  • func (s *Spans) Count() (int, error)
  • func (s *Spans) Delete(ctx context.Context, id string) error
  • func (s *Spans) Get(ctx context.Context, tracer opentracing.Tracer, id string) (*StoreEntry, error)
  • func (s *Spans) Set(ctx context.Context, id string, entry StoreEntry) error
• type StoreEntry
  • func NewStoreEntryFromSpan(span opentracing.Span) StoreEntry
  • func (se StoreEntry) Duration() time.Duration

Constants

const TracePrefix string = "vs"

Variables

var (
	BufferedSpansTotal = stats.Float64(
		"traces/stores/buffered_spans/total",
		"Gauge total number of current buffered spans",
		stats.UnitDimensionless,
	)
	BufferedSpansTotalView = &view.View{
		Name:        "traces/stores/buffered_spans/total",
		Description: "Gauge total number of current buffered spans",
		TagKeys:     []tag.Key{bufferName},
		Measure:     BufferedSpansTotal,
		Aggregation: view.LastValue(),
	}
	BufferedSpansPercentage = stats.Float64(
		"traces/stores/buffered_spans/percentage",
		"Gauge percentage full current buffer",
		stats.UnitDimensionless,
	)
	BufferedSpansPercentageView = &view.View{
		Name:        "traces/stores/buffered_spans/percentage",
		Description: "Gauge percentage full current buffer",
		TagKeys:     []tag.Key{bufferName},
		Measure:     BufferedSpansPercentage,
		Aggregation: view.LastValue(),
	}
)

Functions

func Matches

func Matches(body string) ([]string, error)

Types

type BufferedSpans

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

BufferedSpans only allows a fixed number of spans at any one time. If the max allowed has been reached it will reject new spans.

func NewBufferedSpanStore

func NewBufferedSpanStore(maxAllowedSpans int) (*BufferedSpans, error)

func (*BufferedSpans) Count

func (s *BufferedSpans) Count() (int, error)

func (*BufferedSpans) Delete

func (s *BufferedSpans) Delete(ctx context.Context, id string) error

Delete removes the id, if present, from the buffered spans collection.

func (*BufferedSpans) DeleteAll

func (s *BufferedSpans) DeleteAll(ctx context.Context) error

func (*BufferedSpans) Get

func (s *BufferedSpans) Get(ctx context.Context, tracer opentracing.Tracer, id string) (*StoreEntry, error)

func (*BufferedSpans) Monitor

func (s *BufferedSpans) Monitor(ctx context.Context, interval time.Duration, name string)

func (*BufferedSpans) Set

func (s *BufferedSpans) Set(ctx context.Context, id string, entry StoreEntry) error

Set checks to see if there is a free space in the map if there is then it inserts, if there is no free space it returns an error.

type SpanMissingError

type SpanMissingError struct {
	Err error
}

func (SpanMissingError) Error

func (s SpanMissingError) Error() string

type SpanMissingIDError

type SpanMissingIDError struct {
	Err error
}

func (SpanMissingIDError) Error

func (s SpanMissingIDError) Error() string

type SpanStore

type SpanStore interface {
	Get(ctx context.Context, tracer opentracing.Tracer, id string) (*StoreEntry, error)
	Set(ctx context.Context, id string, entry StoreEntry) error
	Delete(ctx context.Context, id string) error
	Count() (int, error)
}

type Spans

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

func NewMemoryUnboundedSpanStore

func NewMemoryUnboundedSpanStore() *Spans

func (*Spans) Count

func (s *Spans) Count() (int, error)

func (*Spans) Delete

func (s *Spans) Delete(ctx context.Context, id string) error

func (*Spans) Get

func (s *Spans) Get(ctx context.Context, tracer opentracing.Tracer, id string) (*StoreEntry, error)

func (*Spans) Set

func (s *Spans) Set(ctx context.Context, id string, entry StoreEntry) error

type StoreEntry

type StoreEntry struct {
	Span      opentracing.Span
	State     *eventsources.EventState
	CreatedAt time.Time
}

func NewStoreEntryFromSpan

func NewStoreEntryFromSpan(span opentracing.Span) StoreEntry

func (StoreEntry) Duration

func (se StoreEntry) Duration() time.Duration