Documentation
¶
Index ¶
- Constants
- Variables
- func AddEncodingFlags(req *http.Request, flags EncodingFlags)
- func AddEncodingFlagsToContext(ctx context.Context, flags EncodingFlags) context.Context
- func ExtractActorPath(ctx context.Context) []string
- func ExtractHeader(ctx context.Context, name string) string
- func ExtractQueryMetricsMiddleware() middleware.Interface
- func ExtractQueryTagsFromContext(ctx context.Context) string
- func ExtractQueryTagsFromHTTP(req *http.Request) string
- func ExtractQueryTagsMiddleware() middleware.Interface
- func InjectActorPath(ctx context.Context, value string) context.Context
- func InjectHeader(ctx context.Context, key, value string) context.Context
- func InjectQueryTags(ctx context.Context, tags string) context.Context
- func IsLogsDrilldownRequest(ctx context.Context) bool
- func PropagateHeadersMiddleware(headers ...string) middleware.Interface
- func TagsToKeyValues(queryTags string) []interface{}
- type EncodingFlag
- type EncodingFlags
- func ExtractEncodingFlags(req *http.Request) EncodingFlags
- func ExtractEncodingFlagsFromCtx(ctx context.Context) EncodingFlags
- func ExtractEncodingFlagsFromProto(req *httpgrpc.HTTPRequest) EncodingFlags
- func NewEncodingFlags(flags ...EncodingFlag) EncodingFlags
- func ParseEncodingFlags(rawFlags string) EncodingFlags
Constants ¶
View Source
const ( LokiEncodingFlagsHeader = "X-Loki-Response-Encoding-Flags" FlagCategorizeLabels EncodingFlag = "categorize-labels" EncodeFlagsDelimiter = "," )
Variables ¶
View Source
var ( // LokiActorPathHeader is the name of the header e.g. used to enqueue requests in hierarchical queues. LokiActorPathHeader = "X-Loki-Actor-Path" LokiDisablePipelineWrappersHeader = "X-Loki-Disable-Pipeline-Wrappers" // LokiActorPathDelimiter is the delimiter used to serialise the hierarchy of the actor. LokiActorPathDelimiter = "|" )
View Source
var ( QueryTagsHTTPHeader ctxKey = "X-Query-Tags" QueryQueueTimeHTTPHeader ctxKey = "X-Query-Queue-Time" )
Functions ¶
func AddEncodingFlags ¶
func AddEncodingFlags(req *http.Request, flags EncodingFlags)
func AddEncodingFlagsToContext ¶
func AddEncodingFlagsToContext(ctx context.Context, flags EncodingFlags) context.Context
func ExtractActorPath ¶
func ExtractQueryMetricsMiddleware ¶
func ExtractQueryMetricsMiddleware() middleware.Interface
func ExtractQueryTagsFromContext ¶ added in v3.2.0
func ExtractQueryTagsMiddleware ¶
func ExtractQueryTagsMiddleware() middleware.Interface
func IsLogsDrilldownRequest ¶ added in v3.6.0
IsLogsDrilldownRequest checks if the request comes from Logs Drilldown by examining the X-Query-Tags header
func PropagateHeadersMiddleware ¶
func PropagateHeadersMiddleware(headers ...string) middleware.Interface
func TagsToKeyValues ¶ added in v3.5.0
func TagsToKeyValues(queryTags string) []interface{}
TagsToKeyValues converts QueryTags to form that is easy to log. e.g: `Source=foo,Feature=beta` -> []interface{}{"source", "foo", "feature", "beta"} so that we could log nicely! If queryTags is not in canonical form then its completely ignored (e.g: `key1=value1,key2=value`)
Types ¶
type EncodingFlag ¶
type EncodingFlag string
type EncodingFlags ¶
type EncodingFlags map[EncodingFlag]struct{}
func ExtractEncodingFlags ¶
func ExtractEncodingFlags(req *http.Request) EncodingFlags
func ExtractEncodingFlagsFromCtx ¶
func ExtractEncodingFlagsFromCtx(ctx context.Context) EncodingFlags
func ExtractEncodingFlagsFromProto ¶
func ExtractEncodingFlagsFromProto(req *httpgrpc.HTTPRequest) EncodingFlags
func NewEncodingFlags ¶
func NewEncodingFlags(flags ...EncodingFlag) EncodingFlags
func ParseEncodingFlags ¶
func ParseEncodingFlags(rawFlags string) EncodingFlags
func (*EncodingFlags) Has ¶
func (ef *EncodingFlags) Has(flag EncodingFlag) bool
func (*EncodingFlags) Set ¶
func (ef *EncodingFlags) Set(flags ...EncodingFlag)
func (*EncodingFlags) String ¶
func (ef *EncodingFlags) String() string
Source Files
Click to show internal directories.
Click to hide internal directories.