request

Documentation

Index

• Constants
• Variables
• func DisableSearch(ctx context.Context) bool
• func GetAccessToken(ctx context.Context) (*types.AccessToken, error)
• func GetCurrentSub(ctx context.Context) (string, error)
• func GetMetadataFromHeader(ctx context.Context) (string, bool, string, string)
• func GetNamespace(ctx context.Context) (string, error)
• func GetProjectAndBranchAndColl(req any) (string, string, string)
• func Init(tg metadata.TenantGetter)
• func IsAcceptApplicationJSON(ctx context.Context) bool
• func IsAdminApi(fullMethodName string) bool
• func IsHumanUser(ctx context.Context) bool
• func IsLocalRoot(ctx context.Context) bool
• func IsRead(ctx context.Context) bool
• func IsWrite(ctx context.Context) bool
• func NeedSchemaValidation(ctx context.Context) bool
• func ReadSearchDataFromStorage(ctx context.Context) bool
• func SetLocalRoot(ctx context.Context) context.Context
• type AccessTokenNamespaceExtractor
  • func (*AccessTokenNamespaceExtractor) Extract(ctx context.Context) (string, error)
• type AuthInfo
  • func (AuthInfo) AuthType() string
• type Metadata
  • func GetGrpcEndPointMetadataFromFullMethod(ctx context.Context, fullMethod string, methodType string, req any) Metadata
  • func GetRequestMetadataFromContext(ctx context.Context) (*Metadata, error)
  • func NewRequestEndpointMetadata(ctx context.Context, serviceName string, methodInfo grpc.MethodInfo, db string, ...) Metadata
  • func NewRequestMetadata(ctx context.Context) Metadata
  • func (m *Metadata) GetBranch() string
  • func (m *Metadata) GetCollection() string
  • func (m *Metadata) GetFullMethod() string
  • func (m *Metadata) GetInitialTags() map[string]string
  • func (m *Metadata) GetMethodInfo() grpc.MethodInfo
  • func (m *Metadata) GetMethodName() string
  • func (m *Metadata) GetNamespace() string
  • func (m *Metadata) GetNamespaceName() string
  • func (m *Metadata) GetProject() string
  • func (m *Metadata) GetRole() string
  • func (m *Metadata) GetServiceName() string
  • func (m *Metadata) GetServiceType() string
  • func (m *Metadata) GetTigrisNamespaceNameTag() string
  • func (m *Metadata) SaveToContext(ctx context.Context) context.Context
  • func (m *Metadata) SetAccessToken(token *types.AccessToken)
  • func (m *Metadata) SetBranch(branch string)
  • func (m *Metadata) SetCollection(collection string)
  • func (m *Metadata) SetNamespace(ctx context.Context, namespace string)
  • func (m *Metadata) SetProject(project string)
• type MetadataCtxKey
• type NamespaceExtractor

Constants

const (
	JWTTigrisClaimSpace = "https://tigris"
	NamespaceCode       = "nc"
	Role                = "r"
	UserEmail           = "ue"
	Subject             = "sub"
)

const (
	AcceptTypeApplicationJSON = "application/json"
)

Variables

var ErrNamespaceNotFound = errors.NotFound("namespace not found")

Functions

func DisableSearch

func DisableSearch(ctx context.Context) bool

func GetAccessToken

func GetAccessToken(ctx context.Context) (*types.AccessToken, error)

func GetCurrentSub

func GetCurrentSub(ctx context.Context) (string, error)

func GetMetadataFromHeader

func GetMetadataFromHeader(ctx context.Context) (string, bool, string, string)

GetMetadataFromHeader returns the namespaceCode, isHuman, user sub and user role from the header token.

func GetNamespace

func GetNamespace(ctx context.Context) (string, error)

func GetProjectAndBranchAndColl

func GetProjectAndBranchAndColl(req any) (string, string, string)

func Init

func Init(tg metadata.TenantGetter)

func IsAcceptApplicationJSON

