Documentation
¶
Index ¶
- Constants
- func WriteProblem(c *gin.Context, status int, code, title, detail string, ...)
- type CapabilitiesService
- type Handler
- func (h *Handler) GetCapabilities(c *gin.Context)
- func (h *Handler) GetMonoVertexStatus(c *gin.Context, namespace generated.Namespace, monoVertex generated.MonoVertex, ...)
- func (h *Handler) GetMonoVertexSummary(c *gin.Context, namespace generated.Namespace, monoVertex generated.MonoVertex, ...)
- func (h *Handler) GetPipelineVertexStatus(c *gin.Context, namespace generated.Namespace, pipeline generated.Pipeline, ...)
- func (h *Handler) GetPipelineVertexSummary(c *gin.Context, namespace generated.Namespace, pipeline generated.Pipeline, ...)
- type ObservabilityService
Constants ¶
const RequestIDHeader = "X-Request-ID"
RequestIDHeader carries a caller-provided trace identifier into a Problem response.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CapabilitiesService ¶
type CapabilitiesService interface {
GetCapabilities() capabilities.Capabilities
}
CapabilitiesService provides transport-independent API v2 discovery data.
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler adapts API v2 application services to HTTP handlers.
func NewClusterHandler ¶
NewClusterHandler assembles the API v2 handler from server capabilities and observability.
func NewHandler ¶
func NewHandler(capabilitiesService CapabilitiesService, observabilityService ObservabilityService) (*Handler, error)
NewHandler builds the API v2 HTTP adapter from discovery and observability services.
func (*Handler) GetCapabilities ¶
GetCapabilities returns the API v2 discovery document for the current server.
func (*Handler) GetMonoVertexStatus ¶
func (h *Handler) GetMonoVertexStatus(c *gin.Context, namespace generated.Namespace, monoVertex generated.MonoVertex, params generated.GetMonoVertexStatusParams)
GetMonoVertexStatus returns bounded Kubernetes MonoVertex CR status.
func (*Handler) GetMonoVertexSummary ¶
func (h *Handler) GetMonoVertexSummary(c *gin.Context, namespace generated.Namespace, monoVertex generated.MonoVertex, params generated.GetMonoVertexSummaryParams)
GetMonoVertexSummary returns a compact Kubernetes MonoVertex CR projection.
func (*Handler) GetPipelineVertexStatus ¶
func (h *Handler) GetPipelineVertexStatus(c *gin.Context, namespace generated.Namespace, pipeline generated.Pipeline, vertex generated.Vertex, params generated.GetPipelineVertexStatusParams)
GetPipelineVertexStatus returns bounded Kubernetes Vertex CR status for one pipeline vertex.
func (*Handler) GetPipelineVertexSummary ¶
func (h *Handler) GetPipelineVertexSummary(c *gin.Context, namespace generated.Namespace, pipeline generated.Pipeline, vertex generated.Vertex, params generated.GetPipelineVertexSummaryParams)
GetPipelineVertexSummary returns a compact Kubernetes Vertex CR projection.
type ObservabilityService ¶
type ObservabilityService interface {
GetPipelineVertexSummary(ctx context.Context, namespace, pipeline, vertex string) (observability.Result[observability.VertexSummary], error)
GetPipelineVertexStatus(ctx context.Context, namespace, pipeline, vertex string) (observability.Result[observability.VertexStatus], error)
GetMonoVertexSummary(ctx context.Context, namespace, monoVertex string) (observability.Result[observability.VertexSummary], error)
GetMonoVertexStatus(ctx context.Context, namespace, monoVertex string) (observability.Result[observability.VertexStatus], error)
}
ObservabilityService serves Kubernetes-backed Vertex and MonoVertex observability reads.
Source Files
Directories