rpc_pool

package module

v0.0.0-...-e875a5a Latest Latest Go to latest Published: Nov 22, 2021 License: Apache-2.0 Imports: 10 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

rpc pool

This section is empty.

This section is empty.

This section is empty.

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

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 interface {
	Call(method string, args interface{}, reply interface{}) error
	Close()
	ServerConn() error
	GetAddr() string
}

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

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