Versions in this module Expand all Collapse all v0 v0.0.0 Feb 25, 2025 Changes in this version + const AllowedPeerEndpointPrefix + var StatsCounters = []prometheus.CounterDefinition + var StatsGauges = []prometheus.GaugeDefinition + func NewActiveStreamCounter(m *metrics.Metrics, labels []metrics.Label) *activeStreamCounter + func NewOptionalTransportCredentials(creds credentials.TransportCredentials, logger Logger) credentials.TransportCredentials + func NewPanicHandler(logger Logger) recovery.RecoveryHandlerFunc + func NewStatsHandler(m *metrics.Metrics, labels []metrics.Label) *statsHandler + func PanicHandlerMiddlewareOpts(logger Logger) []recovery.Option + func ServerRateLimiterMiddleware(limiter rate.RequestLimitsHandler, panicHandler recovery.RecoveryHandlerFunc, ...) tap.ServerInHandle + type AuthInterceptor struct + Logger Logger + TLS *tlsutil.Configurator + func (a *AuthInterceptor) InterceptStream(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error + func (a *AuthInterceptor) InterceptUnary(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error) + type LabelledConn struct + type LabelledListener struct + Protocol Protocol + func (l LabelledListener) Accept() (net.Conn, error) + type Logger interface + Error func(string, ...interface{}) + Warn func(string, ...interface{}) + type Protocol int + var ProtocolPlaintext Protocol = 0 + var ProtocolTLS Protocol = 1