client

Documentation

Index

• Constants
• func DefaultOptions() []grpc.DialOption
• type Client
  • func NewClient(conf *config.ServerConfig, dialOpt ...map[string][]grpc.DialOption) *Client
  • func (e *Client) Close(app ...string)
  • func (e *Client) Connection(app string, appendOpts ...[]grpc.DialOption) (conn *grpc.ClientConn, err error)
  • func (e *Client) Invoke(ctx context.Context, app, method string, in, rs interface{}, h ...string) error

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 NewClient

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

func (*Client) Close

func (e *Client) Close(app ...string)

func (*Client) Connection

func (e *Client) Connection(app string, appendOpts ...[]grpc.DialOption) (conn *grpc.ClientConn, err error)

获取一个连接

func (*Client) Invoke

func (e *Client) Invoke(ctx context.Context, app, method string, in, rs interface{}, h ...string) error

depreciated 此方法不好，虽然看起来封装了，但是当method改名或者更换之后，编辑器无法识别 没有对外的调用，目前只支持不带验证的 默认执行