Documentation
¶
Overview ¶
Package ytstorage provides YTSaurus-based storage.
Index ¶
- type Inserter
- func (i *Inserter) InsertLogLabels(ctx context.Context, labels map[logstorage.Label]struct{}) (rerr error)
- func (i *Inserter) InsertRecords(ctx context.Context, records []logstorage.Record) (rerr error)
- func (i *Inserter) InsertSpans(ctx context.Context, spans []tracestorage.Span) (rerr error)
- func (i *Inserter) InsertTags(ctx context.Context, tags map[tracestorage.Tag]struct{}) (rerr error)
- type InserterOptions
- type Tables
- type YQLQuerier
- type YQLQuerierOptions
- type YTQLQuerier
- func (q *YTQLQuerier) LabelNames(ctx context.Context, opts logstorage.LabelsOptions) (_ []string, rerr error)
- func (q *YTQLQuerier) LabelValues(ctx context.Context, labelName string, opts logstorage.LabelsOptions) (_ iterators.Iterator[logstorage.Label], rerr error)
- func (q *YTQLQuerier) SearchTags(ctx context.Context, tags map[string]string, ...) (_ iterators.Iterator[tracestorage.Span], rerr error)
- func (q *YTQLQuerier) SelectLogs(ctx context.Context, start, end otelstorage.Timestamp, ...) (_ iterators.Iterator[logstorage.Record], rerr error)
- func (q *YTQLQuerier) SelectSpansets(ctx context.Context, params traceqlengine.SelectSpansetsParams) (_ iterators.Iterator[traceqlengine.Trace], rerr error)
- func (q *YTQLQuerier) TagNames(ctx context.Context) (_ []string, rerr error)
- func (q *YTQLQuerier) TagValues(ctx context.Context, tagName string) (_ iterators.Iterator[tracestorage.Tag], rerr error)
- func (q *YTQLQuerier) TraceByID(ctx context.Context, id otelstorage.TraceID, ...) (_ iterators.Iterator[tracestorage.Span], rerr error)
- func (q *YTQLQuerier) Сapabilities() (caps logqlengine.QuerierСapabilities)
- type YTQLQuerierOptions
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 based on YTSaurus.
func NewInserter ¶
func NewInserter(yc yt.Client, opts InserterOptions) (*Inserter, error)
NewInserter creates new Inserter.
func (*Inserter) InsertLogLabels ¶
func (i *Inserter) InsertLogLabels(ctx context.Context, labels map[logstorage.Label]struct{}) (rerr error)
InsertLogLabels insert given set of labels to the storage.
func (*Inserter) InsertRecords ¶
InsertRecords inserts given Records.
func (*Inserter) InsertSpans ¶
InsertSpans inserts given spans.
func (*Inserter) InsertTags ¶
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 Tables ¶
type Tables struct {
// contains filtered or unexported fields
}
Tables define table paths.
func NewStaticTables ¶ added in v0.0.8
NewStaticTables creates new Tables with given path prefix.
type YQLQuerier ¶ added in v0.0.8
type YQLQuerier struct {
// contains filtered or unexported fields
}
YQLQuerier implements Querier based on YQL.
func NewYQLQuerier ¶ added in v0.0.8
func NewYQLQuerier(client *yqlclient.Client, opts YQLQuerierOptions) (*YQLQuerier, error)
NewYQLQuerier creates new YQLQuerier.
func (*YQLQuerier) SelectLogs ¶ added in v0.0.8
func (q *YQLQuerier) SelectLogs(ctx context.Context, start, end otelstorage.Timestamp, params logqlengine.SelectLogsParams) (_ iterators.Iterator[logstorage.Record], rerr error)
SelectLogs makes a query for LogQL engine.
func (*YQLQuerier) Сapabilities ¶ added in v0.0.8
func (q *YQLQuerier) Сapabilities() (caps logqlengine.QuerierСapabilities)
Сapabilities defines storage capabilities.
type YQLQuerierOptions ¶ added in v0.0.8
type YQLQuerierOptions struct {
// Tables provides table paths to query.
Tables Tables
// ClusterName sets cluster name to use.
ClusterName string
// MeterProvider provides OpenTelemetry meter for this querier.
MeterProvider metric.MeterProvider
// TracerProvider provides OpenTelemetry tracer for this querier.
TracerProvider trace.TracerProvider
}
YQLQuerierOptions is YTQLQuerier's options.
type YTQLQuerier ¶
type YTQLQuerier struct {
// contains filtered or unexported fields
}
YTQLQuerier implements tracestorage.Querier based on YTSaurus QL.
func NewYTQLQuerier ¶
func NewYTQLQuerier(yc yt.TabletClient, opts YTQLQuerierOptions) (*YTQLQuerier, error)
NewYTQLQuerier creates new YTQLQuerier.
func (*YTQLQuerier) LabelNames ¶
func (q *YTQLQuerier) LabelNames(ctx context.Context, opts logstorage.LabelsOptions) (_ []string, rerr error)
LabelNames returns all available label names.
func (*YTQLQuerier) LabelValues ¶
func (q *YTQLQuerier) LabelValues(ctx context.Context, labelName string, opts logstorage.LabelsOptions) (_ iterators.Iterator[logstorage.Label], rerr error)
LabelValues returns all available label values for given label.
func (*YTQLQuerier) SearchTags ¶
func (q *YTQLQuerier) SearchTags(ctx context.Context, tags map[string]string, opts tracestorage.SearchTagsOptions) (_ iterators.Iterator[tracestorage.Span], rerr error)
SearchTags performs search by given tags.
func (*YTQLQuerier) SelectLogs ¶
func (q *YTQLQuerier) SelectLogs(ctx context.Context, start, end otelstorage.Timestamp, params logqlengine.SelectLogsParams) (_ iterators.Iterator[logstorage.Record], rerr error)
SelectLogs makes a query for LogQL engine.
func (*YTQLQuerier) SelectSpansets ¶ added in v0.0.8
func (q *YTQLQuerier) SelectSpansets(ctx context.Context, params traceqlengine.SelectSpansetsParams) (_ iterators.Iterator[traceqlengine.Trace], rerr error)
SelectSpansets get spansets from storage.
func (*YTQLQuerier) TagNames ¶
func (q *YTQLQuerier) TagNames(ctx context.Context) (_ []string, rerr error)
TagNames returns all available tag names.
func (*YTQLQuerier) TagValues ¶
func (q *YTQLQuerier) TagValues(ctx context.Context, tagName string) (_ iterators.Iterator[tracestorage.Tag], rerr error)
TagValues returns all available tag values for given tag.
func (*YTQLQuerier) TraceByID ¶
func (q *YTQLQuerier) TraceByID(ctx context.Context, id otelstorage.TraceID, opts tracestorage.TraceByIDOptions) (_ iterators.Iterator[tracestorage.Span], rerr error)
TraceByID returns spans of given trace.
func (*YTQLQuerier) Сapabilities ¶
func (q *YTQLQuerier) Сapabilities() (caps logqlengine.QuerierСapabilities)
Сapabilities defines storage capabilities.
type YTQLQuerierOptions ¶ added in v0.0.8
type YTQLQuerierOptions 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
}
YTQLQuerierOptions is YTQLQuerier's options.
Source Files
Click to show internal directories.
Click to hide internal directories.