dbmodel

package
v0.0.0-...-03a88a3 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AppendSpanLogsFromInfluxQLResponse 

func AppendSpanLogsFromInfluxQLResponse(response *client.Response, traces []*model.Trace) error

AppendSpanLogsFromInfluxQLResponse appends traces in an InfluxQL response to a slice of traces

func AppendSpanLogsFromInfluxQLRow 

func AppendSpanLogsFromInfluxQLRow(row *models.Row, m map[model.TraceID]map[model.SpanID]*model.Span) error

AppendSpanLogsFromInfluxQLRow appends span logs in an InfluxQL result row to a map of traces/spans

func DependencyLinksFromResultV1 

func DependencyLinksFromResultV1(response *client.Response) ([]model.DependencyLink, error)

DependencyLinksFromResultV1 converts an InfluxDB response to a dependency graph

func DependencyLinksFromResultV2 

func DependencyLinksFromResultV2(resultIterator flux.ResultIterator) ([]model.DependencyLink, error)

DependencyLinksFromResultV2 converts an InfluxDB result to a dependency graph

func SpanFromFluxColReader 

func SpanFromFluxColReader(reader flux.ColReader, rowI int) (*model.Span, error)

SpanFromFluxColReader converts a flux Reader row to a Jaeger span.

func SpanToPointsV1 

func SpanToPointsV1(span *model.Span, spanMeasurement, logMeasurement string, logger hclog.Logger) ([]models.Point, error)

SpanToPointsV1 converts a Jaeger span to InfluxDB v1.x points. One point for the span itself, and one point for each log entry on the span.

func SpanToPointsV2 

func SpanToPointsV2(span *model.Span, spanMeasurement, logMeasurement string, logger hclog.Logger) ([]models.Point, error)

SpanToPointsV2 converts a Jaeger span to InfluxDB v2.x points. One point for the span itself, and one point for each log entry on the span.

func TraceFromInfluxQLRow 

func TraceFromInfluxQLRow(row *models.Row) (*model.Trace, error)

TraceFromInfluxQLRow converts an InfluxQL result row to Jaeger traces.

func TraceIDsFromFluxResult 

func TraceIDsFromFluxResult(resultIterator flux.ResultIterator) ([]model.TraceID, error)

TraceIDsFromFluxResult converts an InfluxDB result to a slice of TraceIDs

func TraceIDsFromInfluxQLResult 

func TraceIDsFromInfluxQLResult(response *client.Response) ([]model.TraceID, error)

TraceIDsFromInfluxQLResult converts an InfluxDB result to a slice of TraceIDs

func TracesFromFluxResult 

func TracesFromFluxResult(resultIterator flux.ResultIterator, spanMeasurement, logMeasurement string, logger hclog.Logger) ([]*model.Trace, error)

TracesFromFluxResult converts a flux Result to Jaeger traces.

func TracesFromInfluxQLResponse 

func TracesFromInfluxQLResponse(response *client.Response) ([]*model.Trace, error)

TracesFromInfluxQLResponse converts an InfluxQL response to Jaeger traces.

Types

type FluxTraceQuery 

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

FluxTraceQuery is a flux query builder that generates trace queries in Flux.

func FluxTraceQueryFromTQP 

func FluxTraceQueryFromTQP(bucket, spanMeasurement, logMeasurement string, query *spanstore.TraceQueryParameters) *FluxTraceQuery

FluxTraceQueryFromTQP constructs a FluxTraceQuery using parameters in a spanstore.TraceQueryParameters

func NewFluxTraceQuery 

func NewFluxTraceQuery(bucket, spanMeasurement, logMeasurement string, startTimeMin time.Time) *FluxTraceQuery

NewFluxTraceQuery constructs a new FluxTraceQuery object.

func (*FluxTraceQuery) BuildTraceIDQuery 

func (q *FluxTraceQuery) BuildTraceIDQuery() string

BuildTraceIDQuery builds a flux query that returns Trace IDs.

func (*FluxTraceQuery) BuildTraceQuery 

func (q *FluxTraceQuery) BuildTraceQuery(traceIDs []model.TraceID) string

BuildTraceQuery builds a flux query that returns whole traces.

func (*FluxTraceQuery) DurationMax 

func (q *FluxTraceQuery) DurationMax(durationMax time.Duration) *FluxTraceQuery

DurationMax sets the query max duration threshold.

func (*FluxTraceQuery) DurationMin 

