httpserver

package

Go to main page

Versions in this module

v0

v0.0.6

Dec 28, 2025

Changes in this version

type Config

+ Credd htcondor.CreddClient

v0.0.5

Dec 19, 2025

v0.0.4

Dec 14, 2025

Changes in this version

+ var ErrAuthorizationPending = &fosite.RFC6749Error

+ var ErrExpiredToken = &fosite.RFC6749Error

+ var ErrSlowDown = &fosite.RFC6749Error

+ func ConfigureSecurityForTokenWithCacheAndFallback(token string, sessionCache *security.SessionCache, allowFSFallback bool) (*security.SecurityConfig, error)

+ func DefaultIDPSession(username string) *openid.DefaultSession

+ type AdvertiseRequest struct

+ Ad *classad.ClassAd

+ Command string

+ WithAck bool

+ type AdvertiseResponse struct

+ Errors []string

+ Failed int

+ Message string

+ Succeeded int

+ Success bool

type Config

+ EnableIDP bool

+ HTCondorConfig *config.Config

+ HTTPBaseURL string

+ IDPDBPath string

+ IDPIssuer string

+ OAuth2Scopes []string

+ PingInterval time.Duration

+ SessionTTL time.Duration

+ StreamBufferSize int

+ StreamWriteTimeout time.Duration

+ TLSCACertFile string

+ Token string

+ type DeviceAuthorizationResponse struct

+ DeviceCode string

+ ExpiresIn int

+ Interval int

+ UserCode string

+ VerificationURI string

+ VerificationURIComplete string

+ type DeviceCodeHandler struct

+ func NewDeviceCodeHandler(storage *OAuth2Storage, config *fosite.Config) *DeviceCodeHandler

+ func (h *DeviceCodeHandler) HandleDeviceAccessRequest(ctx context.Context, deviceCode string, session fosite.Session) (fosite.Requester, error)

+ func (h *DeviceCodeHandler) HandleDeviceAuthorizationRequest(ctx context.Context, client fosite.Client, scopes []string) (*DeviceAuthorizationResponse, error)

+ type HistoryListResponse struct

+ Ads []*classad.ClassAd

+ type IDPProvider struct

+ func NewIDPProvider(dbPath string, issuer string) (*IDPProvider, error)

+ func (p *IDPProvider) Close() error

+ func (p *IDPProvider) GetProvider() fosite.OAuth2Provider

+ func (p *IDPProvider) GetStorage() *IDPStorage

+ func (p *IDPProvider) GetStrategy() *compose.CommonStrategy

+ func (p *IDPProvider) UpdateIssuer(issuer string)

+ type IDPStorage struct

+ func NewIDPStorage(dbPath string) (*IDPStorage, error)

+ func (s *IDPStorage) AuthenticateUser(ctx context.Context, username, password string) error

+ func (s *IDPStorage) ClientAssertionJWTValid(ctx context.Context, jti string) error

+ func (s *IDPStorage) Close() error

+ func (s *IDPStorage) CreateAccessTokenSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *IDPStorage) CreateAuthorizeCodeSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *IDPStorage) CreateClient(ctx context.Context, client *fosite.DefaultClient) error

+ func (s *IDPStorage) CreateOpenIDConnectSession(ctx context.Context, signature string, requester fosite.Requester) error

+ func (s *IDPStorage) CreatePKCERequestSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *IDPStorage) CreateRefreshTokenSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *IDPStorage) CreateSession(ctx context.Context, username string) (string, error)

+ func (s *IDPStorage) CreateUser(ctx context.Context, username, password, state string) error

+ func (s *IDPStorage) DeleteAccessTokenSession(ctx context.Context, signature string) error

+ func (s *IDPStorage) DeleteOpenIDConnectSession(ctx context.Context, signature string) error

+ func (s *IDPStorage) DeletePKCERequestSession(ctx context.Context, signature string) error

+ func (s *IDPStorage) DeleteRefreshTokenSession(ctx context.Context, signature string) error

+ func (s *IDPStorage) DeleteSession(ctx context.Context, sessionID string) error

