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, tenantMgr *metadata.TenantManager, ...) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)
• func GetJWTValidator(config *config.Config) *validator.Validator
• type CustomClaim
  • func (c CustomClaim) Validate(_ context.Context) error
• type Forwarder
• type Namespace
• type NamespaceSetter
  • func (r *NamespaceSetter) NamespaceSetterStreamServerInterceptor() grpc.StreamServerInterceptor
  • func (r *NamespaceSetter) NamespaceSetterUnaryServerInterceptor() ...
• type TokenCtxkey
• type User

Constants

const (
	CookieMaxAgeKey = "Expires"
)

const (
	TigrisStreamSpan string = "rpcstream"
)

Variables

var (
	UnknownNamespace          = "unknown"
	BypassAuthForTheseMethods = set.New("/HealthAPI/Health", "/tigrisdata.auth.v1.Auth/getAccessToken", "/grpc.reflection.v1alpha.ServerReflection/ServerReflectionInfo")
)

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

var OutgoingHeaders = metadata.New(map[string]string{})

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, tenantMgr *metadata.TenantManager, txMgr *transaction.Manager) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)

func GetJWTValidator

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

Types

type CustomClaim

type CustomClaim struct {
	Namespace Namespace `json:"https://tigris/n"`
	User      User      `json:"https://tigris/u"`
}

func (CustomClaim) Validate

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

type Forwarder

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

type Namespace

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

type NamespaceSetter

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

func (*NamespaceSetter) NamespaceSetterStreamServerInterceptor

func (r *NamespaceSetter) NamespaceSetterStreamServerInterceptor() grpc.StreamServerInterceptor

func (*NamespaceSetter) NamespaceSetterUnaryServerInterceptor

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

type TokenCtxkey

type TokenCtxkey struct{}

type User

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