esspanreader

Documentation

Index

• type Config
• type Reader
  • func NewEsSpanReader(client esclient.ElasticsearchClient, logger *zap.Logger, config Config) *Reader
  • func (r *Reader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (r *Reader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (r *Reader) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (r *Reader) GetServices(ctx context.Context) ([]string, error)
  • func (r *Reader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

Types

type Config

type Config struct {
	Archive             bool
	UseReadWriteAliases bool
	IndexPrefix         string
	IndexDateLayout     string
	MaxSpanAge          time.Duration
	MaxDocCount         int
	TagDotReplacement   string
}

Config defines configuration for span reader.

type Reader

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

Reader defines Elasticsearch reader.

func NewEsSpanReader

func NewEsSpanReader(client esclient.ElasticsearchClient, logger *zap.Logger, config Config) *Reader

NewEsSpanReader creates Elasticseach span reader.

func (*Reader) FindTraceIDs

func (r *Reader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)

FindTraceIDs implements spanstore.Reader

func (*Reader) FindTraces

func (r *Reader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces implements spanstore.Reader

func (*Reader) GetOperations

func (r *Reader) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

GetOperations implements spanstore.Reader

func (*Reader) GetServices

func (r *Reader) GetServices(ctx context.Context) ([]string, error)

GetServices implements spanstore.Reader

func (*Reader) GetTrace

func (r *Reader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

GetTrace implements spanstore.Reader