chstorage

Documentation

Overview

Package chstorage provides Clickhouse-based storage.

Index

• type Inserter
  • func NewInserter(c *chpool.Pool, tables Tables) *Inserter
  • func (i *Inserter) InsertSpans(ctx context.Context, spans []tracestorage.Span) error
  • func (i *Inserter) InsertTags(ctx context.Context, tags map[tracestorage.Tag]struct{}) error
• type Querier
  • func NewQuerier(c *chpool.Pool, tables Tables) *Querier
  • func (q *Querier) SearchTags(ctx context.Context, tags map[string]string, ...) (iterators.Iterator[tracestorage.Span], error)
  • func (q *Querier) TagNames(ctx context.Context) (r []string, _ error)
  • func (q *Querier) TagValues(ctx context.Context, tagName string) (iterators.Iterator[tracestorage.Tag], error)
  • func (q *Querier) TraceByID(ctx context.Context, id otelstorage.TraceID, ...) (iterators.Iterator[tracestorage.Span], error)
• type Tables
  • func (t Tables) Create(ctx context.Context, c chClient) error

Types

type Inserter

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

Inserter implements tracestorage.Inserter using Clickhouse.

func NewInserter

func NewInserter(c *chpool.Pool, tables Tables) *Inserter

NewInserter creates new Inserter.

func (*Inserter) InsertSpans

func (i *Inserter) InsertSpans(ctx context.Context, spans []tracestorage.Span) error

InsertSpans inserts given spans.

func (*Inserter) InsertTags

func (i *Inserter) InsertTags(ctx context.Context, tags map[tracestorage.Tag]struct{}) error

InsertTags insert given set of tags to the storage.

type Querier

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

Querier implements tracestorage.Querier using Clickhouse.

func NewQuerier

func NewQuerier(c *chpool.Pool, tables Tables) *Querier

NewQuerier creates new Querier.

func (*Querier) SearchTags

func (q *Querier) SearchTags(ctx context.Context, tags map[string]string, opts tracestorage.SearchTagsOptions) (iterators.Iterator[tracestorage.Span], error)

SearchTags performs search by given tags.

func (*Querier) TagNames

func (q *Querier) TagNames(ctx context.Context) (r []string, _ error)

TagNames returns all available tag names.

func (*Querier) TagValues

func (q *Querier) TagValues(ctx context.Context, tagName string) (iterators.Iterator[tracestorage.Tag], error)

TagValues returns all available tag values for given tag.

func (*Querier) TraceByID

func (q *Querier) TraceByID(ctx context.Context, id otelstorage.TraceID, opts tracestorage.TraceByIDOptions) (iterators.Iterator[tracestorage.Span], error)

TraceByID returns spans of given trace.

type Tables

type Tables struct {
	Spans string
	Tags  string
}

Tables define table names.

func (Tables) Create

func (t Tables) Create(ctx context.Context, c chClient) error

Create creates tables.