querier

package

v1.0.2 Latest Latest Go to latest Published: Jul 26, 2019 License: Apache-2.0 Imports: 28 Imported by: 0

Details

This section is empty.

This section is empty.

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

ReadBatch reads a set of entries off an iterator.

type Config struct {
	TailMaxDuration time.Duration `yaml:"tail_max_duration"`
	QueryTimeout    time.Duration `yaml:"query_timeout"`
}

Config for a querier.

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

RegisterFlags register flags.

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

Querier handlers queries.

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

New makes a new Querier.

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

Check implements the grpc healthcheck

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

Label does the heavy lifting for a Label query.

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

LabelHandler is a http.HandlerFunc for handling label queries.

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

Query does the heavy lifting for an actual query.

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

QueryHandler is a http.HandlerFunc for queries.

func (q *Querier) Tail(ctx context.Context, req *logproto.TailRequest) (*Tailer, error)

Tail keeps getting matching logs from all ingesters for given query

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

TailHandler is a http.HandlerFunc for handling tail queries.

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

TailResponse holds response sent by tailer

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

Tailer manages complete lifecycle of a tail request