middleware

Sep 30, 2021

Changes in this version

+ type Limiter interface

+ Limit func() bool

+ ReturnTicket func()

+ func NewKelvinsRateLimit(maxConcurrent int) Limiter

+ type RPCRateLimitInterceptor struct

+ func NewRPCRateLimitInterceptor(maxConcurrent int) *RPCRateLimitInterceptor

+ func (r *RPCRateLimitInterceptor) StreamServerInterceptor() grpc.StreamServerInterceptor

+ func (r *RPCRateLimitInterceptor) UnaryServerInterceptor() grpc.UnaryServerInterceptor

Sep 24, 2021

Changes in this version

+ func GetRPCPerAuthHeader(secret string) (map[string]string, error)

+ 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

Aug 13, 2021

Changes in this version

+ func RPCPerCredentials(sharedSecret string) credentials.PerRPCCredentials

Aug 13, 2021

Changes in this version

+ func GetRPCAuthDialOptions(conf *setting.RPCAuthSettingS) (opts []grpc.DialOption)

+ func RPCCredentials(sharedSecret string) credentials.PerRPCCredentials

+ func SetTokenValidityDuration(d time.Duration)

+ func TokenValidityDuration() time.Duration

+ type AuthInfo struct

+ Message string

+ SignedMessage []byte

+ Version string

+ type AuthInterceptor struct

+ App *kelvins.GRPCApplication

+ func (i *AuthInterceptor) StreamServerInterceptor(conf *setting.RPCAuthSettingS) grpc.StreamServerInterceptor

+ func (i *AuthInterceptor) UnaryServerInterceptor(conf *setting.RPCAuthSettingS) grpc.UnaryServerInterceptor