+ func (s *IDPStorage) GetAccessTokenSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *IDPStorage) GetAuthorizeCodeSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *IDPStorage) GetClient(ctx context.Context, clientID string) (fosite.Client, error)

+ func (s *IDPStorage) GetOpenIDConnectSession(ctx context.Context, signature string, requester fosite.Requester) (fosite.Requester, error)

+ func (s *IDPStorage) GetPKCERequestSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *IDPStorage) GetRefreshTokenSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *IDPStorage) GetSession(ctx context.Context, sessionID string) (string, error)

+ func (s *IDPStorage) GetUserState(ctx context.Context, username string) (string, error)

+ func (s *IDPStorage) InvalidateAuthorizeCodeSession(ctx context.Context, signature string) error

+ func (s *IDPStorage) LoadHMACSecret(ctx context.Context) ([]byte, error)

+ func (s *IDPStorage) LoadRSAKey(ctx context.Context) (string, error)

+ func (s *IDPStorage) RevokeAccessToken(ctx context.Context, requestID string) error

+ func (s *IDPStorage) RevokeRefreshToken(ctx context.Context, requestID string) error

+ func (s *IDPStorage) RevokeRefreshTokenMaybeGracePeriod(ctx context.Context, requestID string, _ string) error

+ func (s *IDPStorage) SaveHMACSecret(ctx context.Context, secret []byte) error

+ func (s *IDPStorage) SaveRSAKey(ctx context.Context, privateKeyPEM string) error

+ func (s *IDPStorage) SetClientAssertionJWT(ctx context.Context, jti string, exp time.Time) error

+ func (s *IDPStorage) UserExists(ctx context.Context, username string) (bool, error)

+ type JobEditRequest struct

+ Attributes map[string]interface{}

+ type LoginRateLimiter struct

+ func NewLoginRateLimiter(r rate.Limit, b int) *LoginRateLimiter

+ func (l *LoginRateLimiter) Allow(ip string) bool

type OAuth2Provider

+ func (p *OAuth2Provider) GetStrategy() *compose.CommonStrategy

+ func (p *OAuth2Provider) IntrospectToken(ctx context.Context, token string) (fosite.Session, error)

+ func (p *OAuth2Provider) UpdateIssuer(issuer string)

type OAuth2StateEntry

+ OriginalURL string

+ Username string

type OAuth2StateStore

+ func (s *OAuth2StateStore) GetWithURL(state string) (fosite.AuthorizeRequester, string, bool)

+ func (s *OAuth2StateStore) GetWithUsername(state string) (fosite.AuthorizeRequester, string, bool)

+ func (s *OAuth2StateStore) Remove(state string)

+ func (s *OAuth2StateStore) StoreWithURL(state string, ar fosite.AuthorizeRequester, originalURL string)

+ func (s *OAuth2StateStore) StoreWithUsername(state string, ar fosite.AuthorizeRequester, originalURL, username string)

type OAuth2Storage

+ func (s *OAuth2Storage) ApproveDeviceCodeSession(ctx context.Context, userCode string, subject string, session fosite.Session) error

+ func (s *OAuth2Storage) CreateDeviceCodeSession(ctx context.Context, deviceCode string, userCode string, ...) error

+ func (s *OAuth2Storage) CreatePKCERequestSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *OAuth2Storage) DeletePKCERequestSession(ctx context.Context, signature string) error

+ func (s *OAuth2Storage) DenyDeviceCodeSession(ctx context.Context, userCode string) error

+ func (s *OAuth2Storage) GetDB() *sql.DB

+ func (s *OAuth2Storage) GetDeviceCodeSession(ctx context.Context, deviceCode string, session fosite.Session) (fosite.Requester, error)

+ func (s *OAuth2Storage) GetDeviceCodeSessionByUserCode(ctx context.Context, userCode string) (string, fosite.Requester, error)

+ func (s *OAuth2Storage) GetPKCERequestSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *OAuth2Storage) InvalidateDeviceCodeSession(ctx context.Context, deviceCode string) error

