s3spanstore

Documentation

Index

• Constants
• Variables
• 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 SpanRecordReferences
  • func NewSpanRecordReferencesFromSpanReferences(span *model.Span) []*SpanRecordReferences
• type Writer
  • func NewWriter(logger hclog.Logger, svc KinesisAPI, firehoseConfig config.Kinesis) (*Writer, error)
  • func (w *Writer) Close() error
  • func (s *Writer) WriteSpan(ctx context.Context, span *model.Span) error

Constants

const (
	MAX_BATCH_BYTE_SIZE = 1024 * 1024 * 4
	MAX_BATCH_RECORDS   = 500
)

Variables

var (
	MIN_FLUSH_INTERVAL = 10 * time.Second
)

Types

type KinesisAPI

type KinesisAPI interface {
	PutRecordBatch(ctx context.Context, params *firehose.PutRecordBatchInput, optFns ...func(*firehose.Options)) (*firehose.PutRecordBatchOutput, 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
	References    []*SpanRecordReferences `json:"references"`    // 10
}

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

func NewSpanRecordFromSpan

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

type SpanRecordReferences

type SpanRecordReferences struct {
	TraceID string `json:"traceid"` // 1
	SpanID  string `json:"spanid"`  // 2
	RefType int64  `json:"reftype"` // 3
}

func NewSpanRecordReferencesFromSpanReferences

func NewSpanRecordReferencesFromSpanReferences(span *model.Span) []*SpanRecordReferences

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) Close

func (w *Writer) Close() error

func (*Writer) WriteSpan

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