Documentation
¶
Index ¶
- func ValidateAlertsQueryRequest(req *gen.AlertsQueryRequest) error
- func ValidateAndSetLimit(limit *int) error
- func ValidateAndSetSortOrder(sortOrder *string) error
- func ValidateIncidentPutRequest(req *gen.IncidentPutRequest) error
- func ValidateIncidentsQueryRequest(req *gen.IncidentsQueryRequest) error
- func ValidateLogLevels(logLevels []string) error
- func ValidateLogsQueryRequest(req *types.LogsQueryRequest) error
- func ValidateMetricsQueryRequest(req *types.MetricsQueryRequest) error
- func ValidateTimeRange(startTime, endTime string) error
- func ValidateTracesQueryRequest(req *gen.TracesQueryRequest) error
- type Handler
- func (h *Handler) GetSpanDetailsForTrace(w http.ResponseWriter, r *http.Request)
- func (h *Handler) Health(w http.ResponseWriter, r *http.Request)
- func (h *Handler) QueryAlerts(w http.ResponseWriter, r *http.Request)
- func (h *Handler) QueryIncidents(w http.ResponseWriter, r *http.Request)
- func (h *Handler) QueryLogs(w http.ResponseWriter, r *http.Request)
- func (h *Handler) QueryMetrics(w http.ResponseWriter, r *http.Request)
- func (h *Handler) QuerySpansForTrace(w http.ResponseWriter, r *http.Request)
- func (h *Handler) QueryTraces(w http.ResponseWriter, r *http.Request)
- func (h *Handler) UpdateIncident(w http.ResponseWriter, r *http.Request)
- type InternalHandler
- func (h *InternalHandler) CreateAlertRule(w http.ResponseWriter, r *http.Request)
- func (h *InternalHandler) DeleteAlertRule(w http.ResponseWriter, r *http.Request)
- func (h *InternalHandler) GetAlertRule(w http.ResponseWriter, r *http.Request)
- func (h *InternalHandler) HandleAlertWebhook(w http.ResponseWriter, r *http.Request)
- func (h *InternalHandler) UpdateAlertRule(w http.ResponseWriter, r *http.Request)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ValidateAlertsQueryRequest ¶ added in v1.0.0
func ValidateAlertsQueryRequest(req *gen.AlertsQueryRequest) error
ValidateAlertsQueryRequest validates an alerts query request.
func ValidateAndSetLimit ¶
ValidateAndSetLimit validates and sets default for limit
func ValidateAndSetSortOrder ¶
ValidateAndSetSortOrder validates and sets default for sort order
func ValidateIncidentPutRequest ¶ added in v1.0.0
func ValidateIncidentPutRequest(req *gen.IncidentPutRequest) error
ValidateIncidentPutRequest validates an incident update (PUT) request.
func ValidateIncidentsQueryRequest ¶ added in v1.0.0
func ValidateIncidentsQueryRequest(req *gen.IncidentsQueryRequest) error
ValidateIncidentsQueryRequest validates an incidents query request.
func ValidateLogLevels ¶
ValidateLogLevels validates the log levels array
func ValidateLogsQueryRequest ¶
func ValidateLogsQueryRequest(req *types.LogsQueryRequest) error
ValidateLogsQueryRequest validates the LogsQueryRequest
func ValidateMetricsQueryRequest ¶
func ValidateMetricsQueryRequest(req *types.MetricsQueryRequest) error
ValidateMetricsQueryRequest validates the MetricsQueryRequest
func ValidateTimeRange ¶
ValidateTimeRange validates start and end time strings
func ValidateTracesQueryRequest ¶
func ValidateTracesQueryRequest(req *gen.TracesQueryRequest) error
ValidateTracesQueryRequest validates a traces query request
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler contains the HTTP handlers for the public observer API (v1/v1alpha1). Routes are JWT-protected. Authorization is enforced by the service layer — pass authz-wrapped services (e.g. NewAlertIncidentServiceWithAuthz) rather than bare service instances.
func NewHandler ¶
func NewHandler( healthService *service.HealthService, logsService service.LogsQuerier, metricsService service.MetricsQuerier, alertIncidentService service.AlertIncidentService, tracesService service.TracesQuerier, logger *slog.Logger, ) *Handler
NewHandler creates a new public Handler instance.
func (*Handler) GetSpanDetailsForTrace ¶
func (h *Handler) GetSpanDetailsForTrace(w http.ResponseWriter, r *http.Request)
GetSpanDetailsForTrace handles GET /api/v1alpha1/traces/{traceId}/spans/{spanId}
func (*Handler) Health ¶
func (h *Handler) Health(w http.ResponseWriter, r *http.Request)
Health handles GET /health
func (*Handler) QueryAlerts ¶ added in v1.0.0
func (h *Handler) QueryAlerts(w http.ResponseWriter, r *http.Request)
QueryAlerts handles POST /api/v1alpha1/alerts/query
func (*Handler) QueryIncidents ¶ added in v1.0.0
func (h *Handler) QueryIncidents(w http.ResponseWriter, r *http.Request)
QueryIncidents handles POST /api/v1alpha1/incidents/query
func (*Handler) QueryLogs ¶
func (h *Handler) QueryLogs(w http.ResponseWriter, r *http.Request)
QueryLogs handles POST /api/v1/logs/query
func (*Handler) QueryMetrics ¶
func (h *Handler) QueryMetrics(w http.ResponseWriter, r *http.Request)
QueryMetrics handles POST /api/v1/metrics/query
func (*Handler) QuerySpansForTrace ¶
func (h *Handler) QuerySpansForTrace(w http.ResponseWriter, r *http.Request)
QuerySpansForTrace handles POST /api/v1alpha1/traces/{traceId}/spans/query
func (*Handler) QueryTraces ¶
func (h *Handler) QueryTraces(w http.ResponseWriter, r *http.Request)
QueryTraces handles POST /api/v1alpha1/traces/query
func (*Handler) UpdateIncident ¶ added in v1.0.0
func (h *Handler) UpdateIncident(w http.ResponseWriter, r *http.Request)
UpdateIncident handles PUT /api/v1alpha1/incidents/{incidentId} Note: the incident ID is read from the path via r.PathValue to be compatible with http.ServeMux routing.
type InternalHandler ¶ added in v1.0.0
type InternalHandler struct {
// contains filtered or unexported fields
}
InternalHandler contains the HTTP handlers that run on the internal port (8081) without JWT authentication. Only the concrete *AlertService is needed here because these handlers manage alert rules and process incoming webhooks.
func NewInternalHandler ¶ added in v1.0.0
func NewInternalHandler( alertService *service.AlertService, logger *slog.Logger, ) *InternalHandler
NewInternalHandler creates a new InternalHandler instance.
func (*InternalHandler) CreateAlertRule ¶ added in v1.0.0
func (h *InternalHandler) CreateAlertRule(w http.ResponseWriter, r *http.Request)
CreateAlertRule handles POST /api/v1alpha1/alerts/sources/{sourceType}/rules
func (*InternalHandler) DeleteAlertRule ¶ added in v1.0.0
func (h *InternalHandler) DeleteAlertRule(w http.ResponseWriter, r *http.Request)
DeleteAlertRule handles DELETE /api/v1alpha1/alerts/sources/{sourceType}/rules/{ruleName}
func (*InternalHandler) GetAlertRule ¶ added in v1.0.0
func (h *InternalHandler) GetAlertRule(w http.ResponseWriter, r *http.Request)
GetAlertRule handles GET /api/v1alpha1/alerts/sources/{sourceType}/rules/{ruleName}
func (*InternalHandler) HandleAlertWebhook ¶ added in v1.0.0
func (h *InternalHandler) HandleAlertWebhook(w http.ResponseWriter, r *http.Request)
HandleAlertWebhook handles POST /api/v1alpha1/alerts/webhook
func (*InternalHandler) UpdateAlertRule ¶ added in v1.0.0
func (h *InternalHandler) UpdateAlertRule(w http.ResponseWriter, r *http.Request)
UpdateAlertRule handles PUT /api/v1alpha1/alerts/sources/{sourceType}/rules/{ruleName}
Source Files