auth

Documentation

Index

• func IfNeedValidate(ctx context.Context, fullMethod string) bool
• func NewAuth(ak *AccessKeyAuthMiddleware, jwt *JWTAuth, apikey ApiKeyAuth) gosdk.LocalPlugin
• func NewGrpcStream(s grpc.ServerStream, fullName string, ctx context.Context, ...) *grpcServerStream
• func NewHttpHeader(w http.ResponseWriter, r *http.Request) *httpHeader
• type AccessKeyAuthMiddleware
  • func NewAccessKeyAuth(app *biz.AccessKeyAuth, config *config.Config, log logger.Logger) *AccessKeyAuthMiddleware
  • func (a *AccessKeyAuthMiddleware) Name() string
  • func (a *AccessKeyAuthMiddleware) Priority() int
  • func (a *AccessKeyAuthMiddleware) RequestBefore(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}) (context.Context, error)
  • func (a *AccessKeyAuthMiddleware) ResponseAfter(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}, ...) error
  • func (a *AccessKeyAuthMiddleware) SetPriority(priority int)
  • func (a *AccessKeyAuthMiddleware) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (a *AccessKeyAuthMiddleware) StreamRequestBefore(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) (grpc.ServerStream, error)
  • func (a *AccessKeyAuthMiddleware) StreamResponseAfter(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo) error
  • func (a *AccessKeyAuthMiddleware) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp any, err error)
  • func (a *AccessKeyAuthMiddleware) ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)
• type ApiKeyAuth
  • func NewApiKeyAuth(config *config.Config) ApiKeyAuth
• type ApiKeyAuthImpl
  • func (a *ApiKeyAuthImpl) Name() string
  • func (a *ApiKeyAuthImpl) Priority() int
  • func (a *ApiKeyAuthImpl) SetPriority(priority int)
  • func (a *ApiKeyAuthImpl) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (a *ApiKeyAuthImpl) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp any, err error)
  • func (a *ApiKeyAuthImpl) ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)
• type Auth
  • func (a *Auth) Name() string
  • func (a *Auth) Priority() int
  • func (a *Auth) SetPriority(priority int)
  • func (a *Auth) StreamInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (a *Auth) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp any, err error)
• type GrpcHeader
  • func NewGrpcHeader(in metadata.MD, ctx context.Context, out metadata.MD) *GrpcHeader
  • func (g *GrpcHeader) Release()
  • func (g *GrpcHeader) SendHeader(key, value string)
  • func (g *GrpcHeader) Set(key, value string)
• type GrpcStreamHeader
  • func NewGrpcStreamHeader(in metadata.MD, ctx context.Context, out metadata.MD, ss grpc.ServerStream) *GrpcStreamHeader
  • func (g *GrpcStreamHeader) Release()
  • func (g *GrpcStreamHeader) SendHeader(key, value string)
  • func (g *GrpcStreamHeader) Set(key, value string)
• type Header
• type JWTAuth
  • func NewJWTAuth(config *config.Config, rdb *tiga.RedisDao, biz *biz.AuthzUsecase, ...) *JWTAuth
  • func (a *JWTAuth) GetAuthorizationFromMetadata(md metadata.MD) string
  • func (a *JWTAuth) JWTLock(uid string) (*redislock.Lock, error)
  • func (jwt *JWTAuth) Name() string
  • func (jwt *JWTAuth) Priority() int
  • func (a *JWTAuth) RequestBefore(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}) (context.Context, error)
  • func (a *JWTAuth) ResponseAfter(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}, ...) error
  • func (jwt *JWTAuth) SetPriority(priority int)
  • func (a *JWTAuth) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
  • func (a *JWTAuth) StreamRequestBefore(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) (grpc.ServerStream, error)
  • func (a *JWTAuth) StreamResponseAfter(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo) error
  • func (a *JWTAuth) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp any, err error)
  • func (a *JWTAuth) ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)
• type StreamValidator

Functions

func IfNeedValidate

func IfNeedValidate(ctx context.Context, fullMethod string) bool

func NewAuth

func NewAuth(ak *AccessKeyAuthMiddleware, jwt *JWTAuth, apikey ApiKeyAuth) gosdk.LocalPlugin

func NewGrpcStream

func NewGrpcStream(s grpc.ServerStream, fullName string, ctx context.Context, validator StreamValidator) *grpcServerStream

func NewHttpHeader

func NewHttpHeader(w http.ResponseWriter, r *http.Request) *httpHeader

Types

type AccessKeyAuthMiddleware

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

func NewAccessKeyAuth

func NewAccessKeyAuth(app *biz.AccessKeyAuth, config *config.Config, log logger.Logger) *AccessKeyAuthMiddleware

func (*AccessKeyAuthMiddleware) Name

func (a *AccessKeyAuthMiddleware) Name() string

func (*AccessKeyAuthMiddleware) Priority

func (a *AccessKeyAuthMiddleware) Priority() int

func (*AccessKeyAuthMiddleware) RequestBefore

func (a *AccessKeyAuthMiddleware) RequestBefore(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}) (context.Context, error)

func (*AccessKeyAuthMiddleware) ResponseAfter

func (a *AccessKeyAuthMiddleware) ResponseAfter(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}, resp interface{}) error