+ func (s *OAuth2Storage) UpdateDeviceCodePolling(ctx context.Context, deviceCode string) error

+ type PingResponse struct

+ AuthMethod string

+ Authentication bool

+ Authorized bool

+ Daemon string

+ Encryption bool

+ Permission string

+ SessionID string

+ User string

+ ValidCommands string

+ type SessionData struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ Token string

+ Username string

+ type SessionStore struct

+ func NewSessionStore(db *sql.DB, ttl time.Duration) (*SessionStore, error)

+ func (s *SessionStore) Cleanup()

+ func (s *SessionStore) Create(username string) (string, *SessionData, error)

+ func (s *SessionStore) Delete(sessionID string)

+ func (s *SessionStore) Get(sessionID string) *SessionData

+ func (s *SessionStore) Size() int

type TokenCache

+ func (tc *TokenCache) AddValidated(token, username string, expiration time.Time) (*TokenCacheEntry, error)

+ type WhoAmIResponse struct

+ Authenticated bool

+ User string

v0.0.3

Nov 17, 2025

Changes in this version

+ func ConfigureSecurityForTokenWithCache(token string, sessionCache *security.SessionCache) (*security.SecurityConfig, error)

+ func DefaultOpenIDConnectSession(username string) *openid.DefaultSession

+ type CollectorAdsResponse struct

+ Ads []*classad.ClassAd

type Config

+ EnableMCP bool

+ Logger *logging.Logger

+ MCPAccessGroup string

+ MCPReadGroup string

+ MCPWriteGroup string

+ OAuth2AuthURL string

+ OAuth2ClientID string

+ OAuth2ClientSecret string

+ OAuth2DBPath string

+ OAuth2GroupsClaim string

+ OAuth2Issuer string

+ OAuth2RedirectURL string

+ OAuth2TokenURL string

+ OAuth2UserInfoURL string

+ OAuth2UsernameClaim string

+ type JobActionFunc func(ctx context.Context, constraint, reason string) (*htcondor.JobActionResults, error)

+ type OAuth2Provider struct

+ func NewOAuth2Provider(dbPath string, issuer string) (*OAuth2Provider, error)

+ func (p *OAuth2Provider) Close() error

+ func (p *OAuth2Provider) GetProvider() fosite.OAuth2Provider

+ func (p *OAuth2Provider) GetStorage() *OAuth2Storage

+ type OAuth2StateEntry struct

+ AuthorizeRequest fosite.AuthorizeRequester

+ Timestamp time.Time

+ type OAuth2StateStore struct

+ func NewOAuth2StateStore() *OAuth2StateStore

+ func (s *OAuth2StateStore) GenerateState() (string, error)

+ func (s *OAuth2StateStore) Get(state string) (fosite.AuthorizeRequester, bool)

+ func (s *OAuth2StateStore) Store(state string, ar fosite.AuthorizeRequester)

+ type OAuth2Storage struct

+ func NewOAuth2Storage(dbPath string) (*OAuth2Storage, error)

+ func (s *OAuth2Storage) ClientAssertionJWTValid(ctx context.Context, jti string) error

+ func (s *OAuth2Storage) Close() error

+ func (s *OAuth2Storage) CreateAccessTokenSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *OAuth2Storage) CreateAuthorizeCodeSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *OAuth2Storage) CreateClient(ctx context.Context, client *fosite.DefaultClient) error

+ func (s *OAuth2Storage) CreateOpenIDConnectSession(ctx context.Context, signature string, requester fosite.Requester) error

+ func (s *OAuth2Storage) CreateRefreshTokenSession(ctx context.Context, signature string, request fosite.Requester) error

+ func (s *OAuth2Storage) DeleteAccessTokenSession(ctx context.Context, signature string) error

+ func (s *OAuth2Storage) DeleteOpenIDConnectSession(ctx context.Context, signature string) error

+ func (s *OAuth2Storage) DeleteRefreshTokenSession(ctx context.Context, signature string) error

