tokens

Documentation

Index

• Constants
• func ConvertTokenResource(schema *types.Schema, token v3.Token) (map[string]interface{}, error)
• func GetTokenAuthFromRequest(req *http.Request) string
• func IsExpired(token v3.Token) bool
• func NewAPIHandler(ctx context.Context, apiContext *config.ScaledContext, opts ...ServerOption) (http.Handler, error)
• func SetTokenExpiresAt(token *v3.Token)
• func SplitTokenParts(tokenID string) (string, string)
• func StartPurgeDaemon(ctx context.Context, mgmt *config.ManagementContext)
• type Manager
  • func NewManager(ctx context.Context, apiContext *config.ScaledContext) *Manager
  • func (m *Manager) CreateSecret(userID, provider, secret string) error
  • func (m *Manager) CreateTokenAndSetCookie(userID string, userPrincipal v3.Principal, groupPrincipals []v3.Principal, ...) error
  • func (m *Manager) EnsureAndGetUserAttribute(userID string) (*v3.UserAttribute, bool, error)
  • func (m *Manager) GetGroupsForTokenAuthProvider(token *v3.Token) []v3.Principal
  • func (m *Manager) GetSecret(userID string, provider string, fallbackTokens []*v3.Token) (string, error)
  • func (m *Manager) IsMemberOf(token v3.Token, group v3.Principal) bool
  • func (m *Manager) NewLoginToken(userID string, userPrincipal v3.Principal, groupPrincipals []v3.Principal, ...) (v3.Token, error)
  • func (m *Manager) TokenStreamTransformer(apiContext *types.APIContext, schema *types.Schema, ...) (chan map[string]interface{}, error)
  • func (m *Manager) UpdateSecret(userID, provider, secret string) error
  • func (m *Manager) UpdateToken(token *v3.Token) (*v3.Token, error)
  • func (m *Manager) UserAttributeChanged(attribs *v3.UserAttribute, provider string, groupPrincipals []v3.Principal) bool
  • func (m *Manager) UserAttributeCreateOrUpdate(userID, provider string, groupPrincipals []v3.Principal) error
• type ServerOption

Constants

const (
	CookieName      = "R_SESS"
	AuthHeaderName  = "Authorization"
	AuthValuePrefix = "Bearer"
	BasicAuthPrefix = "Basic"
	CSRFCookie      = "CSRF"
)

const (
	UserIDLabel    = "authn.management.cattle.io/token-userId"
	TokenKindLabel = "authn.management.cattle.io/kind"
)

Functions

func ConvertTokenResource

func ConvertTokenResource(schema *types.Schema, token v3.Token) (map[string]interface{}, error)

func GetTokenAuthFromRequest

func GetTokenAuthFromRequest(req *http.Request) string

func IsExpired

func IsExpired(token v3.Token) bool

func NewAPIHandler

func NewAPIHandler(ctx context.Context, apiContext *config.ScaledContext, opts ...ServerOption) (http.Handler, error)

func SetTokenExpiresAt

func SetTokenExpiresAt(token *v3.Token)

func SplitTokenParts

func SplitTokenParts(tokenID string) (string, string)

func StartPurgeDaemon

func StartPurgeDaemon(ctx context.Context, mgmt *config.ManagementContext)

Types

type Manager

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

func NewManager

func NewManager(ctx context.Context, apiContext *config.ScaledContext) *Manager

func (*Manager) CreateSecret

func (m *Manager) CreateSecret(userID, provider, secret string) error

CreateSecret saves the secret in k8s. Secret is saved under the userID-secret with key being the provider and data being the providers secret

func (*Manager) CreateTokenAndSetCookie

func (m *Manager) CreateTokenAndSetCookie(userID string, userPrincipal v3.Principal, groupPrincipals []v3.Principal, providerToken string, ttl int, description string, request *types.APIContext) error

func (*Manager) EnsureAndGetUserAttribute

func (m *Manager) EnsureAndGetUserAttribute(userID string) (*v3.UserAttribute, bool, error)

func (*Manager) GetGroupsForTokenAuthProvider

func (m *Manager) GetGroupsForTokenAuthProvider(token *v3.Token) []v3.Principal

func (*Manager) GetSecret

func (m *Manager) GetSecret(userID string, provider string, fallbackTokens []*v3.Token) (string, error)

func (*Manager) IsMemberOf

func (m *Manager) IsMemberOf(token v3.Token, group v3.Principal) bool

func (*Manager) NewLoginToken

func (m *Manager) NewLoginToken(userID string, userPrincipal v3.Principal, groupPrincipals []v3.Principal, providerToken string, ttl int64, description string) (v3.Token, error)

func (*Manager) TokenStreamTransformer

func (m *Manager) TokenStreamTransformer(
	apiContext *types.APIContext,
	schema *types.Schema,
	data chan map[string]interface{},
	opt *types.QueryOptions) (chan map[string]interface{}, error)

TokenStreamTransformer only filters out data for tokens that do not belong to the user

func (*Manager) UpdateSecret

func (m *Manager) UpdateSecret(userID, provider, secret string) error

func (*Manager) UpdateToken

func (m *Manager) UpdateToken(token *v3.Token) (*v3.Token, error)

func (*Manager) UserAttributeChanged

func (m *Manager) UserAttributeChanged(attribs *v3.UserAttribute, provider string, groupPrincipals []v3.Principal) bool

func (*Manager) UserAttributeCreateOrUpdate

func (m *Manager) UserAttributeCreateOrUpdate(userID, provider string, groupPrincipals []v3.Principal) error

type ServerOption

type ServerOption func(server *normanapi.Server)