func (*AccessKeyAuthMiddleware) SetPriority

func (a *AccessKeyAuthMiddleware) SetPriority(priority int)

func (*AccessKeyAuthMiddleware) StreamInterceptor

func (a *AccessKeyAuthMiddleware) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*AccessKeyAuthMiddleware) StreamRequestBefore

func (a *AccessKeyAuthMiddleware) StreamRequestBefore(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo, req interface{}) (grpc.ServerStream, error)

func (*AccessKeyAuthMiddleware) StreamResponseAfter

func (a *AccessKeyAuthMiddleware) StreamResponseAfter(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo) error

func (*AccessKeyAuthMiddleware) UnaryInterceptor

func (a *AccessKeyAuthMiddleware) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp any, err error)

func (*AccessKeyAuthMiddleware) ValidateStream

func (a *AccessKeyAuthMiddleware) ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)

type ApiKeyAuth

type ApiKeyAuth interface {
	gosdk.LocalPlugin
}

func NewApiKeyAuth

func NewApiKeyAuth(config *config.Config) ApiKeyAuth

type ApiKeyAuthImpl

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

func (*ApiKeyAuthImpl) Name

func (a *ApiKeyAuthImpl) Name() string

func (*ApiKeyAuthImpl) Priority

func (a *ApiKeyAuthImpl) Priority() int

func (*ApiKeyAuthImpl) SetPriority

func (a *ApiKeyAuthImpl) SetPriority(priority int)

func (*ApiKeyAuthImpl) StreamInterceptor

func (a *ApiKeyAuthImpl) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*ApiKeyAuthImpl) UnaryInterceptor

func (a *ApiKeyAuthImpl) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp any, err error)

func (*ApiKeyAuthImpl) ValidateStream

func (a *ApiKeyAuthImpl) ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)

type Auth

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

func (*Auth) Name

func (a *Auth) Name() string

func (*Auth) Priority

func (a *Auth) Priority() int

func (*Auth) SetPriority

func (a *Auth) SetPriority(priority int)

func (*Auth) StreamInterceptor

func (a *Auth) StreamInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*Auth) UnaryInterceptor

func (a *Auth) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp any, err error)

type GrpcHeader

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

func NewGrpcHeader

func NewGrpcHeader(in metadata.MD, ctx context.Context, out metadata.MD) *GrpcHeader

func (*GrpcHeader) Release

func (g *GrpcHeader) Release()

func (*GrpcHeader) SendHeader

func (g *GrpcHeader) SendHeader(key, value string)

func (*GrpcHeader) Set

func (g *GrpcHeader) Set(key, value string)

type GrpcStreamHeader

type GrpcStreamHeader struct {
	*GrpcHeader
	// contains filtered or unexported fields
}

func NewGrpcStreamHeader

func NewGrpcStreamHeader(in metadata.MD, ctx context.Context, out metadata.MD, ss grpc.ServerStream) *GrpcStreamHeader

func (*GrpcStreamHeader) Release

func (g *GrpcStreamHeader) Release()

func (*GrpcStreamHeader) SendHeader

func (g *GrpcStreamHeader) SendHeader(key, value string)

func (*GrpcStreamHeader) Set

func (g *GrpcStreamHeader) Set(key, value string)

type Header

type Header interface {
	Set(key, value string)
	SendHeader(key, value string)
}

type JWTAuth

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

func NewJWTAuth

func NewJWTAuth(config *config.Config, rdb *tiga.RedisDao, biz *biz.AuthzUsecase, log logger.Logger) *JWTAuth

func (*JWTAuth) GetAuthorizationFromMetadata

func (a *JWTAuth) GetAuthorizationFromMetadata(md metadata.MD) string

func (*JWTAuth) JWTLock

func (a *JWTAuth) JWTLock(uid string) (*redislock.Lock, error)

func (*JWTAuth) Name

func (jwt *JWTAuth) Name() string

func (*JWTAuth) Priority

func (jwt *JWTAuth) Priority() int

func (*JWTAuth) RequestBefore

func (a *JWTAuth) RequestBefore(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}) (context.Context, error)

func (*JWTAuth) ResponseAfter

func (a *JWTAuth) ResponseAfter(ctx context.Context, info *grpc.UnaryServerInfo, req interface{}, resp interface{}) error

func (*JWTAuth) SetPriority

func (jwt *JWTAuth) SetPriority(priority int)

func (*JWTAuth) StreamInterceptor

func (a *JWTAuth) StreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (*JWTAuth) StreamRequestBefore

func (a *JWTAuth) StreamRequestBefore(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo, req interface{}) (grpc.ServerStream, error)

func (*JWTAuth) StreamResponseAfter

func (a *JWTAuth) StreamResponseAfter(ctx context.Context, ss grpc.ServerStream, info *grpc.StreamServerInfo) error

func (*JWTAuth) UnaryInterceptor

func (a *JWTAuth) UnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp any, err error)

func (*JWTAuth) ValidateStream

func (a *JWTAuth) ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)

type StreamValidator

type StreamValidator interface {
	ValidateStream(ctx context.Context, req interface{}, fullName string, headers Header) (context.Context, error)
}