Versions in this module Expand all Collapse all v3 v3.0.0 Apr 8, 2024 Changes in this version + func NewPool(name string, cfg PoolConfig, ring ring.ReadRing, ...) *ring_client.Pool + type ClosableHealthAndIngesterClient struct + type Config struct + GRCPStreamClientInterceptors []grpc.StreamClientInterceptor + GRPCClientConfig grpcclient.Config + GRPCUnaryClientInterceptors []grpc.UnaryClientInterceptor + Internal bool + PoolConfig PoolConfig + RemoteTimeout time.Duration + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type HealthAndIngesterClient interface + Close func() error + func NewClient(cfg Config, addr string) (HealthAndIngesterClient, error) + type PoolConfig struct + ClientCleanupPeriod time.Duration + HealthCheckIngesters bool + RemoteTimeout time.Duration + func (cfg *PoolConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)