Documentation
¶
Index ¶
- type AuthMiddleware
- type HttpServer
- type UIServer
- func (s *UIServer) HandleAdminCleanup(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleAdminTokens(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleAdminWorkers(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleBackfillRepoURLs(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleCleanupStuckRuns(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleGeneratePoolToken(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleIndex(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleLogs(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleRepoIssues(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleRun(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleRunLogsText(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleRunRetry(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleStatusStream(w http.ResponseWriter, r *http.Request)
- func (s *UIServer) HandleTerminateWorker(w http.ResponseWriter, r *http.Request)
- type WebSocketServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthMiddleware ¶
type AuthMiddleware struct {
// contains filtered or unexported fields
}
func NewAuthMiddleware ¶
func NewAuthMiddleware(c *core.Core, config *config.AuthConfig) *AuthMiddleware
func (*AuthMiddleware) RequireBasicAuth ¶
func (m *AuthMiddleware) RequireBasicAuth(next http.HandlerFunc) http.HandlerFunc
RequireBasicAuth protects admin endpoints (e.g. /ui/)
func (*AuthMiddleware) RequireRunToken ¶
func (m *AuthMiddleware) RequireRunToken(next http.HandlerFunc) http.HandlerFunc
RequireRunToken protects endpoints that need a specific run token (e.g. /ui/run/<id>)
func (*AuthMiddleware) RequireStatusStreamAuth ¶
func (m *AuthMiddleware) RequireStatusStreamAuth(next http.HandlerFunc) http.HandlerFunc
RequireStatusStreamAuth protects endpoints that can be accessed via token OR basic auth e.g. /ui/status-stream
type HttpServer ¶
type HttpServer struct {
// contains filtered or unexported fields
}
func NewHttpServer ¶
func NewHttpServer(addr string, service *core.Service, wsServer *WebSocketServer, uiServer *UIServer, authMiddleware *AuthMiddleware, logger *slog.Logger) *HttpServer
type UIServer ¶
type UIServer struct {
// contains filtered or unexported fields
}
func NewUIServer ¶
func (*UIServer) HandleAdminCleanup ¶
func (s *UIServer) HandleAdminCleanup(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleAdminTokens ¶
func (s *UIServer) HandleAdminTokens(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleAdminWorkers ¶
func (s *UIServer) HandleAdminWorkers(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleBackfillRepoURLs ¶
func (s *UIServer) HandleBackfillRepoURLs(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleCleanupStuckRuns ¶
func (s *UIServer) HandleCleanupStuckRuns(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleGeneratePoolToken ¶
func (s *UIServer) HandleGeneratePoolToken(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleIndex ¶
func (s *UIServer) HandleIndex(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleLogs ¶
func (s *UIServer) HandleLogs(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleRepoIssues ¶
func (s *UIServer) HandleRepoIssues(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleRunLogsText ¶
func (s *UIServer) HandleRunLogsText(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleRunRetry ¶
func (s *UIServer) HandleRunRetry(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleStatusStream ¶
func (s *UIServer) HandleStatusStream(w http.ResponseWriter, r *http.Request)
func (*UIServer) HandleTerminateWorker ¶
func (s *UIServer) HandleTerminateWorker(w http.ResponseWriter, r *http.Request)
type WebSocketServer ¶
type WebSocketServer struct {
// contains filtered or unexported fields
}
func NewWebSocketServer ¶
func NewWebSocketServer(c *core.Core, logger *slog.Logger) *WebSocketServer
func (*WebSocketServer) HandleConnect ¶
func (s *WebSocketServer) HandleConnect(w http.ResponseWriter, r *http.Request)
func (*WebSocketServer) StartPingPongDaemon ¶
func (s *WebSocketServer) StartPingPongDaemon(ctx context.Context)
StartPingPongDaemon starts the centralized ping/pong health check daemon
Source Files
Click to show internal directories.
Click to hide internal directories.