clientpool

Documentation

Index

• func NewPool(ring ring.ReadRing, factory ring_client.PoolFactory, ...) *ring_client.Pool
• func PoolFactoryFn(options ...connect.ClientOption) ring_client.PoolFactory
• type BidiClientMergeProfilesLabels
• type BidiClientMergeProfilesPprof
• type BidiClientMergeProfilesStacktraces

Functions

func NewPool

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

func PoolFactoryFn

func PoolFactoryFn(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
}