middleware

Documentation

Index

• Constants
• Variables
• func AuthFromMD(ctx context.Context, expectedScheme string) (string, error)
• func AuthFunction(ctx context.Context, jwtValidator *validator.Validator, config *config.Config) (ctxResult context.Context, err error)
• func Get(config *config.Config) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)
• func GetJWTValidator(config *config.Config) *validator.Validator
• func StreamMetricsServerInterceptor() grpc.StreamServerInterceptor
• func TxCtxUnaryServerInterceptor(timeout time.Duration) grpc.UnaryServerInterceptor
• func UnaryMetricsServerInterceptor() ...
• type CustomClaim
  • func (c CustomClaim) Validate(ctx context.Context) error
• type Forwarder
• type Organization
• type RateLimiter
  • func (r *RateLimiter) Limit(_ context.Context) error
• type User

Constants

const (
	AllowedConnections      int           = 256
	BacklogConnectionsLimit int           = 256
	BacklogWindow           time.Duration = 1 * time.Second
)

Variables

var (
	DefaultTimeout = 2 * time.Second
	MaximumTimeout = 5 * time.Second
)

var (
	UserAgent = "tigris-forwarder/" + util.Version
)

Functions

func AuthFromMD

func AuthFromMD(ctx context.Context, expectedScheme string) (string, error)

func AuthFunction

func AuthFunction(ctx context.Context, jwtValidator *validator.Validator, config *config.Config) (ctxResult context.Context, err error)

func Get

func Get(config *config.Config) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)

func GetJWTValidator

func GetJWTValidator(config *config.Config) *validator.Validator

func StreamMetricsServerInterceptor

func StreamMetricsServerInterceptor() grpc.StreamServerInterceptor

func TxCtxUnaryServerInterceptor

func TxCtxUnaryServerInterceptor(timeout time.Duration) grpc.UnaryServerInterceptor

func UnaryMetricsServerInterceptor

func UnaryMetricsServerInterceptor() func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

Types

type CustomClaim

type CustomClaim struct {
	Roles []string     `json:"https://tigris-db-api/r"`
	Org   Organization `json:"https://tigris-db-api/o"`
	User  User         `json:"https://tigris-db-api/u"`
}

func (CustomClaim) Validate

func (c CustomClaim) Validate(ctx context.Context) error

type Forwarder

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

type Organization

type Organization struct {
	Code string `json:"code"`
}

type RateLimiter

type RateLimiter struct {
}

func (*RateLimiter) Limit

func (r *RateLimiter) Limit(_ context.Context) error

type User

type User struct {
	Email string `json:"email"`
}