 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- func NewIngesterPool(cfg PoolConfig, ring ring.ReadRing, factory ring_client.PoolFactory, ...) *ring_client.Pool
- func NewStoreGatewayPool(ring ring.ReadRing, factory ring_client.PoolFactory, ...) *ring_client.Pool
- type BidiClientMergeProfilesLabels
- type BidiClientMergeProfilesPprof
- type BidiClientMergeProfilesStacktraces
- type BidiClientMergeSpanProfile
- type PoolConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 NewStoreGatewayPool ¶ added in v1.6.0
func NewStoreGatewayPool(ring ring.ReadRing, factory ring_client.PoolFactory, clientsMetric prometheus.Gauge, logger log.Logger, options ...connect.ClientOption) *ring_client.Pool
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 BidiClientMergeSpanProfile ¶ added in v1.2.0
type BidiClientMergeSpanProfile interface {
	Send(request *ingestv1.MergeSpanProfileRequest) error
	Receive() (*ingestv1.MergeSpanProfileResponse, 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.
 Click to show internal directories. 
   Click to hide internal directories.