Versions in this module Expand all Collapse all v0 v0.6.1 Jun 12, 2023 Changes in this version + func IngesterPoolFactoryFn(options ...connect.ClientOption) ring_client.PoolFactory + func NeStoreGatewayPool(ring ring.ReadRing, factory ring_client.PoolFactory, ...) *ring_client.Pool + func NewIngesterPool(cfg PoolConfig, ring ring.ReadRing, factory ring_client.PoolFactory, ...) *ring_client.Pool + func StoreGatewayPoolFactoryFn(options ...connect.ClientOption) ring_client.PoolFactory + type BidiClientMergeProfilesLabels interface + CloseRequest func() error + CloseResponse func() error + Receive func() (*ingestv1.MergeProfilesLabelsResponse, error) + Send func(*ingestv1.MergeProfilesLabelsRequest) error + type BidiClientMergeProfilesPprof interface + CloseRequest func() error + CloseResponse func() error + Receive func() (*ingestv1.MergeProfilesPprofResponse, error) + Send func(*ingestv1.MergeProfilesPprofRequest) error + type BidiClientMergeProfilesStacktraces interface + CloseRequest func() error + CloseResponse func() error + Receive func() (*ingestv1.MergeProfilesStacktracesResponse, error) + Send func(*ingestv1.MergeProfilesStacktracesRequest) error + type PoolConfig struct + ClientCleanupPeriod time.Duration + HealthCheckIngesters bool + RemoteTimeout time.Duration + func (cfg *PoolConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)
Go to main page