middleware

Documentation

Index

• 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
• type AuthInterceptor
  • func (i *AuthInterceptor) StreamServerInterceptor(conf *setting.RPCAuthSettingS) grpc.StreamServerInterceptor
  • func (i *AuthInterceptor) UnaryServerInterceptor(conf *setting.RPCAuthSettingS) grpc.UnaryServerInterceptor

Functions

func GetRPCAuthDialOptions

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

func RPCCredentials

func RPCCredentials(sharedSecret string) credentials.PerRPCCredentials

func SetTokenValidityDuration

func SetTokenValidityDuration(d time.Duration)

func TokenValidityDuration

func TokenValidityDuration() time.Duration

Types

type AuthInfo

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

type AuthInterceptor

type AuthInterceptor struct {
	App *kelvins.GRPCApplication
}

func (*AuthInterceptor) StreamServerInterceptor

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

func (*AuthInterceptor) UnaryServerInterceptor

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