chstorage

package
v0.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 4, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package chstorage provides Clickhouse-based storage.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Inserter 

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

Inserter implements tracestorage.Inserter using Clickhouse.

func NewInserter 

func NewInserter(c *chpool.Pool, opts InserterOptions) (*Inserter, error)

NewInserter creates new Inserter.

func (*Inserter) InsertSpans 

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

InsertSpans inserts given spans.

func (*Inserter) InsertTags 

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

InsertTags insert given set of tags to the storage.

type InserterOptions added in v0.0.8 

type InserterOptions struct {
	// Tables provides table paths to query.
	Tables Tables
	// MeterProvider provides OpenTelemetry meter for this querier.
	MeterProvider metric.MeterProvider
	// TracerProvider provides OpenTelemetry tracer for this querier.
	TracerProvider trace.TracerProvider
}

InserterOptions is Inserter's options.

type Querier 

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

Querier implements tracestorage.Querier using Clickhouse.

func NewQuerier 

func NewQuerier(c *chpool.Pool, opts QuerierOptions) (*Querier, error)

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], rerr error)

SearchTags performs search by given tags.

func (*Querier) SelectSpansets added in v0.0.8 

func (q *Querier) SelectSpansets(ctx context.Context, params traceqlengine.SelectSpansetsParams) (_ iterators.Iterator[traceqlengine.Trace], rerr error)

SelectSpansets get spansets from storage.

func (*Querier) TagNames 

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

TagNames returns all available tag names.

func (*Querier) TagValues 

func (q *Querier) TagValues(ctx context.Context, tagName string) (_ iterators.Iterator[tracestorage.Tag], rerr 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], rerr error)

TraceByID returns spans of given trace.

type QuerierOptions added in v0.0.8 

type QuerierOptions struct {
	// Tables provides table paths to query.
	Tables Tables
	// MeterProvider provides OpenTelemetry meter for this querier.
	MeterProvider metric.MeterProvider
	// TracerProvider provides OpenTelemetry tracer for this querier.
	TracerProvider trace.TracerProvider
}

QuerierOptions is Querier's options.

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.