store

Documentation

Index

• Variables
• type Config
  • func NewConfig(v *viper.Viper) (*Config, error)
• type Store
  • func New(store clickhousestore.ClickhouseStore, tracer trace.Tracer) *Store
  • func (s *Store) Close() error
  • func (s *Store) DependencyReader() dependencystore.Reader
  • 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) GetDependencies(ctx context.Context, endTime time.Time, lookback time.Duration) ([]model.DependencyLink, 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, traceID model.TraceID) (*model.Trace, error)
  • func (s *Store) SpanReader() spanstore.Reader
  • func (s *Store) SpanWriter() spanstore.Writer
  • func (s *Store) StreamingSpanWriter() spanstore.Writer
  • func (s *Store) WriteSpan(ctx context.Context, span *model.Span) error

Variables

var (
	ErrStartTimeRequired = errors.New("start time is required for search queries")
)

Types

type Config

type Config struct {
	DBHost                  string `yaml:"db_host"`
	DBPort                  int    `yaml:"db_port"`
	DBUser                  string `yaml:"db_user"`
	DBPass                  string `yaml:"db_pass"`
	DBName                  string `yaml:"db_name"`
	DBTable                 string `yaml:"db_table"`
	DBCaFile                string `yaml:"db_ca_file"`
	DBTlsEnabled            bool   `yaml:"db_tls_enabled"`
	DBTlsInsecure           bool   `yaml:"db_tls_insecure"`
	DBMaxOpenConns          uint   `yaml:"db_max_open_conns"`
	DBMaxIdleConns          uint   `yaml:"db_max_idle_conns"`
	DBConnMaxLifetimeMillis uint   `yaml:"db_conn_max_lifetime_millis"`
	DBConnMaxIdleTimeMillis uint   `yaml:"db_conn_max_idle_time_millis"`
	PadTraceID              bool   `yaml:"pad_trace_id"`
	EnableTracing           bool   `yaml:"enable_tracing"`
}

func NewConfig

func NewConfig(v *viper.Viper) (*Config, error)

type Store

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

func New

func New(store clickhousestore.ClickhouseStore, tracer trace.Tracer) *Store

func (*Store) Close

func (s *Store) Close() error

func (*Store) DependencyReader

func (s *Store) DependencyReader() dependencystore.Reader

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

func (s *Store) GetDependencies(ctx context.Context, endTime time.Time, lookback time.Duration) ([]model.DependencyLink, 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, traceID model.TraceID) (*model.Trace, error)

func (*Store) SpanReader

func (s *Store) SpanReader() spanstore.Reader

func (*Store) SpanWriter

func (s *Store) SpanWriter() spanstore.Writer

func (*Store) StreamingSpanWriter

func (s *Store) StreamingSpanWriter() spanstore.Writer

func (*Store) WriteSpan

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