server

Documentation

Index

• func MetricUnaryServerInterceptor(serverName string) grpc.UnaryServerInterceptor
• func RateLimitUnaryServerInterceptor(configs map[MethodName]RateLimitConfig) grpc.UnaryServerInterceptor
• func RecoveryUnaryServerInterceptor() grpc.UnaryServerInterceptor
• func TraceUnaryServerInterceptor() grpc.UnaryServerInterceptor
• type MethodName
• type RateLimitConfig

Functions

func MetricUnaryServerInterceptor

func MetricUnaryServerInterceptor(serverName string) grpc.UnaryServerInterceptor

记录请求开始的时间，调用原始的处理函数，然后记录请求处理的时间和错误代码

func RateLimitUnaryServerInterceptor

func RateLimitUnaryServerInterceptor(configs map[MethodName]RateLimitConfig) grpc.UnaryServerInterceptor

func RecoveryUnaryServerInterceptor

func RecoveryUnaryServerInterceptor() grpc.UnaryServerInterceptor

func TraceUnaryServerInterceptor

func TraceUnaryServerInterceptor() grpc.UnaryServerInterceptor

Types

type MethodName

type MethodName string

type RateLimitConfig

type RateLimitConfig struct {
	Cap             int64         `json:"cap"`
	Rate            float64       `json:"rate"`
	WaitMaxDuration time.Duration `json:"wait_max_duration"`
}