pool

package

v0.0.0-...-941e108 Latest Latest Go to latest Published: Aug 28, 2015 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

flume连接池

func (self *FlumeClientPool) ActivePoolSize() 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

返回当前的poolszie

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

* * 归还当前的连接 *

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

释放坏的资源

type FlumePoolLink struct {
	FlumePool *FlumeClientPool

	BusinessLink *list.List //使用这个clientpool的业务名称

	Mutex sync.RWMutex //保证在并发情况下能够对list的操作安全
}

flumeclient的pool Link

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

func (self *FlumePoolLink) AttachBusiness(business string)

将该business从link加入

func (self *FlumePoolLink) DetachBusiness(business string)

将该business从link重移除

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

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