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
- type RPCPerAuthInterceptor
- type RPCRateLimitInterceptor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetRPCAuthDialOptions ¶
func GetRPCAuthDialOptions(conf *setting.RPCAuthSettingS) (opts []grpc.DialOption)
func GetRPCPerAuthHeader ¶
GetRPCPerAuthHeader 根据私钥获取RPC 接入auth header
func RPCPerCredentials ¶
func RPCPerCredentials(sharedSecret string) credentials.PerRPCCredentials
Types ¶
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
Click to show internal directories.
Click to hide internal directories.