rpc_pool

README

rpc_pool

rpc pool

Documentation

Index

• type ConnPool
  • func NewCreateRpcPool(addrs []string, retry, timeout, resetTime int64) *ConnPool
  • func (c *ConnPool) AddCli(cli *RpcCli)
  • func (c *ConnPool) Call(method string, args interface{}, reply interface{}) error
  • func (c *ConnPool) Destroy()
  • func (c *ConnPool) GetIdx() int
  • func (c *ConnPool) IncrIdx()
  • func (c *ConnPool) SetIdx(idx int)
• type RcpClier
• type RpcCli
  • func NewRcpCli(addr string, timeout time.Duration) *RpcCli
  • func (c *RpcCli) Call(method string, args interface{}, reply interface{}) error
  • func (c *RpcCli) Close()
  • func (c *RpcCli) GetAddr() string
  • func (c *RpcCli) ServerConn() error
  • func (c *RpcCli) String() string

Types

type ConnPool

type ConnPool struct {
	sync.Mutex
	RpcClis   []RcpClier
	Idx       int
	Retry     int   //异常重试次数
	ResetTime int64 // 复位连接池下标周期,单位：秒
}

func NewCreateRpcPool

func NewCreateRpcPool(addrs []string, retry, timeout, resetTime int64) *ConnPool

func (*ConnPool) AddCli

func (c *ConnPool) AddCli(cli *RpcCli)

func (*ConnPool) Call

func (c *ConnPool) Call(method string, args interface{}, reply interface{}) error

func (*ConnPool) Destroy

func (c *ConnPool) Destroy()

func (*ConnPool) GetIdx

func (c *ConnPool) GetIdx() int

func (*ConnPool) IncrIdx

func (c *ConnPool) IncrIdx()

func (*ConnPool) SetIdx

func (c *ConnPool) SetIdx(idx int)

type RcpClier

type RcpClier interface {
	Call(method string, args interface{}, reply interface{}) error
	Close()
	ServerConn() error
	GetAddr() string
}

type RpcCli

type RpcCli struct {
	sync.Mutex
	Addr    string
	Timeout time.Duration
	Cli     *rpc.Client
}

func NewRcpCli

func NewRcpCli(addr string, timeout time.Duration) *RpcCli

func (*RpcCli) Call

func (c *RpcCli) Call(method string, args interface{}, reply interface{}) error

func (*RpcCli) Close

func (c *RpcCli) Close()

func (*RpcCli) GetAddr

func (c *RpcCli) GetAddr() string

func (*RpcCli) ServerConn

func (c *RpcCli) ServerConn() error

func (*RpcCli) String

func (c *RpcCli) String() string