rpc

Documentation

Index

• type BalanceConnectPool
• type ClientTarget
• type Clients
  • func NewClients(ctx context.Context, targets []string, except *string, newF NewClientF, ...) *Clients
  • func (c *Clients) GetClient(target string) (any, *grpc.ClientConn)
  • func (c *Clients) ShutDown()
• type NewClientF

Types

type BalanceConnectPool

type BalanceConnectPool struct {
	Clients *ring.Ring
	Balance int
	// contains filtered or unexported fields
}

type ClientTarget

type ClientTarget struct {
	Conn *grpc.ClientConn
	// contains filtered or unexported fields
}

type Clients

type Clients struct {
	Targets []string

	Ctx context.Context
	// contains filtered or unexported fields
}

func NewClients

func NewClients(ctx context.Context, targets []string, except *string, newF NewClientF, poolCnt int) *Clients

func (*Clients) GetClient

func (c *Clients) GetClient(target string) (any, *grpc.ClientConn)

连接池功能去掉了。。把游戏卡住了。

func (*Clients) ShutDown

func (c *Clients) ShutDown()

type NewClientF

type NewClientF func(*grpc.ClientConn) any