rpcx

Documentation

Index

• func WithStreamClientInterceptors(interceptors ...grpc.StreamClientInterceptor) grpc.DialOption
• func WithUnaryClientInterceptors(interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption
• type Client
• type ClientOption
  • func WithDialOption(opt grpc.DialOption) ClientOption
  • func WithTimeout(timeout time.Duration) ClientOption
• type ClientOptions
• type DirectClient
  • func NewDirectClient(host string, timeout int64, opts ...ClientOption) (*DirectClient, error)
  • func (c *DirectClient) Next() (*grpc.ClientConn, bool)

Functions

func WithStreamClientInterceptors

func WithStreamClientInterceptors(interceptors ...grpc.StreamClientInterceptor) grpc.DialOption

func WithUnaryClientInterceptors

func WithUnaryClientInterceptors(interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption

Types

type Client

type Client interface {
	Next() (*grpc.ClientConn, bool)
}

type ClientOption

type ClientOption func(options *ClientOptions)

func WithDialOption

func WithDialOption(opt grpc.DialOption) ClientOption

func WithTimeout

func WithTimeout(timeout time.Duration) ClientOption

type ClientOptions

type ClientOptions struct {
	Timeout     time.Duration
	DialOptions []grpc.DialOption
}

type DirectClient

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

func NewDirectClient

func NewDirectClient(host string, timeout int64, opts ...ClientOption) (*DirectClient, error)

@desc 初始化客户端 @auth liuguoqiang 2020-04-21 @param @return

func (*DirectClient) Next

func (c *DirectClient) Next() (*grpc.ClientConn, bool)

@desc 返回grpc链接 @auth liuguoqiang 2020-04-21 @param @return