middleware

Documentation

Index

• Constants
• Variables
• func AuthFromMD(ctx context.Context, expectedScheme string) (string, error)
• func Get(config *config.Config) (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 TokenCtxkey
• type User

Constants

const (
	CookieMaxAgeKey = "Expires"
)

const (
	TigrisStreamSpan string = "rpcstream"
)

Variables

var (
	UnknownNamespace          = "unknown"
	BypassAuthForTheseMethods = container.NewHashSet(
		"/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 Get

func Get(config *config.Config) (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 TokenCtxkey

type TokenCtxkey struct{}

type User

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