client

Documentation

Index

• Constants
• func DefaultOptions() []grpc.DialOption
• type Client
  • func New(conf *config.Config, dialOpt ...map[string][]grpc.DialOption) *Client
  • func (e *Client) Connection(app string, options ...grpc.DialOption) (conn grpc.ClientConnInterface, err error)
• type Config

Constants

const (
	// DialTimeout the timeout of create connection
	DialTimeout = 5 * time.Second

	// BackoffMaxDelay provided maximum delay when backing off after failed connection attempts.
	BackoffMaxDelay = 3 * time.Second

	// KeepAliveTime is the duration of time after which if the client doesn't see
	// any activity it pings the server to see if the transport is still alive.
	KeepAliveTime = time.Duration(10) * time.Second

	// KeepAliveTimeout is the duration of time for which the client waits after having
	// pinged for keepalive check and if no activity is seen even after that the connection
	// is closed.
	KeepAliveTimeout = time.Duration(3) * time.Second

	// InitialWindowSize we set it 1GB is to provide system's throughput.
	InitialWindowSize = 1 << 30

	// InitialConnWindowSize we set it 1GB is to provide system's throughput.
	InitialConnWindowSize = 1 << 30

	// MaxSendMsgSize set max gRPC request message size sent to server.
	// If any request message size is larger than current value, an error will be reported from gRPC.
	MaxSendMsgSize = 4 << 30

	// MaxRecvMsgSize set max gRPC receive message size received from server.
	// If any message size is larger than current value, an error will be reported from gRPC.
	MaxRecvMsgSize = 4 << 30
)

Functions

func DefaultOptions

func DefaultOptions() []grpc.DialOption

Types

type Client

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

func New

func New(conf *config.Config, dialOpt ...map[string][]grpc.DialOption) *Client

func (*Client) Connection

func (e *Client) Connection(app string, options ...grpc.DialOption) (conn grpc.ClientConnInterface, err error)

获取一个连接

type Config

type Config struct {
	Endpoints []string
	Target    string
	App       string
	Token     string
	Timeout   int64

	Registry naming.Config
}