func (q *FluxTraceQuery) DurationMin(durationMin time.Duration) *FluxTraceQuery

DurationMin sets the query min duration threshold.

func (*FluxTraceQuery) NumTraces 

func (q *FluxTraceQuery) NumTraces(numTraces int) *FluxTraceQuery

NumTraces sets the query max traces threshold.

func (*FluxTraceQuery) OperationName 

func (q *FluxTraceQuery) OperationName(operationName string) *FluxTraceQuery

OperationName sets the query operation name.

func (*FluxTraceQuery) ServiceName 

func (q *FluxTraceQuery) ServiceName(serviceName string) *FluxTraceQuery

ServiceName sets the query service name.

func (*FluxTraceQuery) StartTimeMax 

func (q *FluxTraceQuery) StartTimeMax(startTimeMax time.Time) *FluxTraceQuery

StartTimeMax sets the max start time to query.

func (*FluxTraceQuery) Tag 

func (q *FluxTraceQuery) Tag(k, v string) *FluxTraceQuery

Tag adds a query tag key:value pair.

type InfluxQLLogQuery 

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

InfluxQLLogQuery abstracts an InfluxQL query for span logs

func NewInfluxQLLogQuery 

func NewInfluxQLLogQuery(measurement string) *InfluxQLLogQuery

NewInfluxQLLogQuery constructs a new InfluxQLLogQuery

func (*InfluxQLLogQuery) BuildLogQuery 

func (q *InfluxQLLogQuery) BuildLogQuery(traceIDs []model.TraceID) string

BuildLogQuery builds a InfluxQL query

type InfluxQLTraceQuery 

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

InfluxQLTraceQuery abstracts an InfluxQL query for spans

func InfluxQLTraceQueryFromTQP 

func InfluxQLTraceQueryFromTQP(measurement string, query *spanstore.TraceQueryParameters) *InfluxQLTraceQuery

InfluxQLTraceQueryFromTQP constructs an InfluxQLTraceQuery using parameters in a spanstore.TraceQueryParameters

func NewInfluxQLTraceQuery 

func NewInfluxQLTraceQuery(measurement string) *InfluxQLTraceQuery

NewInfluxQLTraceQuery constructs a new InfluxQLTraceQuery

func (*InfluxQLTraceQuery) BuildTraceIDQuery 

func (q *InfluxQLTraceQuery) BuildTraceIDQuery() string

BuildTraceIDQuery builds an InfluxQL query that returns Trace IDs.

func (*InfluxQLTraceQuery) BuildTraceQuery 

func (q *InfluxQLTraceQuery) BuildTraceQuery(traceIDs []model.TraceID) string

BuildTraceQuery builds a flux query that returns whole traces.

func (*InfluxQLTraceQuery) DurationMax 

func (q *InfluxQLTraceQuery) DurationMax(durationMax time.Duration) *InfluxQLTraceQuery

DurationMax sets the query max duration threshold.

func (*InfluxQLTraceQuery) DurationMin 

func (q *InfluxQLTraceQuery) DurationMin(durationMin time.Duration) *InfluxQLTraceQuery

DurationMin sets the query min duration threshold.

func (*InfluxQLTraceQuery) NumTraces 

func (q *InfluxQLTraceQuery) NumTraces(numTraces int) *InfluxQLTraceQuery

NumTraces sets the query max traces threshold.

func (*InfluxQLTraceQuery) OperationName 

func (q *InfluxQLTraceQuery) OperationName(operationName string) *InfluxQLTraceQuery

OperationName sets the query operation name.

func (*InfluxQLTraceQuery) ServiceName 

func (q *InfluxQLTraceQuery) ServiceName(serviceName string) *InfluxQLTraceQuery

ServiceName sets the query service name.

func (*InfluxQLTraceQuery) StartTimeMax 

func (q *InfluxQLTraceQuery) StartTimeMax(startTimeMax time.Time) *InfluxQLTraceQuery

StartTimeMax sets the max start time to query.

func (*InfluxQLTraceQuery) StartTimeMin 

func (q *InfluxQLTraceQuery) StartTimeMin(startTimeMin time.Time) *InfluxQLTraceQuery

StartTimeMin sets the min start time to query.

func (*InfluxQLTraceQuery) Tag 

func (q *InfluxQLTraceQuery) Tag(k, v string) *InfluxQLTraceQuery

Tag adds a query tag key:value pair.

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.