pools

Documentation

Index

• type ConnPools
  • func NewConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *ConnPools
  • func (cp *ConnPools) Call(addr, method string, args interface{}, resp interface{}) error
  • func (cp *ConnPools) Get(address string) (*pool.ConnPool, bool)
  • func (cp *ConnPools) UpdatePools(addrs []string) []string
• type OpenTsdbClient
  • func (t OpenTsdbClient) Close() error
  • func (t OpenTsdbClient) Closed() bool
  • func (t OpenTsdbClient) Name() string
• type OpenTsdbConnPoolHelper
  • func NewOpenTsdbConnPoolHelper(address string, maxConns, maxIdle, connTimeout, callTimeout int) *OpenTsdbConnPoolHelper
  • func (t *OpenTsdbConnPoolHelper) Send(data []byte) (err error)
• type RpcClient
  • func (rc RpcClient) Call(method string, args, reply interface{}) error
  • func (rc RpcClient) Close() error
  • func (rc RpcClient) Closed() bool
  • func (rc RpcClient) Name() string

Types

type ConnPools

type ConnPools struct {
	sync.RWMutex
	P           map[string]*pool.ConnPool
	MaxConns    int
	MaxIdle     int
	ConnTimeout int
	CallTimeout int
}

ConnPools is responsible for the Connection Pool lifecycle management.

func NewConnPools

func NewConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *ConnPools

func (*ConnPools) Call

func (cp *ConnPools) Call(addr, method string, args interface{}, resp interface{}) error

Call will block until request failed or timeout.

func (*ConnPools) Get

func (cp *ConnPools) Get(address string) (*pool.ConnPool, bool)

func (*ConnPools) UpdatePools

func (cp *ConnPools) UpdatePools(addrs []string) []string

type OpenTsdbClient

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

func (OpenTsdbClient) Close

func (t OpenTsdbClient) Close() error

func (OpenTsdbClient) Closed

func (t OpenTsdbClient) Closed() bool

func (OpenTsdbClient) Name

func (t OpenTsdbClient) Name() string

type OpenTsdbConnPoolHelper

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

func NewOpenTsdbConnPoolHelper

func NewOpenTsdbConnPoolHelper(address string, maxConns, maxIdle, connTimeout, callTimeout int) *OpenTsdbConnPoolHelper

func (*OpenTsdbConnPoolHelper) Send

func (t *OpenTsdbConnPoolHelper) Send(data []byte) (err error)

type RpcClient

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

RpcClient implements the io.Closer interface

func (RpcClient) Call

func (rc RpcClient) Call(method string, args, reply interface{}) error

func (RpcClient) Close

func (rc RpcClient) Close() error

func (RpcClient) Closed

func (rc RpcClient) Closed() bool

func (RpcClient) Name

func (rc RpcClient) Name() string