spanlogger

package

v2.1.1 Latest Latest Go to latest Published: Jul 10, 2026 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/grafana/pyroscope

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type LazyJoin
- func (l *LazyJoin) String() string
type LogSpanParametersWrapper
- func NewLogSpanParametersWrapper(client querierv1connect.QuerierServiceClient, logger log.Logger) *LogSpanParametersWrapper
type QueryStats
- func ContextWithQueryStats(ctx context.Context) (context.Context, *QueryStats)
- func QueryStatsFromContext(ctx context.Context) *QueryStats
type SpanLogger
- func FromContext(ctx context.Context, fallback log.Logger) *SpanLogger
- func NewWithLogger(ctx context.Context, logger log.Logger, method string, kvps ...interface{}) (*SpanLogger, context.Context)

Constants ¶

View Source

const (
	// TenantIDsTagName is the tenant IDs tag name.
	TenantIDsTagName = spanlogger.TenantIDsTagName
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type LazyJoin ¶

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

func (*LazyJoin) String ¶

func (l *LazyJoin) String() string

type LogSpanParametersWrapper ¶

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

func NewLogSpanParametersWrapper ¶

func NewLogSpanParametersWrapper(client querierv1connect.QuerierServiceClient, logger log.Logger) *LogSpanParametersWrapper

func (LogSpanParametersWrapper) AnalyzeQuery ¶

func (l LogSpanParametersWrapper) AnalyzeQuery(ctx context.Context, c *connect.Request[querierv1.AnalyzeQueryRequest]) (*connect.Response[querierv1.AnalyzeQueryResponse], error)

func (LogSpanParametersWrapper) Diff ¶

func (l LogSpanParametersWrapper) Diff(ctx context.Context, c *connect.Request[querierv1.DiffRequest]) (*connect.Response[querierv1.DiffResponse], error)

func (LogSpanParametersWrapper) GetProfileStats ¶

func (l LogSpanParametersWrapper) GetProfileStats(ctx context.Context, c *connect.Request[typesv1.GetProfileStatsRequest]) (*connect.Response[typesv1.GetProfileStatsResponse], error)

func (LogSpanParametersWrapper) LabelNames ¶

func (l LogSpanParametersWrapper) LabelNames(ctx context.Context, c *connect.Request[typesv1.LabelNamesRequest]) (*connect.Response[typesv1.LabelNamesResponse], error)

func (LogSpanParametersWrapper) LabelValues ¶

func (l LogSpanParametersWrapper) LabelValues(ctx context.Context, c *connect.Request[typesv1.LabelValuesRequest]) (*connect.Response[typesv1.LabelValuesResponse], error)

func (LogSpanParametersWrapper) ProfileTypes ¶

func (l LogSpanParametersWrapper) ProfileTypes(ctx context.Context, c *connect.Request[querierv1.ProfileTypesRequest]) (*connect.Response[querierv1.ProfileTypesResponse], error)

func (LogSpanParametersWrapper) SelectHeatmap ¶

func (l LogSpanParametersWrapper) SelectHeatmap(ctx context.Context, c *connect.Request[querierv1.SelectHeatmapRequest]) (*connect.Response[querierv1.SelectHeatmapResponse], error)

func (LogSpanParametersWrapper) SelectMergeProfile ¶

func (l LogSpanParametersWrapper) SelectMergeProfile(ctx context.Context, c *connect.Request[querierv1.SelectMergeProfileRequest]) (*connect.Response[profilev1.Profile], error)

func (LogSpanParametersWrapper) SelectMergeSpanProfile ¶

func (l LogSpanParametersWrapper) SelectMergeSpanProfile(ctx context.Context, c *connect.Request[querierv1.SelectMergeSpanProfileRequest]) (*connect.Response[querierv1.SelectMergeSpanProfileResponse], error)

func (LogSpanParametersWrapper) SelectMergeStacktraces ¶

func (l LogSpanParametersWrapper) SelectMergeStacktraces(ctx context.Context, c *connect.Request[querierv1.SelectMergeStacktracesRequest]) (*connect.Response[querierv1.SelectMergeStacktracesResponse], error)

func (LogSpanParametersWrapper) SelectSeries ¶

func (l LogSpanParametersWrapper) SelectSeries(ctx context.Context, c *connect.Request[querierv1.SelectSeriesRequest]) (*connect.Response[querierv1.SelectSeriesResponse], error)

func (LogSpanParametersWrapper) Series ¶

func (l LogSpanParametersWrapper) Series(ctx context.Context, c *connect.Request[querierv1.SeriesRequest]) (*connect.Response[querierv1.SeriesResponse], error)

type QueryStats ¶ added in v2.1.0

type QueryStats struct {
	ObjectStorageBytes uint64
	MetastoreBytes     uint64
	// EstimatedBytes is the pre-execution metadata size estimate (weight.Total())
	// derived from block dataset section offsets before the backend is invoked.
	EstimatedBytes uint64
}

QueryStats is populated by the query-frontend during query execution and read by LogSpanParametersWrapper after the call returns, so that bytes fetched can be included in the query log line.

func ContextWithQueryStats ¶ added in v2.1.0

func ContextWithQueryStats(ctx context.Context) (context.Context, *QueryStats)

ContextWithQueryStats attaches a fresh QueryStats to ctx and returns both the enriched context and a pointer to the stats struct.

func QueryStatsFromContext ¶ added in v2.1.0

func QueryStatsFromContext(ctx context.Context) *QueryStats

QueryStatsFromContext returns the QueryStats stored in ctx, or nil if none.

type SpanLogger ¶

type SpanLogger = spanlogger.SpanLogger

SpanLogger unifies tracing and logging, to reduce repetition.

func FromContext ¶

func FromContext(ctx context.Context, fallback log.Logger) *SpanLogger

FromContext returns a SpanLogger using the current parent span. If there is no parent span, the SpanLogger will only log to the logger within the context. If the context doesn't have a logger, the fallback logger is used.

func NewWithLogger ¶

func NewWithLogger(ctx context.Context, logger log.Logger, method string, kvps ...interface{}) (*SpanLogger, context.Context)

NewWithLogger is like New but allows to pass a logger.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL