Documentation
¶
Index ¶
- type APIHandler
- func (h *APIHandler) CreateJob(ctx forge.Context) error
- func (h *APIHandler) DeleteJob(ctx forge.Context) error
- func (h *APIHandler) DisableJob(ctx forge.Context) error
- func (h *APIHandler) EnableJob(ctx forge.Context) error
- func (h *APIHandler) GetExecution(ctx forge.Context) error
- func (h *APIHandler) GetJob(ctx forge.Context) error
- func (h *APIHandler) GetJobExecutions(ctx forge.Context) error
- func (h *APIHandler) GetJobStats(ctx forge.Context) error
- func (h *APIHandler) GetStats(ctx forge.Context) error
- func (h *APIHandler) Health(ctx forge.Context) error
- func (h *APIHandler) ListExecutions(ctx forge.Context) error
- func (h *APIHandler) ListJobs(ctx forge.Context) error
- func (h *APIHandler) RegisterRoutes(router forge.Router, prefix string)
- func (h *APIHandler) TriggerJob(ctx forge.Context) error
- func (h *APIHandler) UpdateJob(ctx forge.Context) error
- type WebSocketHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIHandler ¶
type APIHandler struct {
// contains filtered or unexported fields
}
APIHandler provides REST API endpoints for cron job management.
func NewAPIHandler ¶
func NewAPIHandler(extension *cronext.Extension, logger forge.Logger) *APIHandler
NewAPIHandler creates a new API handler.
func (*APIHandler) CreateJob ¶
func (h *APIHandler) CreateJob(ctx forge.Context) error
CreateJob creates a new job.
func (*APIHandler) DeleteJob ¶
func (h *APIHandler) DeleteJob(ctx forge.Context) error
DeleteJob deletes a job.
func (*APIHandler) DisableJob ¶
func (h *APIHandler) DisableJob(ctx forge.Context) error
DisableJob disables a job.
func (*APIHandler) EnableJob ¶
func (h *APIHandler) EnableJob(ctx forge.Context) error
EnableJob enables a job.
func (*APIHandler) GetExecution ¶
func (h *APIHandler) GetExecution(ctx forge.Context) error
GetExecution retrieves a single execution.
func (*APIHandler) GetJob ¶
func (h *APIHandler) GetJob(ctx forge.Context) error
GetJob retrieves a job by ID.
func (*APIHandler) GetJobExecutions ¶
func (h *APIHandler) GetJobExecutions(ctx forge.Context) error
GetJobExecutions retrieves execution history for a job.
func (*APIHandler) GetJobStats ¶
func (h *APIHandler) GetJobStats(ctx forge.Context) error
GetJobStats retrieves statistics for a specific job.
func (*APIHandler) GetStats ¶
func (h *APIHandler) GetStats(ctx forge.Context) error
GetStats retrieves scheduler statistics.
func (*APIHandler) Health ¶
func (h *APIHandler) Health(ctx forge.Context) error
Health checks the health of the cron extension.
func (*APIHandler) ListExecutions ¶
func (h *APIHandler) ListExecutions(ctx forge.Context) error
ListExecutions lists all executions.
func (*APIHandler) ListJobs ¶
func (h *APIHandler) ListJobs(ctx forge.Context) error
ListJobs lists all jobs.
func (*APIHandler) RegisterRoutes ¶
func (h *APIHandler) RegisterRoutes(router forge.Router, prefix string)
RegisterRoutes registers API routes with the router.
func (*APIHandler) TriggerJob ¶
func (h *APIHandler) TriggerJob(ctx forge.Context) error
TriggerJob manually triggers a job execution.
type WebSocketHandler ¶
type WebSocketHandler struct {
// contains filtered or unexported fields
}
WebSocketHandler provides WebSocket support for real-time job updates. This is a placeholder implementation that needs to be completed.
func NewWebSocketHandler ¶
func NewWebSocketHandler(extension *cronext.Extension, logger forge.Logger) *WebSocketHandler
NewWebSocketHandler creates a new WebSocket handler. TODO: Implement full WebSocket support for real-time updates.
func (*WebSocketHandler) RegisterRoutes ¶
func (h *WebSocketHandler) RegisterRoutes(router forge.Router, prefix string)
RegisterRoutes registers WebSocket routes. TODO: Implement WebSocket endpoint for job execution updates.
Source Files