spanstore

Jan 21, 2019

Changes in this version

type SpanReader

+ func (s *SpanReader) FindTraceIDs(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]model.TraceID, error)

type SpanReaderParams

+ MaxNumSpans int

Nov 13, 2018

Changes in this version

type SpanReaderParams

+ MaxSpanAge time.Duration

Sep 19, 2018

Changes in this version

+ type SpanReaderParams struct

+ Client es.Client

+ IndexPrefix string

+ Logger *zap.Logger

+ MaxLookback time.Duration

+ MetricsFactory metrics.Factory

+ TagDotReplacement string

+ type SpanWriterParams struct

+ AllTagsAsFields bool

+ Client es.Client

+ IndexPrefix string

+ Logger *zap.Logger

+ MetricsFactory metrics.Factory

+ NumReplicas int64

+ NumShards int64

+ TagDotReplacement string

+ TagKeysAsFields []string

Feb 7, 2018

Changes in this version

type SpanWriter

+ func (s *SpanWriter) Close() error

Dec 6, 2017

Changes in this version

+ type Span struct

+ StartTimeMillis uint64

Jul 20, 2017

Changes in this version

+ func IndexWithDate(date time.Time) string

+ type ServiceOperationStorage struct

+ func NewServiceOperationStorage(ctx context.Context, client es.Client, metricsFactory metrics.Factory, ...) *ServiceOperationStorage

+ func (s *ServiceOperationStorage) Write(indexName string, jsonSpan *jModel.Span) error

Jul 1, 2017

Changes in this version

+ var ErrDurationMinGreaterThanMax = errors.New("Duration Minimum is above Maximum")

+ var ErrMalformedRequestObject = errors.New("Malformed request object")

+ var ErrServiceNameNotSet = errors.New("Service Name must be set")

+ var ErrStartAndEndTimeNotSet = errors.New("Start and End Time must be set")

+ var ErrStartTimeMinGreaterThanMax = errors.New("Start Time Minimum is above Maximum")

+ var ErrUnableToFindTraceIDAggregation = errors.New("Could not find aggregation of traceIDs")

+ type Service struct

+ OperationName string

+ ServiceName string

+ type SpanReader struct

+ func NewSpanReader(client es.Client, logger *zap.Logger) *SpanReader

+ func (s *SpanReader) FindTraces(traceQuery *spanstore.TraceQueryParameters) ([]*model.Trace, error)

+ func (s *SpanReader) GetOperations(service string) ([]string, error)

+ func (s *SpanReader) GetServices() ([]string, error)

+ func (s *SpanReader) GetTrace(traceID model.TraceID) (*model.Trace, error)

+ type SpanWriter struct

+ func NewSpanWriter(client es.Client, logger *zap.Logger) *SpanWriter

+ func (s *SpanWriter) WriteSpan(span *model.Span) error