+ func (s *OAuth2Storage) GetAccessTokenSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *OAuth2Storage) GetAuthorizeCodeSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *OAuth2Storage) GetClient(ctx context.Context, clientID string) (fosite.Client, error)

+ func (s *OAuth2Storage) GetOpenIDConnectSession(ctx context.Context, signature string, requester fosite.Requester) (fosite.Requester, error)

+ func (s *OAuth2Storage) GetRefreshTokenSession(ctx context.Context, signature string, session fosite.Session) (fosite.Requester, error)

+ func (s *OAuth2Storage) InvalidateAuthorizeCodeSession(ctx context.Context, signature string) error

+ func (s *OAuth2Storage) LoadHMACSecret(ctx context.Context) ([]byte, error)

+ func (s *OAuth2Storage) LoadRSAKey(ctx context.Context) (string, error)

+ func (s *OAuth2Storage) RevokeAccessToken(ctx context.Context, requestID string) error

+ func (s *OAuth2Storage) RevokeRefreshToken(ctx context.Context, requestID string) error

+ func (s *OAuth2Storage) RevokeRefreshTokenMaybeGracePeriod(ctx context.Context, requestID string, _ string) error

+ func (s *OAuth2Storage) SaveHMACSecret(ctx context.Context, secret []byte) error

+ func (s *OAuth2Storage) SaveRSAKey(ctx context.Context, privateKeyPEM string) error

+ func (s *OAuth2Storage) SetClientAssertionJWT(ctx context.Context, jti string, exp time.Time) error

type Server

+ func (s *Server) GetAddr() string

+ func (s *Server) GetOAuth2Provider() *OAuth2Provider

+ func (s *Server) UpdateOAuth2RedirectURL(redirectURL string)

+ type TokenCache struct

+ func NewTokenCache() *TokenCache

+ func (tc *TokenCache) Add(token string) (*TokenCacheEntry, error)

+ func (tc *TokenCache) Get(token string) (*TokenCacheEntry, bool)

+ func (tc *TokenCache) Remove(token string)

+ func (tc *TokenCache) Size() int

+ type TokenCacheEntry struct

+ Expiration time.Time

+ SessionCache *security.SessionCache

+ Token string

+ Username string

+ type UserInfo struct

+ Claims map[string]interface{}

+ Email string

+ Groups interface{}

+ Name string

+ Subject string

v0.0.2

Nov 14, 2025

Changes in this version

type Config

+ Collector *htcondor.Collector

+ EnableMetrics bool

+ MetricsCacheTTL time.Duration

+ TrustDomain string

+ UIDDomain string

v0.0.1

Nov 13, 2025

Changes in this version

+ func ConfigureSecurityForToken(token string) (*security.SecurityConfig, error)

+ func EncodeSigningKey(key []byte) string

+ func GenerateSigningKey() ([]byte, error)

+ func GenerateToken(username, signingKeyPath string) (string, error)

+ func GetScheddWithToken(ctx context.Context, schedd *htcondor.Schedd) (*htcondor.Schedd, error)

+ func GetSecurityConfigFromToken(ctx context.Context) (*security.SecurityConfig, error)

+ func GetTokenFromContext(ctx context.Context) (string, bool)

+ func WithToken(ctx context.Context, token string) context.Context

+ type Config struct

+ IdleTimeout time.Duration

+ ListenAddr string

+ ReadTimeout time.Duration

+ ScheddAddr string

+ ScheddName string

+ ScheddPort int

+ SigningKeyPath string

+ TLSCertFile string

+ TLSKeyFile string

+ UserHeader string

+ WriteTimeout time.Duration

+ type ErrorResponse struct

+ Code int

+ Error string

+ Message string

+ type JobListResponse struct

+ Jobs []map[string]interface{}

+ type JobSubmitRequest struct

+ SubmitFile string

+ type JobSubmitResponse struct

+ ClusterID int

+ JobIDs []string

+ type Server struct

+ func NewServer(cfg Config) (*Server, error)

+ func (s *Server) Shutdown(ctx context.Context) error

+ func (s *Server) Start() error

+ func (s *Server) StartTLS(certFile, keyFile string) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL