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.