s3spanstore

Documentation

Index

• type KinesisAPI
• type Reader
  • func NewReader(logger hclog.Logger, svc *athena.Client, cfg config.Athena) (*Reader, error)
  • func (s *Reader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (s *Reader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (s *Reader) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (s *Reader) GetServices(ctx context.Context) ([]string, error)
  • func (s *Reader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
• type SpanRecord
  • func NewSpanRecordFromSpan(span *model.Span) (*SpanRecord, error)
• type Writer
  • func NewWriter(logger hclog.Logger, svc KinesisAPI, firehoseConfig config.Kinesis) (*Writer, error)
  • func (s *Writer) WriteSpan(ctx context.Context, span *model.Span) error

Types

type KinesisAPI

type KinesisAPI interface {
	PutRecord(ctx context.Context, params *firehose.PutRecordInput, optFns ...func(*firehose.Options)) (*firehose.PutRecordOutput, error)
}

type Reader

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

func NewReader

func NewReader(logger hclog.Logger, svc *athena.Client, cfg config.Athena) (*Reader, error)

func (*Reader) FindTraceIDs

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

This method is not used

func (*Reader) FindTraces

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

func (*Reader) GetOperations

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

func (*Reader) GetServices

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

func (*Reader) GetTrace

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

type SpanRecord

type SpanRecord struct {
	TraceID       string            `json:"traceid"`       // 1
	SpanID        string            `json:"spanid"`        // 2
	OperationName string            `json:"operationname"` // 3
	SpanKind      string            `json:"spankind"`      // 4
	StartTime     int64             `json:"starttime"`     // 5
	Duration      int64             `json:"duration"`      // 6
	Tags          map[string]string `json:"tags"`          // 7
	ServiceName   string            `json:"servicename"`   // 8
	SpanPayload   string            `json:"spanpayload"`   // 9
}

SpanRecord contains queryable properties from the span and the span as json payload

func NewSpanRecordFromSpan

func NewSpanRecordFromSpan(span *model.Span) (*SpanRecord, error)

type Writer

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

func NewWriter

func NewWriter(logger hclog.Logger, svc KinesisAPI, firehoseConfig config.Kinesis) (*Writer, error)

func (*Writer) WriteSpan

func (s *Writer) WriteSpan(ctx context.Context, span *model.Span) error