Versions in this module Expand all Collapse all v1 v1.0.2 Jul 26, 2019 Changes in this version + var ErrStreamMissing = errors.New("Stream missing") + type ChunkStore interface + Put func(ctx context.Context, chunks []chunk.Chunk) error + type Config struct + BlockSize int + ConcurrentFlushes int + FlushCheckPeriod time.Duration + FlushOpTimeout time.Duration + LifecyclerConfig ring.LifecyclerConfig + MaxChunkIdle time.Duration + RetainPeriod time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Ingester struct + func New(cfg Config, store ChunkStore) (*Ingester, error) + func (*Ingester) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error) + func (*Ingester) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error + func (i *Ingester) Flush() + func (i *Ingester) FlushHandler(w http.ResponseWriter, _ *http.Request) + func (i *Ingester) Label(ctx context.Context, req *logproto.LabelRequest) (*logproto.LabelResponse, error) + func (i *Ingester) Push(ctx context.Context, req *logproto.PushRequest) (*logproto.PushResponse, error) + func (i *Ingester) Query(req *logproto.QueryRequest, queryServer logproto.Querier_QueryServer) error + func (i *Ingester) ReadinessHandler(w http.ResponseWriter, r *http.Request) + func (i *Ingester) Shutdown() + func (i *Ingester) StopIncomingRequests() + func (i *Ingester) Stopping() + func (i *Ingester) Tail(req *logproto.TailRequest, queryServer logproto.Querier_TailServer) error + func (i *Ingester) TransferOut(context.Context) error