middleware

Documentation

Index

• func GetRPCAuthDialOptions(conf *setting.RPCAuthSettingS) (opts []grpc.DialOption)
• func GetRPCPerAuthHeader(secret string) (map[string]string, error)
• func RPCPerCredentials(sharedSecret string) credentials.PerRPCCredentials
• type AuthInfo
• type Limiter
  • func NewKelvinsRateLimit(maxConcurrent int) Limiter
• type RPCPerAuthInterceptor
  • 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
  • func NewRPCRateLimitInterceptor(maxConcurrent int) *RPCRateLimitInterceptor
  • func (r *RPCRateLimitInterceptor) StreamServerInterceptor() grpc.StreamServerInterceptor
  • func (r *RPCRateLimitInterceptor) UnaryServerInterceptor() grpc.UnaryServerInterceptor

Functions

func GetRPCAuthDialOptions

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

func GetRPCPerAuthHeader

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

GetRPCPerAuthHeader 根据私钥获取RPC 接入auth header

func RPCPerCredentials

func RPCPerCredentials(sharedSecret string) credentials.PerRPCCredentials

Types

type AuthInfo

type AuthInfo struct {
	Version       string
	SignedMessage []byte
	Message       string
}

type Limiter

type Limiter interface {
	Limit() bool
	ReturnTicket()
}

func NewKelvinsRateLimit

func NewKelvinsRateLimit(maxConcurrent int) Limiter

type RPCPerAuthInterceptor

type RPCPerAuthInterceptor struct {
	// contains filtered or unexported fields
}

func NewRPCPerAuthInterceptor

func NewRPCPerAuthInterceptor(errLogger log.LoggerContextIface) *RPCPerAuthInterceptor

func (*RPCPerAuthInterceptor) StreamServerInterceptor

func (i *RPCPerAuthInterceptor) StreamServerInterceptor(conf *setting.RPCAuthSettingS) grpc.StreamServerInterceptor

func (*RPCPerAuthInterceptor) UnaryServerInterceptor

func (i *RPCPerAuthInterceptor) UnaryServerInterceptor(conf *setting.RPCAuthSettingS) grpc.UnaryServerInterceptor

type RPCRateLimitInterceptor

type RPCRateLimitInterceptor struct {
	// contains filtered or unexported fields
}

func NewRPCRateLimitInterceptor

func NewRPCRateLimitInterceptor(maxConcurrent int) *RPCRateLimitInterceptor

func (*RPCRateLimitInterceptor) StreamServerInterceptor

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

func (*RPCRateLimitInterceptor) UnaryServerInterceptor

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