client_conn

Documentation

Index

• func RPCClientDialOptionAppend(opts []grpc.DialOption)
• type ConnClient
  • func NewConnClient(serviceName string) (*ConnClient, error)
  • func (c *ConnClient) GetConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
  • func (c *ConnClient) GetEndpoints(ctx context.Context) (endpoints []string, err error)

Functions

func RPCClientDialOptionAppend

func RPCClientDialOptionAppend(opts []grpc.DialOption)

only executed at boot load, so no locks are used

Types

type ConnClient

type ConnClient struct {
	ServerName string
}

func NewConnClient

func NewConnClient(serviceName string) (*ConnClient, error)

func (*ConnClient) GetConn

func (c *ConnClient) GetConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

return a valid connection as much as possible

func (*ConnClient) GetEndpoints

func (c *ConnClient) GetEndpoints(ctx context.Context) (endpoints []string, err error)

the returned endpoint list may have invalid nodes