generated

type ApiLimits struct {
	DefaultPageSize     int `json:"defaultPageSize"`
	MaximumLogLines     int `json:"maximumLogLines"`
	MaximumMetricPoints int `json:"maximumMetricPoints"`
	MaximumPageSize     int `json:"maximumPageSize"`
}

type Capabilities struct {
	ApiVersion string    `json:"apiVersion"`
	Limits     ApiLimits `json:"limits"`
	Operations []string  `json:"operations"`
}

type Condition struct {
	LastTransitionTime time.Time       `json:"lastTransitionTime"`
	Message            *string         `json:"message,omitempty"`
	ObservedGeneration int64           `json:"observedGeneration"`
	Reason             string          `json:"reason"`
	Status             ConditionStatus `json:"status"`
	Type               string          `json:"type"`
}

type ConditionStatus string

type Forbidden = Problem

type GetMonoVertexStatusParams struct {
	// IfNoneMatch ETag from an earlier response
	IfNoneMatch *IfNoneMatch `json:"If-None-Match,omitempty"`
}

type GetMonoVertexSummaryParams struct {
	// IfNoneMatch ETag from an earlier response
	IfNoneMatch *IfNoneMatch `json:"If-None-Match,omitempty"`
}

type GetPipelineVertexStatusParams struct {
	// IfNoneMatch ETag from an earlier response
	IfNoneMatch *IfNoneMatch `json:"If-None-Match,omitempty"`
}

type GetPipelineVertexSummaryParams struct {
	// IfNoneMatch ETag from an earlier response
	IfNoneMatch *IfNoneMatch `json:"If-None-Match,omitempty"`
}

type GinServerOptions struct {
	BaseURL      string
	Middlewares  []MiddlewareFunc
	ErrorHandler func(*gin.Context, error, int)
}

type Health struct {
	Message *string     `json:"message,omitempty"`
	Reason  *string     `json:"reason,omitempty"`
	State   HealthState `json:"state"`
}

type HealthState string

type IfNoneMatch = string

type InternalServerError = Problem

type MiddlewareFunc func(c *gin.Context)

type MonoVertex = string

type Namespace = string

type NotFound = Problem

type Pipeline = string

type Problem struct {
	Code       string       `json:"code"`
	Detail     string       `json:"detail"`
	Instance   string       `json:"instance"`
	Retryable  *bool        `json:"retryable,omitempty"`
	Status     int          `json:"status"`
	Title      string       `json:"title"`
	TraceId    *string      `json:"traceId,omitempty"`
	Type       string       `json:"type"`
	Violations *[]Violation `json:"violations,omitempty"`
}

type ReplicaStatus struct {
	Current      int64 `json:"current"`
	Desired      int64 `json:"desired"`
	Ready        int64 `json:"ready"`
	Updated      int64 `json:"updated"`
	UpdatedReady int64 `json:"updatedReady"`
}

type ServerInterface interface {
	// Get capabilities available to the current caller
	// (GET /capabilities)
	GetCapabilities(c *gin.Context)
	// Get detailed Kubernetes status for a MonoVertex
	// (GET /namespaces/{namespace}/mono-vertices/{monoVertex}/status)
	GetMonoVertexStatus(c *gin.Context, namespace Namespace, monoVertex MonoVertex, params GetMonoVertexStatusParams)
	// Get a compact MonoVertex summary
	// (GET /namespaces/{namespace}/mono-vertices/{monoVertex}/summary)
	GetMonoVertexSummary(c *gin.Context, namespace Namespace, monoVertex MonoVertex, params GetMonoVertexSummaryParams)
	// Get detailed Kubernetes status for a pipeline vertex
	// (GET /namespaces/{namespace}/pipelines/{pipeline}/vertices/{vertex}/status)
	GetPipelineVertexStatus(c *gin.Context, namespace Namespace, pipeline Pipeline, vertex Vertex, params GetPipelineVertexStatusParams)
	// Get a compact pipeline vertex summary
	// (GET /namespaces/{namespace}/pipelines/{pipeline}/vertices/{vertex}/summary)
	GetPipelineVertexSummary(c *gin.Context, namespace Namespace, pipeline Pipeline, vertex Vertex, params GetPipelineVertexSummaryParams)
}

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandler       func(*gin.Context, error, int)
}

type TargetKind string

type TargetRef struct {
	Kind      TargetKind `json:"kind"`
	Name      string     `json:"name"`
	Namespace string     `json:"namespace"`

	// Pipeline Pipeline name for Vertex targets; omitted for MonoVertex targets.
	Pipeline *string `json:"pipeline,omitempty"`
	Uid      string  `json:"uid"`
}

type Unauthorized = Problem

type ValidationFailed = Problem

type Vertex = string

type VertexStatus struct {
	Conditions   []Condition `json:"conditions"`
	DesiredPhase string      `json:"desiredPhase"`
	Generation   int64       `json:"generation"`
	Message      *string     `json:"message,omitempty"`

	// ObservedAt Latest condition-transition or scaling timestamp from CR status, not response generation time.
	ObservedAt         time.Time     `json:"observedAt"`
	ObservedGeneration int64         `json:"observedGeneration"`
	Phase              string        `json:"phase"`
	Reason             *string       `json:"reason,omitempty"`
	Ref                TargetRef     `json:"ref"`
	Replicas           ReplicaStatus `json:"replicas"`
	TruncatedFields    *[]string     `json:"truncatedFields,omitempty"`
}

type VertexSummary struct {
	Capabilities []string  `json:"capabilities"`
	CreatedAt    time.Time `json:"createdAt"`
	DesiredPhase string    `json:"desiredPhase"`
	Generation   int64     `json:"generation"`

	// Health Compact health derived from Kubernetes Vertex or MonoVertex CR status. It excludes live Pod inspection and data-flow health.
	Health       Health     `json:"health"`
	LastScaledAt *time.Time `json:"lastScaledAt,omitempty"`

	// ObservedAt Latest condition-transition or scaling timestamp from CR status, not response generation time.
	ObservedAt         time.Time  `json:"observedAt"`
	ObservedGeneration int64      `json:"observedGeneration"`
	Phase              string     `json:"phase"`
	Ref                TargetRef  `json:"ref"`
	TruncatedFields    *[]string  `json:"truncatedFields,omitempty"`
	VertexType         VertexType `json:"vertexType"`
}

type VertexType string

type Violation struct {
	AllowedValues *[]string `json:"allowedValues,omitempty"`
	Field         string    `json:"field"`
	Message       string    `json:"message"`
	Reason        string    `json:"reason"`
}