func IsAcceptApplicationJSON(ctx context.Context) bool

func IsAdminApi

func IsAdminApi(fullMethodName string) bool

func IsHumanUser

func IsHumanUser(ctx context.Context) bool

func IsLocalRoot

func IsLocalRoot(ctx context.Context) bool

func IsRead

func IsRead(ctx context.Context) bool

func IsWrite

func IsWrite(ctx context.Context) bool

func NeedSchemaValidation

func NeedSchemaValidation(ctx context.Context) bool

func ReadSearchDataFromStorage

func ReadSearchDataFromStorage(ctx context.Context) bool

func SetLocalRoot

func SetLocalRoot(ctx context.Context) context.Context

Types

type AccessTokenNamespaceExtractor

type AccessTokenNamespaceExtractor struct{}

func (*AccessTokenNamespaceExtractor) Extract

func (*AccessTokenNamespaceExtractor) Extract(ctx context.Context) (string, error)

type AuthInfo

type AuthInfo struct {
	credentials.CommonAuthInfo
	LocalRoot bool
}

AuthInfo is used for root authentication on the unix socket peer.

func (AuthInfo) AuthType

func (AuthInfo) AuthType() string

AuthType returns the type of info as a string.

type Metadata

type Metadata struct {
	IsHuman bool

	// Current user/application
	Sub  string
	Role string
	// contains filtered or unexported fields
}

func GetGrpcEndPointMetadataFromFullMethod

func GetGrpcEndPointMetadataFromFullMethod(ctx context.Context, fullMethod string, methodType string, req any) Metadata

func GetRequestMetadataFromContext

func GetRequestMetadataFromContext(ctx context.Context) (*Metadata, error)

func NewRequestEndpointMetadata

func NewRequestEndpointMetadata(ctx context.Context, serviceName string, methodInfo grpc.MethodInfo, db string, branch string, coll string) Metadata

func NewRequestMetadata

func NewRequestMetadata(ctx context.Context) Metadata

func (*Metadata) GetBranch

func (m *Metadata) GetBranch() string

func (*Metadata) GetCollection

func (m *Metadata) GetCollection() string

func (*Metadata) GetFullMethod

func (m *Metadata) GetFullMethod() string

func (*Metadata) GetInitialTags

func (m *Metadata) GetInitialTags() map[string]string

func (*Metadata) GetMethodInfo

func (m *Metadata) GetMethodInfo() grpc.MethodInfo

func (*Metadata) GetMethodName

func (m *Metadata) GetMethodName() string

func (*Metadata) GetNamespace

func (m *Metadata) GetNamespace() string

func (*Metadata) GetNamespaceName

func (m *Metadata) GetNamespaceName() string

func (*Metadata) GetProject

func (m *Metadata) GetProject() string

func (*Metadata) GetRole

func (m *Metadata) GetRole() string

func (*Metadata) GetServiceName

func (m *Metadata) GetServiceName() string

func (*Metadata) GetServiceType

func (m *Metadata) GetServiceType() string

func (*Metadata) GetTigrisNamespaceNameTag

func (m *Metadata) GetTigrisNamespaceNameTag() string

func (*Metadata) SaveToContext

func (m *Metadata) SaveToContext(ctx context.Context) context.Context

func (*Metadata) SetAccessToken

func (m *Metadata) SetAccessToken(token *types.AccessToken)

func (*Metadata) SetBranch

func (m *Metadata) SetBranch(branch string)

func (*Metadata) SetCollection

func (m *Metadata) SetCollection(collection string)

func (*Metadata) SetNamespace

func (m *Metadata) SetNamespace(ctx context.Context, namespace string)

func (*Metadata) SetProject

func (m *Metadata) SetProject(project string)

type MetadataCtxKey

type MetadataCtxKey struct{}

type NamespaceExtractor

type NamespaceExtractor interface {
	Extract(ctx context.Context) (string, error)
}

NamespaceExtractor - extract the namespace from context.