Documentation
¶
Index ¶
- Variables
- func StreamClientRateLimiterInterceptor(limiter rateLimiterAcessor, opts ...ClientRateLimiterOption) grpc.StreamClientInterceptor
- func StreamClientRequestIDInterceptor() grpc.StreamClientInterceptor
- func StreamMetricsInterceptor() grpc.StreamServerInterceptor
- func StreamRequestIDInterceptor() grpc.StreamServerInterceptor
- func StreamServerRateLimiterInterceptor(limiter rateLimiterAcessor) grpc.StreamServerInterceptor
- func UnaryClientRateLimiterInterceptor(limiter rateLimiterAcessor, opts ...ClientRateLimiterOption) grpc.UnaryClientInterceptor
- func UnaryClientRequestIDInterceptor() grpc.UnaryClientInterceptor
- func UnaryMetricsInterceptor() grpc.UnaryServerInterceptor
- func UnaryRequestIDInterceptor() grpc.UnaryServerInterceptor
- func UnaryServerRateLimiterInterceptor(limiter rateLimiterAcessor) grpc.UnaryServerInterceptor
- type ClientRateLimitKeyFunc
- type ClientRateLimiterOption
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultSkipper = func(method string) bool { switch method { case reflectionpb.ServerReflection_ServerReflectionInfo_FullMethodName, healthpb.Health_List_FullMethodName, healthpb.Health_Check_FullMethodName, healthpb.Health_Watch_FullMethodName: return true default: return false } }
Functions ¶
func StreamClientRateLimiterInterceptor ¶
func StreamClientRateLimiterInterceptor( limiter rateLimiterAcessor, opts ...ClientRateLimiterOption, ) grpc.StreamClientInterceptor
func StreamClientRequestIDInterceptor ¶
func StreamClientRequestIDInterceptor() grpc.StreamClientInterceptor
func StreamMetricsInterceptor ¶
func StreamMetricsInterceptor() grpc.StreamServerInterceptor
func StreamRequestIDInterceptor ¶
func StreamRequestIDInterceptor() grpc.StreamServerInterceptor
func StreamServerRateLimiterInterceptor ¶
func StreamServerRateLimiterInterceptor(limiter rateLimiterAcessor) grpc.StreamServerInterceptor
func UnaryClientRateLimiterInterceptor ¶
func UnaryClientRateLimiterInterceptor( limiter rateLimiterAcessor, opts ...ClientRateLimiterOption, ) grpc.UnaryClientInterceptor
func UnaryClientRequestIDInterceptor ¶
func UnaryClientRequestIDInterceptor() grpc.UnaryClientInterceptor
func UnaryMetricsInterceptor ¶
func UnaryMetricsInterceptor() grpc.UnaryServerInterceptor
func UnaryRequestIDInterceptor ¶
func UnaryRequestIDInterceptor() grpc.UnaryServerInterceptor
func UnaryServerRateLimiterInterceptor ¶
func UnaryServerRateLimiterInterceptor(limiter rateLimiterAcessor) grpc.UnaryServerInterceptor
Types ¶
type ClientRateLimitKeyFunc ¶
type ClientRateLimiterOption ¶
type ClientRateLimiterOption func(*clientRateLimiterConfig)
func WithClientRateLimitKeyFunc ¶
func WithClientRateLimitKeyFunc(keyFunc ClientRateLimitKeyFunc) ClientRateLimiterOption
func WithClientRateLimitScope ¶
func WithClientRateLimitScope(scope string) ClientRateLimiterOption
WithClientRateLimitScope replaces the transport target with a stable logical upstream name while retaining per-method buckets.
Source Files
Click to show internal directories.
Click to hide internal directories.