Documentation ¶
Index ¶
- Variables
- func ClientBreaker() middleware.Middleware
- func GetClientConn(endpoint string, timeout int, dialWithCredentials bool, ...) (*grpc.ClientConn, error)
- func GetRPCClientConn(configPath string, opts ...kgrpc.ClientOption) *grpc.ClientConn
- func Log() middleware.Middleware
- func NewGRPCServer(opts ...kgrpc.ServerOption) *kgrpc.Server
- func RateLimit(opts ...bbr.Option) middleware.Middleware
- func Recovery() middleware.Middleware
- func StartAt() middleware.Middleware
- func Validator() middleware.Middleware
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // DefaultServerMiddlewares ... DefaultServerMiddlewares = []middleware.Middleware{StartAt(), tracing.Server(), Log(), Recovery(), metadata.Server(), RateLimit(bbr.WithCPUThreshold(900)), Validator()} // DefaultClientMiddlewares ... DefaultClientMiddlewares = []middleware.Middleware{Recovery(), tracing.Client(), metadata.Client(), ClientBreaker()} )
Functions ¶
func GetClientConn ¶
func GetClientConn(endpoint string, timeout int, dialWithCredentials bool, opts ...kgrpc.ClientOption) (*grpc.ClientConn, error)
GetClientConn ...
func GetRPCClientConn ¶
func GetRPCClientConn(configPath string, opts ...kgrpc.ClientOption) *grpc.ClientConn
GetRPCClientConn 配置结构规则 config/env/env.go:58
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.