client

package

v0.1.1 Latest Latest Go to latest Published: Jul 7, 2022 License: BSD-3-Clause Imports: 35 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gorillazer/ginny-serve

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
type ClientOptions
type GrpcClientOptional
type GrpcClientOptions
type Resolver

Constants ¶

View Source

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"
)

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL