spanstore

Documentation

Index

• Constants
• type Config
  • func (c *Config) SetDefaults()
• type Operation
• type Span
• type Store
  • func New(logger hclog.Logger, rc *rockset.RockClient, config Config) (*Store, error)
  • func (s Store) Close() error
  • func (s Store) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (s Store) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (s Store) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (s Store) GetServices(ctx context.Context) ([]string, error)
  • func (s Store) GetTrace(ctx context.Context, tid model.TraceID) (*model.Trace, error)
  • func (s Store) Setup() error
  • func (s Store) WriteSpan(_ context.Context, span *model.Span) error

Constants

const (
	DefaultWorkspace  = "tracing"
	DefaultSpans      = "spans"
	DefaultOperations = "operations"
	DefaultRetention  = 7 * 24 * 60 * 60 // 7 days
	DefaultWorkers    = 3
)

Types

type Config

type Config struct {
	Workspace     string `yaml:"workspace"`
	Spans         string `yaml:"spans"`
	Operations    string `yaml:"operations"`
	Workers       uint64 `yaml:"workers"`
	Create        bool   `yaml:"create"`
	RetentionSecs int64  `yaml:"retention_secs"`
}

func (*Config) SetDefaults

func (c *Config) SetDefaults()

type Operation

type Operation struct {
	ID        string `json:"_id"`
	Service   string `json:"service"`
	Operation string `json:"operation"`
	Kind      string `json:"span_kind"`
}

type Span

type Span struct {
	model.Span
	KV map[string]string `json:"kv"`
}

type Store

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

func New

func New(logger hclog.Logger, rc *rockset.RockClient, config Config) (*Store, error)

func (Store) Close

func (s Store) Close() error

func (Store) FindTraceIDs

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

func (Store) FindTraces

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

func (Store) GetOperations

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

func (Store) GetServices

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

func (Store) GetTrace

func (s Store) GetTrace(ctx context.Context, tid model.TraceID) (*model.Trace, error)

func (Store) Setup

func (s Store) Setup() error

func (Store) WriteSpan

func (s Store) WriteSpan(_ context.Context, span *model.Span) error