The highest tagged major version is
Documentation
¶
Index ¶
- Constants
- func HealthCheck(srv string, conn *grpc.ClientConn) error
- func NewDirect(addr string, opts ...func(cfg *Cfg)) (*grpc.ClientConn, error)
- type Cfg
- type Client
- func (t *Client) CheckHealth(opts ...grpc.CallOption) (*grpc_health_v1.HealthCheckResponse, error)
- func (t *Client) Close() error
- func (t *Client) Get() (_ grpc.ClientConnInterface, err error)
- func (t *Client) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
- func (t *Client) Kind() string
- func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
- func (t *Client) UpdateResObj(val interface{})
- func (t *Client) Watch(ctx context.Context, in *grpc_health_v1.HealthCheckRequest, ...) (grpc_health_v1.Health_WatchClient, error)
Constants ¶
View Source
const ( Name = "grpcc" // DefaultTimeout 默认的连接超时时间 DefaultTimeout = 3 * time.Second )
Variables ¶
This section is empty.
Functions ¶
func HealthCheck ¶
func HealthCheck(srv string, conn *grpc.ClientConn) error
Types ¶
type Cfg ¶
type Cfg struct {
Registry string `json:"registry"`
MaxMsgSize int `json:"max_msg_size"`
Codec string `json:"codec"`
Compressor string `json:"compressor"`
Decompressor string `json:"decompressor"`
Balancer string `json:"balancer"`
BackoffMaxDelay time.Duration `json:"backoff_max_delay"`
Timeout time.Duration `json:"timeout"`
DialTimeout time.Duration `json:"dial_timeout"`
MaxDelay time.Duration `json:"max_delay"`
UserAgent string `json:"user_agent"`
Authority string `json:"authority"`
ChannelzParentID int64 `json:"channelz_parent_id"`
DisableServiceConfig bool `json:"disable_service_config"`
DefaultServiceConfig string `json:"default_service_config"`
DisableRetry bool `json:"disable_retry"`
MaxHeaderListSize uint32 `json:"max_header_list_size"`
DisableHealthCheck bool `json:"disable_health_check"`
BalancerName string `json:"balancer_name"`
Insecure bool `json:"insecure"`
Block bool `json:"block"`
IdleNum uint32 `json:"idle_num"`
WriteBuffer int `json:"write_buffer"`
ReadBuffer int `json:"read_buffer"`
WindowSize int32 `json:"window_size"`
ConnWindowSize int32 `json:"conn_window_size"`
// MaxRecvMsgSize maximum message that Client can receive (4 MB).
MaxRecvMsgSize int `json:"max_recv_msg_size"`
NoProxy bool `json:"no_proxy"`
Proxy bool `json:"proxy"`
ConnectParams connectParams `json:"connect_params"`
ClientParameters clientParameters `json:"client_parameters"`
Call callParameters `json:"call"`
Middlewares []string `json:"-"`
DialOptions []grpc.DialOption `json:"-"`
UnaryInterceptors []grpc.UnaryClientInterceptor `json:"-"`
StreamInterceptors []grpc.StreamClientInterceptor `json:"-"`
}
Cfg ...
func DefaultCfg ¶
func (Cfg) BuildDirect ¶
func (t Cfg) BuildDirect(target string) (conn *grpc.ClientConn, gErr error)
BuildDirect 直连模式
func (Cfg) ToOpts ¶
func (t Cfg) ToOpts() []grpc.DialOption
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) CheckHealth ¶
func (t *Client) CheckHealth(opts ...grpc.CallOption) (*grpc_health_v1.HealthCheckResponse, error)
func (*Client) Get ¶
func (t *Client) Get() (_ grpc.ClientConnInterface, err error)
Get new grpc Client
func (*Client) NewStream ¶
func (t *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
func (*Client) UpdateResObj ¶
func (t *Client) UpdateResObj(val interface{})
func (*Client) Watch ¶
func (t *Client) Watch(ctx context.Context, in *grpc_health_v1.HealthCheckRequest, opts ...grpc.CallOption) (grpc_health_v1.Health_WatchClient, error)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.