Versions in this module Expand all Collapse all v1 v1.0.1 Dec 23, 2023 Changes in this version + func GetRPCAuthDialOptions(conf *setting.RPCAuthSettingS) (opts []grpc.DialOption) + func GetRPCPerAuthHeader(secret string) (map[string]string, error) + func RPCPerCredentials(sharedSecret string) credentials.PerRPCCredentials + type AuthInfo struct + Message string + SignedMessage []byte + Version string + type Limiter interface + Limit func() bool + ReturnTicket func() + func NewKelvinsRateLimit(maxConcurrent int) Limiter + type RPCPerAuthInterceptor struct + func NewRPCPerAuthInterceptor(errLogger log.LoggerContextIface) *RPCPerAuthInterceptor + func (i *RPCPerAuthInterceptor) StreamServerInterceptor(conf *setting.RPCAuthSettingS) grpc.StreamServerInterceptor + func (i *RPCPerAuthInterceptor) UnaryServerInterceptor(conf *setting.RPCAuthSettingS) grpc.UnaryServerInterceptor + type RPCRateLimitInterceptor struct + func NewRPCRateLimitInterceptor(maxConcurrent int) *RPCRateLimitInterceptor + func (r *RPCRateLimitInterceptor) StreamServerInterceptor() grpc.StreamServerInterceptor + func (r *RPCRateLimitInterceptor) UnaryServerInterceptor() grpc.UnaryServerInterceptor