bloomgateway

type AddressProvider interface {
	Addresses() []string
}

type BlockResolver interface {
	Resolve(ctx context.Context, tenant string, interval bloomshipper.Interval, series []*logproto.GroupedChunkRefs) (blocks []blockWithSeries, skipped []*logproto.GroupedChunkRefs, err error)
}

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

type Client interface {
	FilterChunks(ctx context.Context, tenant string, interval bloomshipper.Interval, blocks []blockWithSeries, plan plan.QueryPlan) ([]*logproto.GroupedChunkRefs, error)
	PrefetchBloomBlocks(ctx context.Context, blocks []bloomshipper.BlockRef) error
}

type ClientConfig struct {
	// PoolConfig defines the behavior of the gRPC connection pool used to communicate
	// with the Bloom Gateway.
	PoolConfig PoolConfig `yaml:"pool_config,omitempty" doc:"description=Configures the behavior of the connection pool."`

	// GRPCClientConfig configures the gRPC connection between the Bloom Gateway client and the server.
	GRPCClientConfig grpcclient.Config `yaml:"grpc_client_config"`

	// Client sharding using DNS disvovery and jumphash
	Addresses string `yaml:"addresses,omitempty"`
}

type ClientFactory func(addr string) (client.PoolClient, error)

type Config struct {
	// Enabled is the global switch to configures whether Bloom Gateways should be used to filter chunks.
	Enabled bool `yaml:"enabled"`
	// Client configures the Bloom Gateway client
	Client ClientConfig `yaml:"client,omitempty" doc:""`

	WorkerConcurrency       int  `yaml:"worker_concurrency"`
	BlockQueryConcurrency   int  `yaml:"block_query_concurrency"`
	MaxOutstandingPerTenant int  `yaml:"max_outstanding_per_tenant"`
	NumMultiplexItems       int  `yaml:"num_multiplex_tasks"`
	FetchBlocksAsync        bool `yaml:"fetch_blocks_async" doc:"hidden"`
}

type GRPCPool struct {
	grpc_health_v1.HealthClient
	logproto.BloomGatewayClient
	io.Closer
}

type Gateway struct {
	services.Service
	// contains filtered or unexported fields
}

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

type JumpHashClientPool struct {
	services.Service
	*jumphash.Selector
	sync.RWMutex
	// contains filtered or unexported fields
}

type Limits interface {
	BloomGatewayEnabled(tenantID string) bool
}

type PoolConfig struct {
	CheckInterval time.Duration `yaml:"check_interval"`
}

type QuerierConfig struct {
	BuildInterval    time.Duration
	BuildTableOffset int
}

type Stats struct {
	Status                              string
	NumTasks, NumMatchers               int
	ChunksRequested, ChunksFiltered     int
	SeriesRequested, SeriesFiltered     int
	QueueTime                           *atomic.Duration
	BlocksFetchTime                     *atomic.Duration
	ProcessingTime, TotalProcessingTime *atomic.Duration
	PostProcessingTime                  *atomic.Duration
	SkippedBlocks                       *atomic.Int32 // blocks skipped because they were not available (yet)
	ProcessedBlocks                     *atomic.Int32 // blocks processed for this specific request
	ProcessedBlocksTotal                *atomic.Int32 // blocks processed for multiplexed request
}

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