clientpool

Documentation

Index

• 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
• type BidiClientMergeProfilesPprof
• type BidiClientMergeProfilesStacktraces
• type PoolConfig
  • func (cfg *PoolConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

Functions

func IngesterPoolFactoryFn

func IngesterPoolFactoryFn(options ...connect.ClientOption) ring_client.PoolFactory

func NeStoreGatewayPool

func NeStoreGatewayPool(ring ring.ReadRing, factory ring_client.PoolFactory, clientsMetric prometheus.Gauge, logger log.Logger, options ...connect.ClientOption) *ring_client.Pool

func NewIngesterPool

func NewIngesterPool(cfg PoolConfig, ring ring.ReadRing, factory ring_client.PoolFactory, clientsMetric prometheus.Gauge, logger log.Logger, options ...connect.ClientOption) *ring_client.Pool

func StoreGatewayPoolFactoryFn

func StoreGatewayPoolFactoryFn(options ...connect.ClientOption) ring_client.PoolFactory

Types

type BidiClientMergeProfilesLabels

type BidiClientMergeProfilesLabels interface {
	Send(*ingestv1.MergeProfilesLabelsRequest) error
	Receive() (*ingestv1.MergeProfilesLabelsResponse, error)
	CloseRequest() error
	CloseResponse() error
}

type BidiClientMergeProfilesPprof

type BidiClientMergeProfilesPprof interface {
	Send(*ingestv1.MergeProfilesPprofRequest) error
	Receive() (*ingestv1.MergeProfilesPprofResponse, error)
	CloseRequest() error
	CloseResponse() error
}

type BidiClientMergeProfilesStacktraces

type BidiClientMergeProfilesStacktraces interface {
	Send(*ingestv1.MergeProfilesStacktracesRequest) error
	Receive() (*ingestv1.MergeProfilesStacktracesResponse, error)
	CloseRequest() error
	CloseResponse() error
}

type PoolConfig

type PoolConfig struct {
	ClientCleanupPeriod  time.Duration `yaml:"client_cleanup_period"`
	HealthCheckIngesters bool          `yaml:"health_check_ingesters"`
	RemoteTimeout        time.Duration `yaml:"remote_timeout"`
}

PoolConfig is config for creating a Pool.

func (*PoolConfig) RegisterFlagsWithPrefix

func (cfg *PoolConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

RegisterFlagsWithPrefix adds the flags required to config this to the given FlagSet.