interceptor

package

v1.9.9 Latest Latest Go to latest Published: Jan 28, 2023 License: MIT Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bluekaki/pkg

Links

Open Source Insights

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 ¶

View Source

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"
)

Variables ¶

This section is empty.

Functions ¶

func FileDescriptorHasResloved ¶ added in v1.3.7

func FileDescriptorHasResloved(fullMethod string) bool

func IgnoreFileDescriptor ¶ added in v1.5.3

func IgnoreFileDescriptor(fds []protoreflect.FileDescriptor)

IgnoreFileDescriptor ignore some methods

func RegisteAuthorizationProxyValidator ¶ added in v1.3.0

func RegisteAuthorizationProxyValidator(name string, handler proposal.SignatureHandler)

RegisteAuthorizationProxyValidator signature handler for interceptor options.authorization_proxy

func RegisteAuthorizationValidator ¶ added in v1.3.0

func RegisteAuthorizationValidator(name string, handler proposal.UserinfoHandler)

RegisteAuthorizationValidator userinfo handler for interceptor options.authorization

func RegisteWhitelistingValidator ¶ added in v1.3.0

func RegisteWhitelistingValidator(name string, handler proposal.WhitelistingHandler)

RegisteWhitelistingValidator whiteling handler for interceptor options.whitelisting

func ResloveFileDescriptor ¶ added in v1.3.0

func ResloveFileDescriptor(role Role)

ResloveFileDescriptor reslove options from FileDescriptor

func StreamClientInterceptor ¶ added in v1.3.1

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

StreamClientInterceptor stream interceptor for client

func StreamGatewayInterceptor ¶ added in v1.3.7

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

StreamGatewayInterceptor stream interceptor for gateway

func StreamServerInterceptor ¶ added in v1.3.0

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 ¶ added in v1.3.1

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

UnaryClientInterceptor unary interceptor for client

func UnaryGatewayInterceptor ¶ added in v1.3.0

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

UnaryGatewayInterceptor unary interceptor for gateway

func UnaryServerInterceptor ¶ added in v1.3.0

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 ¶ added in v1.3.7

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL