querier

Documentation

Index

• func ReadBatch(i iter.EntryIterator, size uint32) (*logproto.QueryResponse, uint32, error)
• type Config
  • func (cfg *Config) RegisterFlags(f *flag.FlagSet)
• type Querier
  • func New(cfg Config, clientCfg client.Config, ring ring.ReadRing, store chunk.Store) (*Querier, error)
  • func (*Querier) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (q *Querier) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error)
  • func (q *Querier) LabelHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) Query(ctx context.Context, req *logproto.QueryRequest) (*logproto.QueryResponse, error)
  • func (q *Querier) QueryHandler(w http.ResponseWriter, r *http.Request)
  • func (q *Querier) TailHandler(w http.ResponseWriter, r *http.Request)
• type TailResponse

Functions

func ReadBatch

func ReadBatch(i iter.EntryIterator, size uint32) (*logproto.QueryResponse, uint32, error)

ReadBatch reads a set of entries off an iterator.

Types

type Config

type Config struct {
}

Config for a querier.

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags register flags.

type Querier

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

Querier handlers queries.

func New

func New(cfg Config, clientCfg client.Config, ring ring.ReadRing, store chunk.Store) (*Querier, error)

New makes a new Querier.

func (*Querier) Check

func (*Querier) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

Check implements the grpc healthcheck

func (*Querier) Label

func (q *Querier) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error)

Label does the heavy lifting for a Label query.

func (*Querier) LabelHandler

func (q *Querier) LabelHandler(w http.ResponseWriter, r *http.Request)

LabelHandler is a http.HandlerFunc for handling label queries.

func (*Querier) Query

func (q *Querier) Query(ctx context.Context, req *logproto.QueryRequest) (*logproto.QueryResponse, error)

Query does the heavy lifting for an actual query.

func (*Querier) QueryHandler

func (q *Querier) QueryHandler(w http.ResponseWriter, r *http.Request)

QueryHandler is a http.HandlerFunc for queries.

func (*Querier) TailHandler

func (q *Querier) TailHandler(w http.ResponseWriter, r *http.Request)

TailHandler is a http.HandlerFunc for handling tail queries.

type TailResponse

type TailResponse struct {
	Streams []*logproto.Stream `json:"streams"`
}

TailResponse represents response for tail query