Versions in this module Expand all Collapse all v0 v0.2.0 Jun 18, 2017 Changes in this version + type SafeRpcConnPools struct + CallTimeout int + ConnTimeout int + M map[string]*connp.ConnPool + MaxConns int + MaxIdle int + func CreateSafeJsonrpcConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *SafeRpcConnPools + func CreateSafeRpcConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *SafeRpcConnPools + func (this *SafeRpcConnPools) Call(addr, method string, args interface{}, resp interface{}) error + func (this *SafeRpcConnPools) Destroy() + func (this *SafeRpcConnPools) Get(address string) (*connp.ConnPool, bool) + func (this *SafeRpcConnPools) Proc() []string + type TsdbClient struct + func (t TsdbClient) Close() error + func (t TsdbClient) Closed() bool + func (t TsdbClient) Name() string + type TsdbConnPoolHelper struct + func NewTsdbConnPoolHelper(address string, maxConns, maxIdle, connTimeout, callTimeout int) *TsdbConnPoolHelper + func (t *TsdbConnPoolHelper) Destroy() + func (t *TsdbConnPoolHelper) Send(data []byte) (err error)
Go to main page