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 { if method == "/grpc.reflection.v1.ServerReflection/ServerReflectionInfo" || method == "/grpc.health.v1.Health/List" || method == "/grpc.health.v1.Health/Check" || method == "/grpc.health.v1.Health/Watch" { return true } 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.