interceptor

Documentation

Index

• Constants
• func FileDescriptorHasResloved(fullMethod string) bool
• func IgnoreFileDescriptor(fds []protoreflect.FileDescriptor)
• func RegisteAuthorizationProxyValidator(name string, handler proposal.SignatureHandler)
• func RegisteAuthorizationValidator(name string, handler proposal.UserinfoHandler)
• func RegisteWhitelistingValidator(name string, handler proposal.WhitelistingHandler)
• func ResloveFileDescriptor(role Role)
• func StreamClientInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, signer proposal.Signer, ...) grpc.StreamClientInterceptor
• func StreamGatewayInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), ...) grpc.StreamClientInterceptor
• func StreamServerInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), ...) grpc.StreamServerInterceptor
• func UnaryClientInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, signer proposal.Signer, ...) grpc.UnaryClientInterceptor
• func UnaryGatewayInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), ...) grpc.UnaryClientInterceptor
• func UnaryServerInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), ...) grpc.UnaryServerInterceptor
• type Role
• type SessionUserinfo
• type SignatureIdentifier

Constants

const (
	// JournalID a random id used by log journal
	JournalID = "journal-id"
	// Authorization used by auth, both gateway and grpc
	Authorization = "authorization"
	// AuthorizationProxy used by signature, both gateway and grpc
	AuthorizationProxy = "authorization-proxy"
	// Date GMT format
	Date = "date"
	// Method http.XXXMethod
	Method = "method"
	// URI url encoded
	URI = "uri"
	// Body string body
	Body = "body"
	// XForwardedFor forwarded for
	XForwardedFor = "x-forwarded-for"
	// XForwardedHost forwarded host
	XForwardedHost = "x-forwarded-host"
	// OctetStream binary files
	OctetStream = "octet-stream"
)

Functions

func FileDescriptorHasResloved

func FileDescriptorHasResloved(fullMethod string) bool

func IgnoreFileDescriptor

func IgnoreFileDescriptor(fds []protoreflect.FileDescriptor)

IgnoreFileDescriptor ignore some methods

func RegisteAuthorizationProxyValidator

func RegisteAuthorizationProxyValidator(name string, handler proposal.SignatureHandler)

RegisteAuthorizationProxyValidator signature handler for interceptor options.authorization_proxy

func RegisteAuthorizationValidator

func RegisteAuthorizationValidator(name string, handler proposal.UserinfoHandler)

RegisteAuthorizationValidator userinfo handler for interceptor options.authorization

func RegisteWhitelistingValidator

func RegisteWhitelistingValidator(name string, handler proposal.WhitelistingHandler)

RegisteWhitelistingValidator whiteling handler for interceptor options.whitelisting

func ResloveFileDescriptor

func ResloveFileDescriptor(role Role)

ResloveFileDescriptor reslove options from FileDescriptor

func StreamClientInterceptor

func StreamClientInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, signer proposal.Signer, projectName string) grpc.StreamClientInterceptor

StreamClientInterceptor stream interceptor for client

func StreamGatewayInterceptor

func StreamGatewayInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), projectName string) grpc.StreamClientInterceptor

StreamGatewayInterceptor stream interceptor for gateway

func StreamServerInterceptor

func StreamServerInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), projectName string, disableMessageValitator bool) grpc.StreamServerInterceptor

StreamServerInterceptor stream interceptor for server

func UnaryClientInterceptor

func UnaryClientInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, signer proposal.Signer, projectName string) grpc.UnaryClientInterceptor

UnaryClientInterceptor unary interceptor for client

func UnaryGatewayInterceptor

func UnaryGatewayInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), projectName string) grpc.UnaryClientInterceptor

UnaryGatewayInterceptor unary interceptor for gateway

func UnaryServerInterceptor

func UnaryServerInterceptor(logger *zap.Logger, notify proposal.NotifyHandler, metrics func(http.Handler), projectName string, disableMessageValitator bool) grpc.UnaryServerInterceptor

UnaryServerInterceptor unary interceptor for server

Types

type Role

type Role int

const (
	Gateway Role = iota + 1
	Client
	Server
)

type SessionUserinfo

type SessionUserinfo struct{}

SessionUserinfo mark userinfo in context

type SignatureIdentifier

type SignatureIdentifier struct{}

SignatureIdentifier mark identifier in context