client

Documentation

Index

• Constants
• func NewGrpcClient(ctx context.Context, uri string, pbNewXxxClient interface{}, ...) (interface{}, error)
• type Client
  • func NewClient(ctx context.Context, uri string, opts ...ClientOptional) (*Client, error)
  • func (c *Client) Request(ctx context.Context, method, path string, header http.Header, ...) (err error)
• type ClientOptional
  • func WithConnectTimeout(t time.Duration) ClientOptional
  • func WithConsulConfig(consul *consulApi.Config) ClientOptional
  • func WithLogger(logger *zap.Logger) ClientOptional
  • func WithReadTimeout(t time.Duration) ClientOptional
  • func WithResolver(resolver Resolver) ClientOptional
  • func WithRetryTimes(retryTimes int) ClientOptional
  • func WithTracer(tracer opentracing.Tracer) ClientOptional
  • func WithWriteTimeout(t time.Duration) ClientOptional
• type ClientOptions
• type GrpcClientOptional
  • func WithGrpcDialOptions(options ...grpc.DialOption) GrpcClientOptional
  • func WithGrpcLogger(logger *zap.Logger) GrpcClientOptional
  • func WithGrpcResolver(resolver Resolver) GrpcClientOptional
  • func WithGrpcTracer(tracer opentracing.Tracer) GrpcClientOptional
  • func WithLoadBalance(loadBalance string) GrpcClientOptional
  • func WithMetrics(metrics bool) GrpcClientOptional
  • func WithSecure(secure bool) GrpcClientOptional
  • func WithTimeout(d time.Duration) GrpcClientOptional
• type GrpcClientOptions
• type Resolver

Constants

const (
	// DefaultTimeout
	DefaultConnectTimeout = time.Second * 10
	DefaultReadTimeout    = time.Second * 10
	DefaultWriteTimeout   = time.Second * 10
	// DefaultRetryTimes 如果请求失败，最多重试3次
	DefaultRetryTimes = 3
	// DefaultRetryDelay 在重试前，延迟等待100毫秒
	DefaultRetryDelay = time.Millisecond * 100
	RequestIDHeader   = "X-Request-Id"
)

Functions

func NewGrpcClient

func NewGrpcClient(ctx context.Context, uri string, pbNewXxxClient interface{},
	opts ...GrpcClientOptional) (interface{}, error)

NewGrpcClient 参数 bNewXxxClient 对应 pb.NewXxxClient 方法

Types

type Client

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

Client

func NewClient

func NewClient(ctx context.Context, uri string, opts ...ClientOptional) (*Client, error)

NewClient

func (*Client) Request

func (c *Client) Request(ctx context.Context, method,
	path string, header http.Header, reqData interface{},
	respDataPtr interface{},
) (err error)

Request 自动序列化和反序列化地请求 请求 和 响应 支持 struct 和 string 和 []byte 三种方式

type ClientOptional

type ClientOptional func(o *ClientOptions)

ClientOptional

func WithConnectTimeout

func WithConnectTimeout(t time.Duration) ClientOptional

WithConnectTimeout

func WithConsulConfig

func WithConsulConfig(consul *consulApi.Config) ClientOptional

WithConsulConfig

func WithLogger

func WithLogger(logger *zap.Logger) ClientOptional

WithLogger

func WithReadTimeout

func WithReadTimeout(t time.Duration) ClientOptional

WithReadTimeout

func WithResolver

func WithResolver(resolver Resolver) ClientOptional

WithResolver

func WithRetryTimes

func WithRetryTimes(retryTimes int) ClientOptional

WithRetryTimes 设置失败重试

func WithTracer

func WithTracer(tracer opentracing.Tracer) ClientOptional

WithTracer

func WithWriteTimeout

func WithWriteTimeout(t time.Duration) ClientOptional

WithWriteTimeout

type ClientOptions

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

ClientOptions

type GrpcClientOptional

type GrpcClientOptional func(o *GrpcClientOptions)

GrpcClientOptional

func WithGrpcDialOptions

func WithGrpcDialOptions(options ...grpc.DialOption) GrpcClientOptional

WithGrpcDialOptions

func WithGrpcLogger

func WithGrpcLogger(logger *zap.Logger) GrpcClientOptional

WithGrpcLogger

func WithGrpcResolver

func WithGrpcResolver(resolver Resolver) GrpcClientOptional

WithGrpcResolver

func WithGrpcTracer

func WithGrpcTracer(tracer opentracing.Tracer) GrpcClientOptional

WithGrpcTracer

func WithLoadBalance

func WithLoadBalance(loadBalance string) GrpcClientOptional

WithLoadBalance

func WithMetrics

func WithMetrics(metrics bool) GrpcClientOptional

WithMetrics

func WithSecure

func WithSecure(secure bool) GrpcClientOptional

WithSecure

func WithTimeout

func WithTimeout(d time.Duration) GrpcClientOptional

WithTimeout

type GrpcClientOptions

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

GrpcClientOptions

type Resolver

type Resolver func(ctx context.Context, host string) (addr string, err error)

Resolver resolver the host