Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + const Day + type AddressProvider interface + Addresses func() []string + type BloomQuerier struct + func NewQuerier(c Client, r prometheus.Registerer, logger log.Logger) *BloomQuerier + func (bq *BloomQuerier) FilterChunkRefs(ctx context.Context, tenant string, from, through model.Time, ...) ([]*logproto.ChunkRef, error) + type CacheConfig struct + func (cfg *CacheConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *CacheConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + type CacheLimits interface + BloomGatewayCacheKeyInterval func(tenantID string) time.Duration + type Client interface + FilterChunks func(ctx context.Context, tenant string, from, through model.Time, ...) ([]*logproto.GroupedChunkRefs, error) + type ClientCache struct + func NewBloomGatewayClientCacheMiddleware(logger log.Logger, next logproto.BloomGatewayClient, c cache.Cache, ...) *ClientCache + func (c *ClientCache) FilterChunkRefs(ctx context.Context, req *logproto.FilterChunkRefRequest, ...) (*logproto.FilterChunkRefResponse, error) + type ClientConfig struct + Addresses string + Cache CacheConfig + CacheResults bool + GRPCClientConfig grpcclient.Config + PoolConfig PoolConfig + func (i *ClientConfig) RegisterFlags(f *flag.FlagSet) + func (i *ClientConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (i *ClientConfig) Validate() error + type Config struct + BlockQueryConcurrency int + Client ClientConfig + Enabled bool + MaxOutstandingPerTenant int + NumMultiplexItems int + WorkerConcurrency int + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (cfg *Config) Validate() error + type GRPCPool struct + func NewBloomGatewayGRPCPool(address string, opts []grpc.DialOption) (*GRPCPool, error) + type Gateway struct + func New(cfg Config, store bloomshipper.Store, logger log.Logger, ...) (*Gateway, error) + func (g *Gateway) FilterChunkRefs(ctx context.Context, req *logproto.FilterChunkRefRequest) (*logproto.FilterChunkRefResponse, error) + type GatewayClient struct + func NewClient(cfg ClientConfig, limits Limits, registerer prometheus.Registerer, ...) (*GatewayClient, error) + func (c *GatewayClient) Close() + func (c *GatewayClient) FilterChunks(ctx context.Context, tenant string, from, through model.Time, ...) ([]*logproto.GroupedChunkRefs, error) + type JumpHashClientPool struct + func NewJumpHashClientPool(pool *client.Pool, dnsProvider AddressProvider, updateInterval time.Duration, ...) *JumpHashClientPool + func (p *JumpHashClientPool) AddrForFingerprint(fp uint64) (string, error) + func (p *JumpHashClientPool) Start() + func (p *JumpHashClientPool) Stop() + type Limits interface + BloomGatewayEnabled func(tenantID string) bool + BloomGatewayShardSize func(tenantID string) int + type PoolConfig struct + CheckInterval time.Duration + HealthCheckEnabled bool + HealthCheckTimeout time.Duration + MaxConcurrentHealthChecks int + func (cfg *PoolConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + func (cfg *PoolConfig) Validate() error + type Stats struct + BlocksFetchTime *atomic.Duration + ChunksFiltered int + ChunksRequested int + MetasFetchTime *atomic.Duration + NumFilters int + NumTasks int + PostProcessingTime *atomic.Duration + ProcessedBlocks *atomic.Int32 + ProcessingTime *atomic.Duration + QueueTime *atomic.Duration + SeriesFiltered int + SeriesRequested int + Status string + TotalProcessingTime *atomic.Duration + func ContextWithEmptyStats(ctx context.Context) (*Stats, context.Context) + func FromContext(ctx context.Context) *Stats + func (s *Stats) AddBlocksFetchTime(t time.Duration) + func (s *Stats) AddMetasFetchTime(t time.Duration) + func (s *Stats) AddPostProcessingTime(t time.Duration) + func (s *Stats) AddProcessingTime(t time.Duration) + func (s *Stats) AddQueueTime(t time.Duration) + func (s *Stats) AddTotalProcessingTime(t time.Duration) + func (s *Stats) Duration() (dur time.Duration) + func (s *Stats) IncProcessedBlocks() + func (s *Stats) KVArgs() []any + type Task struct + ID ulid.ULID + Tenant string + func NewTask(ctx context.Context, tenantID string, refs seriesWithInterval, ...) (Task, error) + func (t Task) Bounds() (model.Time, model.Time) + func (t Task) Close() + func (t Task) CloseWithError(err error) + func (t Task) Copy(series []*logproto.GroupedChunkRefs) Task + func (t Task) Done() <-chan struct{} + func (t Task) Err() error + func (t Task) RequestIter(tokenizer *v1.NGramTokenizer) v1.Iterator[v1.Request]