Versions in this module Expand all Collapse all v1 v1.0.2 Jul 26, 2019 Changes in this version + func ReadBatch(i iter.EntryIterator, size uint32) (*logproto.QueryResponse, uint32, error) + type Config struct + QueryTimeout time.Duration + TailMaxDuration time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Querier struct + func New(cfg Config, clientCfg client.Config, ring ring.ReadRing, store storage.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) Tail(ctx context.Context, req *logproto.TailRequest) (*Tailer, error) + func (q *Querier) TailHandler(w http.ResponseWriter, r *http.Request) + type TailResponse struct + DroppedEntries []droppedEntry + Streams []logproto.Stream + type Tailer struct
Go to main page