lib

Documentation

Index

• Constants
• func ChannelzClient(addr string) channelz.ChannelzClient
• func NewStreamLogger() grpc.StreamServerInterceptor
• func NewStreamRateLimiter(opts ...RateLimitOption) grpc.StreamServerInterceptor
• func NewTokenBucketRateLimiter(fillInterval time.Duration, capacity, quantum int64) *tokenBucketLimiter
• func NewUnaryLogger() grpc.UnaryServerInterceptor
• func NewUnaryRateLimiter(opts ...RateLimitOption) grpc.UnaryServerInterceptor
• func NewUnaryUUID() grpc.UnaryServerInterceptor
• func UnaryAuthInterceptor(ctxFunc func(ctx context.Context) (context.Context, error)) grpc.UnaryServerInterceptor
• type Channelz
  • func NewChannelz() *Channelz
  • func NewReflection() *Channelz
• type Healthz
  • func NewHealthz() *Healthz
• type Limiter
• type RateLimitOption
  • func WithLimiter(l Limiter) RateLimitOption
  • func WithMaxWaitDuration(maxWaitDuration time.Duration) RateLimitOption
• type Reflection

Constants

const RequestIDKey = keyType(iota)

Functions

func ChannelzClient

func ChannelzClient(addr string) channelz.ChannelzClient

ChannelzClient creates a new grpc channelz client for connecting to a registered channelz server for debugging.

func NewStreamLogger

func NewStreamLogger() grpc.StreamServerInterceptor

func NewStreamRateLimiter

func NewStreamRateLimiter(opts ...RateLimitOption) grpc.StreamServerInterceptor

func NewTokenBucketRateLimiter

func NewTokenBucketRateLimiter(fillInterval time.Duration, capacity, quantum int64) *tokenBucketLimiter

func NewUnaryLogger

func NewUnaryLogger() grpc.UnaryServerInterceptor

func NewUnaryRateLimiter

func NewUnaryRateLimiter(opts ...RateLimitOption) grpc.UnaryServerInterceptor

func NewUnaryUUID

func NewUnaryUUID() grpc.UnaryServerInterceptor

func UnaryAuthInterceptor

func UnaryAuthInterceptor(ctxFunc func(ctx context.Context) (context.Context, error)) grpc.UnaryServerInterceptor

Types

type Channelz

type Channelz struct {
	driver.PluginFunc
}

func NewChannelz

func NewChannelz() *Channelz

func NewReflection

func NewReflection() *Channelz

type Healthz

type Healthz struct {
	driver.PluginFunc
}

func NewHealthz

func NewHealthz() *Healthz

type Limiter

type Limiter interface {
	WaitMaxDuration(time.Duration) bool
}

type RateLimitOption

type RateLimitOption func(*rateLimiter)

func WithLimiter

func WithLimiter(l Limiter) RateLimitOption

func WithMaxWaitDuration

func WithMaxWaitDuration(maxWaitDuration time.Duration) RateLimitOption

type Reflection

type Reflection struct {
	driver.PluginFunc
}