client

Documentation

Index

• func NewClientConn(target string, opts ...options.Option[clientOptions]) (*grpc.ClientConn, error)
• func NewClientConnContext(ctx context.Context, target string, opts ...options.Option[clientOptions]) (*grpc.ClientConn, error)
• func NewClientOptions(opts ...options.Option[clientOptions]) (*[]grpc.DialOption, error)
• func WithClientTracing(tp *sdktrace.TracerProvider) options.Option[clientOptions]
• func WithClientValidator(all bool) options.Option[clientOptions]
• func WithEtcdDiscovery(conf clientv3.Config, serviceDesc grpc.ServiceDesc) options.Option[clientOptions]
• func WithInsecure() options.Option[clientOptions]
• func WithRRLB() options.Option[clientOptions]
• func WithRetry(mc ...MethodConfig) options.Option[clientOptions]
• type MethodConfig
• type MethodName
• type RetryPolicy
• type ServiceConfig

Functions

func NewClientConn

func NewClientConn(target string, opts ...options.Option[clientOptions]) (*grpc.ClientConn, error)

func NewClientConnContext

func NewClientConnContext(ctx context.Context, target string, opts ...options.Option[clientOptions]) (*grpc.ClientConn, error)

func NewClientOptions

func NewClientOptions(opts ...options.Option[clientOptions]) (*[]grpc.DialOption, error)

func WithClientTracing

func WithClientTracing(tp *sdktrace.TracerProvider) options.Option[clientOptions]

func WithClientValidator

func WithClientValidator(all bool) options.Option[clientOptions]

WithClientValidator validate fields, all==true return all fields error, otherwise return first error

func WithEtcdDiscovery

func WithEtcdDiscovery(conf clientv3.Config, serviceDesc grpc.ServiceDesc) options.Option[clientOptions]

func WithInsecure

func WithInsecure() options.Option[clientOptions]

func WithRRLB

func WithRRLB() options.Option[clientOptions]

round_robin load balancing policy

func WithRetry

func WithRetry(mc ...MethodConfig) options.Option[clientOptions]

Types

type MethodConfig

type MethodConfig struct {
	Name        []MethodName `json:"name"`
	RetryPolicy RetryPolicy  `json:"retryPolicy"`
}

type MethodName

type MethodName struct {
	Service string `json:"service"`
	Method  string `json:"method"`
}

type RetryPolicy

type RetryPolicy struct {
	MaxAttempts          int      `json:"MaxAttempts"`
	MaxBackoff           string   `json:"MaxBackoff"`
	InitialBackoff       string   `json:"InitialBackoff"`
	BackoffMultiplier    int      `json:"BackoffMultiplier"`
	RetryableStatusCodes []string `json:"RetryableStatusCodes"`
}

type ServiceConfig

type ServiceConfig struct {
	Methodconfig        []MethodConfig `json:"methodConfig,omitempty"`
	LoadBalancingPolicy string         `json:"loadBalancingPolicy,omitempty"`
}