client

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, addr string, authConfig types.AuthConfig) (*Client, error)
  • func (c *Client) GetConn() *grpc.ClientConn
  • func (c *Client) GetRPCClient() pb.CoreRPCClient
• type Pool
  • func NewCoreRPCClientPool(ctx context.Context, config *PoolConfig) (*Pool, error)
  • func (c *Pool) GetClient() pb.CoreRPCClient
• type PoolConfig

Types

type Client

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

Client contain grpc conn

func NewClient

func NewClient(ctx context.Context, addr string, authConfig types.AuthConfig) (*Client, error)

NewClient new a client

func (*Client) GetConn

func (c *Client) GetConn() *grpc.ClientConn

GetConn return connection

func (*Client) GetRPCClient

func (c *Client) GetRPCClient() pb.CoreRPCClient

GetRPCClient return rpc client

type Pool

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

Pool implement of RPCClientPool

func NewCoreRPCClientPool

func NewCoreRPCClientPool(ctx context.Context, config *PoolConfig) (*Pool, error)

NewCoreRPCClientPool .

func (*Pool) GetClient

func (c *Pool) GetClient() pb.CoreRPCClient

GetClient finds the first *client.Client instance with an active connection. If all connections are dead, returns the first one.

type PoolConfig

type PoolConfig struct {
	EruAddrs          []string
	Auth              types.AuthConfig
	ConnectionTimeout time.Duration
}

PoolConfig config for client pool