chunkinfologger

Documentation

Index

• Constants
• func ChunkInfoLoggingFromContext(ctx context.Context) []string
• func ContextWithChunkInfoLogging(ctx context.Context, labels []string) context.Context
• func IsChunkInfoLoggingEnabled(ctx context.Context) bool
• func Middleware() middleware.Interface
• type ChunkInfoLogger
  • func NewChunkInfoLogger(msg, traceID, spanID string, logger log.Logger, labels []string) *ChunkInfoLogger
  • func (c *ChunkInfoLogger) EndSeries(lastOne bool)
  • func (c *ChunkInfoLogger) FormatIngesterChunkInfo(sourceID string, chunks []client.Chunk)
  • func (c *ChunkInfoLogger) FormatStoreGatewayChunkInfo(sourceID string, chunks []storepb.AggrChunk)
  • func (c *ChunkInfoLogger) LogSelect(msg string, minT, maxT int64)
  • func (c *ChunkInfoLogger) SetMsg(msg string)
  • func (c *ChunkInfoLogger) StartSeries(ls labels.Labels)

Constants

const ChunkInfoLoggingHeader = "X-Mimir-Chunk-Info-Logger"

Functions

func ChunkInfoLoggingFromContext

func ChunkInfoLoggingFromContext(ctx context.Context) []string

func ContextWithChunkInfoLogging

func ContextWithChunkInfoLogging(ctx context.Context, labels []string) context.Context

func IsChunkInfoLoggingEnabled

func IsChunkInfoLoggingEnabled(ctx context.Context) bool

func Middleware

func Middleware() middleware.Interface

Types

type ChunkInfoLogger

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

func NewChunkInfoLogger

func NewChunkInfoLogger(msg, traceID, spanID string, logger log.Logger, labels []string) *ChunkInfoLogger

func (*ChunkInfoLogger) EndSeries

func (c *ChunkInfoLogger) EndSeries(lastOne bool)

Close a series in the chunk info and dump into log if it exceeds the max size.

func (*ChunkInfoLogger) FormatIngesterChunkInfo

func (c *ChunkInfoLogger) FormatIngesterChunkInfo(sourceID string, chunks []client.Chunk)

Format the chunk info from ingesters

func (*ChunkInfoLogger) FormatStoreGatewayChunkInfo

func (c *ChunkInfoLogger) FormatStoreGatewayChunkInfo(sourceID string, chunks []storepb.AggrChunk)

func (*ChunkInfoLogger) LogSelect

func (c *ChunkInfoLogger) LogSelect(msg string, minT, maxT int64)

func (*ChunkInfoLogger) SetMsg

func (c *ChunkInfoLogger) SetMsg(msg string)

func (*ChunkInfoLogger) StartSeries

func (c *ChunkInfoLogger) StartSeries(ls labels.Labels)