grpc_pool

Documentation

Index

• Variables
• func LoadLeastNode(ctx context.Context, m map[string]*fs.ServerNode) (err error)
• type Builder
• type ClientConn
• type Conn
• type Option
• type Pool
  • func GetLeastNodePool() Pool
  • func GetNodeConn() (Pool, error)
  • func NewPool(builder Builder, options ...Option) (Pool, error)

Variables

var (
	ConnMap map[string]Pool
	NodeMap map[string]*fs.ServerNode
)

var ClosedErr = errors.New("grpc pool has closed")

Functions

func LoadLeastNode

func LoadLeastNode(ctx context.Context, m map[string]*fs.ServerNode) (err error)

Types

type Builder

type Builder func() (*grpc.ClientConn, error)

type ClientConn

type ClientConn interface {
	grpc.ClientConnInterface
	// contains filtered or unexported methods
}

type Conn

type Conn interface {
	Conn() ClientConn
	// contains filtered or unexported methods
}

type Option

type Option func(*option)

Option optional configs

type Pool

type Pool interface {
	Get() (Conn, error)
	Restore(Conn)
	Close()
}

func GetLeastNodePool

func GetLeastNodePool() Pool

func GetNodeConn

func GetNodeConn() (Pool, error)

func NewPool

func NewPool(builder Builder, options ...Option) (Pool, error)