Versions in this module Expand all Collapse all v1 v1.6.2 Jan 17, 2024 Changes in this version + var ErrReadOnly = errors.New("Ingester is shutting down") + var ErrStreamMissing = errors.New("Stream missing") + type ChunkStore interface + GetChunkRefs func(ctx context.Context, userID string, from, through model.Time, ...) ([][]chunk.Chunk, []*chunk.Fetcher, error) + GetSchemaConfigs func() []chunk.PeriodConfig + Put func(ctx context.Context, chunks []chunk.Chunk) error + SelectLogs func(ctx context.Context, req logql.SelectLogParams) (iter.EntryIterator, error) + SelectSamples func(ctx context.Context, req logql.SelectSampleParams) (iter.SampleIterator, error) + type Config struct + BlockSize int + ChunkEncoding string + ConcurrentFlushes int + FlushCheckPeriod time.Duration + FlushOpTimeout time.Duration + LifecyclerConfig ring.LifecyclerConfig + MaxChunkAge time.Duration + MaxChunkIdle time.Duration + MaxReturnedErrors int + MaxTransferRetries int + QueryStore bool + QueryStoreMaxLookBackPeriod time.Duration + RetainPeriod time.Duration + SyncMinUtilization float64 + SyncPeriod time.Duration + TargetChunkSize int + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Ingester struct + func New(cfg Config, clientConfig client.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) CheckReady(ctx context.Context) error + func (i *Ingester) Flush() + func (i *Ingester) FlushHandler(w http.ResponseWriter, _ *http.Request) + func (i *Ingester) GetChunkIDs(ctx context.Context, req *logproto.GetChunkIDsRequest) (*logproto.GetChunkIDsResponse, error) + 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) QuerySample(req *logproto.SampleQueryRequest, ...) error + func (i *Ingester) Series(ctx context.Context, req *logproto.SeriesRequest) (*logproto.SeriesResponse, error) + func (i *Ingester) Tail(req *logproto.TailRequest, queryServer logproto.Querier_TailServer) error + func (i *Ingester) TailersCount(ctx context.Context, in *logproto.TailersCountRequest) (*logproto.TailersCountResponse, error) + func (i *Ingester) TransferChunks(stream logproto.Ingester_TransferChunksServer) error + func (i *Ingester) TransferOut(ctx context.Context) error + type Limiter struct + func NewLimiter(limits *validation.Overrides, ring RingCount, replicationFactor int) *Limiter + func (l *Limiter) AssertMaxStreamsPerUser(userID string, streams int) error + type RingCount interface + HealthyInstancesCount func() int
Go to main page