pool

Documentation

Index

• type FlumeClientPool
  • func (self *FlumeClientPool) ActivePoolSize() int
  • func (self *FlumeClientPool) CorePoolSize() int
  • func (self *FlumeClientPool) Destroy()
  • func (self *FlumeClientPool) Get(timeout time.Duration) (*client.FlumeClient, error)
  • func (self *FlumeClientPool) GetHostPort() config.HostPort
  • func (self *FlumeClientPool) MonitorPool() (int, int, int)
  • func (self *FlumeClientPool) PoolSize() int
  • func (self *FlumeClientPool) Release(fclient *client.FlumeClient) error
  • func (self *FlumeClientPool) ReleaseBroken(fclient *client.FlumeClient) error
• type FlumePoolLink
  • func NewFlumePoolLink(hp config.HostPort) (*FlumePoolLink, error)
  • func (self *FlumePoolLink) AttachBusiness(business string)
  • func (self *FlumePoolLink) DetachBusiness(business string)
  • func (self *FlumePoolLink) IsAttached(business string) bool
• type IdleClient

Types

type FlumeClientPool

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

func (*FlumeClientPool) ActivePoolSize

func (self *FlumeClientPool) ActivePoolSize() int

func (*FlumeClientPool) CorePoolSize

func (self *FlumeClientPool) CorePoolSize() int

func (*FlumeClientPool) Destroy

func (self *FlumeClientPool) Destroy()

func (*FlumeClientPool) Get

func (self *FlumeClientPool) Get(timeout time.Duration) (*client.FlumeClient, error)

func (*FlumeClientPool) GetHostPort

func (self *FlumeClientPool) GetHostPort() config.HostPort

func (*FlumeClientPool) MonitorPool

func (self *FlumeClientPool) MonitorPool() (int, int, int)

func (*FlumeClientPool) PoolSize

func (self *FlumeClientPool) PoolSize() int

func (*FlumeClientPool) Release

func (self *FlumeClientPool) Release(fclient *client.FlumeClient) error

return current connection

func (*FlumeClientPool) ReleaseBroken

func (self *FlumeClientPool) ReleaseBroken(fclient *client.FlumeClient) error

unleash bad resources

type FlumePoolLink

type FlumePoolLink struct {
	FlumePool *FlumeClientPool

	BusinessLink *list.List

	Mutex sync.RWMutex // Ensures that the list can be operated safely in concurrent situations
}

flumeclient pool Link

func NewFlumePoolLink

func NewFlumePoolLink(hp config.HostPort) (*FlumePoolLink, error)

func (*FlumePoolLink) AttachBusiness

func (self *FlumePoolLink) AttachBusiness(business string)

func (*FlumePoolLink) DetachBusiness

func (self *FlumePoolLink) DetachBusiness(business string)

func (*FlumePoolLink) IsAttached

func (self *FlumePoolLink) IsAttached(business string) bool

type IdleClient

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