gen

type AgentDetail struct {
	// Hostname Agent hostname.
	Hostname string `json:"hostname"`

	// Labels Formatted label string.
	Labels *string `json:"labels,omitempty"`

	// Registered Time since last heartbeat registration.
	Registered string `json:"registered"`
}

type AgentStats struct {
	// Agents Per-agent registration details.
	Agents *[]AgentDetail `json:"agents,omitempty"`

	// Ready Number of agents with Ready status.
	Ready int `json:"ready"`

	// Total Total number of registered agents.
	Total int `json:"total"`
}

type ComponentEntry struct {
	// Age Time since component started.
	Age *string `json:"age,omitempty"`

	// Conditions Active conditions.
	Conditions *[]string `json:"conditions,omitempty"`

	// CpuPercent Process CPU usage percentage.
	CpuPercent *float32 `json:"cpu_percent,omitempty"`

	// Hostname Component hostname.
	Hostname *string `json:"hostname,omitempty"`

	// MemBytes Process RSS memory in bytes.
	MemBytes *int64 `json:"mem_bytes,omitempty"`

	// Status Component status.
	Status *string `json:"status,omitempty"`

	// Type Component type (agent, api, nats).
	Type *string `json:"type,omitempty"`
}

type ComponentHealth struct {
	// Address Listen address of the component (if applicable).
	Address *string `json:"address,omitempty"`

	// Error Error message when component is unhealthy.
	Error *string `json:"error,omitempty"`

	// Status Component health status.
	Status string `json:"status"`
}

type ConsumerDetail struct {
	// AckPending Messages delivered but not yet acknowledged.
	AckPending int `json:"ack_pending"`

	// Name Consumer name.
	Name string `json:"name"`

	// Pending Messages not yet delivered.
	Pending int `json:"pending"`

	// Redelivered Messages redelivered and not yet acknowledged.
	Redelivered int `json:"redelivered"`
}

type ConsumerStats struct {
	// Consumers Per-consumer details.
	Consumers *[]ConsumerDetail `json:"consumers,omitempty"`

	// Total Total number of JetStream consumers.
	Total int `json:"total"`
}

type EchoRouter interface {
	CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
}

type ErrorResponse = externalRef0.ErrorResponse

type GetHealth200JSONResponse HealthResponse

type GetHealthReady200JSONResponse ReadyResponse

type GetHealthReady503JSONResponse ReadyResponse

type GetHealthReadyRequestObject struct {
}

type GetHealthReadyResponseObject interface {
	VisitGetHealthReadyResponse(w http.ResponseWriter) error
}

type GetHealthRequestObject struct {
}

type GetHealthResponseObject interface {
	VisitGetHealthResponse(w http.ResponseWriter) error
}

type GetHealthStatus200JSONResponse StatusResponse

type GetHealthStatus401JSONResponse externalRef0.ErrorResponse

type GetHealthStatus403JSONResponse externalRef0.ErrorResponse

type GetHealthStatus503JSONResponse StatusResponse

type GetHealthStatusRequestObject struct {
}

type GetHealthStatusResponseObject interface {
	VisitGetHealthStatusResponse(w http.ResponseWriter) error
}

type HealthResponse struct {
	// Status Health status.
	Status string `json:"status"`
}

type JobStats struct {
	// Completed Number of completed jobs.
	Completed int `json:"completed"`

	// Dlq Number of jobs in the dead letter queue.
	Dlq int `json:"dlq"`

	// Failed Number of failed jobs.
	Failed int `json:"failed"`

	// Processing Number of jobs currently processing.
	Processing int `json:"processing"`

	// Total Total number of jobs.
	Total int `json:"total"`

	// Unprocessed Number of unprocessed jobs.
	Unprocessed int `json:"unprocessed"`
}

type KVBucketInfo struct {
	// Bytes Total bytes in the bucket.
	Bytes int `json:"bytes"`

	// Keys Number of keys in the bucket.
	Keys int `json:"keys"`

	// Name KV bucket name.
	Name string `json:"name"`
}

type NATSInfo struct {
	// Url Connected NATS server URL.
	Url string `json:"url"`

	// Version NATS server version.
	Version string `json:"version"`
}

type ObjectStoreInfo struct {
	// Name Object Store bucket name.
	Name string `json:"name"`

	// Size Total bytes in the store.
	Size int `json:"size"`
}

type ReadyResponse struct {
	// Error Error message when not ready.
	Error *string `json:"error,omitempty"`

	// Status Readiness status.
	Status string `json:"status"`
}

type ServerInterface interface {
	// Liveness probe
	// (GET /api/health)
	GetHealth(ctx echo.Context) error
	// Readiness probe
	// (GET /api/health/ready)
	GetHealthReady(ctx echo.Context) error
	// System status and component health
	// (GET /api/health/status)
	GetHealthStatus(ctx echo.Context) error
}

type ServerInterfaceWrapper struct {
	Handler ServerInterface
}

type StatusResponse struct {
	Agents *AgentStats `json:"agents,omitempty"`

	// Components Per-component health status.
	Components map[string]ComponentHealth `json:"components"`
	Consumers  *ConsumerStats             `json:"consumers,omitempty"`
	Jobs       *JobStats                  `json:"jobs,omitempty"`

	// KvBuckets KV bucket statistics.
	KvBuckets *[]KVBucketInfo `json:"kv_buckets,omitempty"`
	Nats      *NATSInfo       `json:"nats,omitempty"`

	// ObjectStores Object Store statistics.
	ObjectStores *[]ObjectStoreInfo `json:"object_stores,omitempty"`

	// Registry All registered components with health details.
	Registry *[]ComponentEntry `json:"registry,omitempty"`

	// Status Overall health status.
	Status string `json:"status"`

	// Streams JetStream stream statistics.
	Streams *[]StreamInfo `json:"streams,omitempty"`

	// Uptime Time since server started.
	Uptime string `json:"uptime"`

	// Version Application version.
	Version string `json:"version"`
}

type StreamInfo struct {
	// Bytes Total bytes in the stream.
	Bytes int `json:"bytes"`

	// Consumers Number of consumers on the stream.
	Consumers int `json:"consumers"`

	// Messages Number of messages in the stream.
	Messages int `json:"messages"`

	// Name Stream name.
	Name string `json:"name"`
}

type StrictHandlerFunc = strictecho.StrictEchoHandlerFunc

type StrictMiddlewareFunc = strictecho.StrictEchoMiddlewareFunc

type StrictServerInterface interface {
	// Liveness probe
	// (GET /api/health)
	GetHealth(ctx context.Context, request GetHealthRequestObject) (GetHealthResponseObject, error)
	// Readiness probe
	// (GET /api/health/ready)
	GetHealthReady(ctx context.Context, request GetHealthReadyRequestObject) (GetHealthReadyResponseObject, error)
	// System status and component health
	// (GET /api/health/status)
	GetHealthStatus(ctx context.Context, request GetHealthStatusRequestObject) (GetHealthStatusResponseObject, error)
}