legacyclientpool

Documentation

Index

• type ClientPool
  • func New(dopplerAddr string, maxWriteCount int, ri time.Duration) *ClientPool
  • func (p *ClientPool) Write(data []byte) error
• type CombinedPool
  • func NewCombinedPool(pools ...Pool) *CombinedPool
  • func (p *CombinedPool) Write(message []byte, chainers ...metricbatcher.BatchCounterChainer) error
• type Pool

Types

type ClientPool

type ClientPool struct {
	// contains filtered or unexported fields
}

func New

func New(dopplerAddr string, maxWriteCount int, ri time.Duration) *ClientPool

func (*ClientPool) Write

func (p *ClientPool) Write(data []byte) error

type CombinedPool

type CombinedPool struct {
	// contains filtered or unexported fields
}

func NewCombinedPool

func NewCombinedPool(pools ...Pool) *CombinedPool

func (*CombinedPool) Write

func (p *CombinedPool) Write(message []byte, chainers ...metricbatcher.BatchCounterChainer) error

type Pool

type Pool interface {
	Write(message []byte, chainers ...metricbatcher.BatchCounterChainer) error
}