Versions in this module Expand all Collapse all v0 v0.0.8 Oct 27, 2020 v0.0.7 Oct 27, 2020 Changes in this version + func StreamClientCtxAugmentingInterceptor(f ContextAugmenter) grpc.StreamClientInterceptor + func StreamClientLimitingInterceptor(limiter ClientLimiter) grpc.StreamClientInterceptor + func StreamServerCtxAugmentingInterceptor(f ContextAugmenter) grpc.StreamServerInterceptor + func StreamServerLimitingInterceptor(limiter ServerLimiter) grpc.StreamServerInterceptor + func UnaryClientCtxAugmentingInterceptor(f ContextAugmenter) grpc.UnaryClientInterceptor + func UnaryClientLimitingInterceptor(limiter ClientLimiter) grpc.UnaryClientInterceptor + func UnaryServerCtxAugmentingInterceptor(f ContextAugmenter) grpc.UnaryServerInterceptor + func UnaryServerLimitingInterceptor(limiter ServerLimiter) grpc.UnaryServerInterceptor + type ClientLimiter interface + Wait func(context.Context) error + type ContextAugmenter func(context.Context) (context.Context, error) + func JoinContexts(aux context.Context) ContextAugmenter + type ServerLimiter interface + Allow func(ctx context.Context) bool
Go to main page