server

type Agent struct {
	// AgentId Server-generated unique identifier
	AgentId *string `json:"agent_id,omitempty"`

	// Cost Relative cost weight for placement decisions
	Cost *AgentCost `json:"cost,omitempty"`

	// CreateTime Timestamp when the agent was first registered
	CreateTime *time.Time `json:"create_time,omitempty"`

	// Environment Environment label for the agent
	Environment *string `json:"environment,omitempty"`

	// HealthStatus Current health status of the agent
	HealthStatus *AgentHealthStatus `json:"health_status,omitempty"`

	// LastHeartbeat Timestamp of last heartbeat received
	LastHeartbeat *time.Time `json:"last_heartbeat,omitempty"`

	// Name Unique name of the agent
	Name *string `json:"name,omitempty"`

	// ServiceTypes List of service types this agent can provide
	ServiceTypes *[]string `json:"service_types,omitempty"`

	// TopicName NATS topic name for this agent
	TopicName *string `json:"topic_name,omitempty"`

	// UpdateTime Timestamp when the agent was last updated
	UpdateTime *time.Time `json:"update_time,omitempty"`
}

type AgentCost string

type AgentHealthStatus string

type AgentHeartbeat200JSONResponse Agent

type AgentHeartbeat400ApplicationProblemPlusJSONResponse Error

type AgentHeartbeat404ApplicationProblemPlusJSONResponse Error

type AgentHeartbeatJSONRequestBody = HeartbeatRequest

type AgentHeartbeatRequestObject struct {
	AgentId AgentIdPath `json:"agentId"`
	Body    *AgentHeartbeatJSONRequestBody
}

type AgentHeartbeatResponseObject interface {
	VisitAgentHeartbeatResponse(w http.ResponseWriter) error
}

type AgentHeartbeatdefaultApplicationProblemPlusJSONResponse struct {
	Body       Error
	StatusCode int
}

type AgentIdPath = string

type AgentList struct {
	Agents *[]Agent `json:"agents,omitempty"`

	// NextPageToken Token for retrieving the next page of results
	NextPageToken *string `json:"next_page_token,omitempty"`
}

type AgentRegistrationRequest struct {
	// Cost Relative cost weight for placement decisions
	Cost AgentRegistrationRequestCost `json:"cost"`

	// Environment Environment label for the agent
	Environment string `json:"environment"`

	// Name Unique name of the agent
	Name string `json:"name"`

	// ServiceTypes List of service types this agent can provide
	ServiceTypes []string `json:"service_types"`

	// TopicName NATS topic name for this agent (must start with dcm.agent.)
	TopicName string `json:"topic_name"`
}

type AgentRegistrationRequestCost string

type ChiServerOptions struct {
	BaseURL          string
	BaseRouter       chi.Router
	Middlewares      []MiddlewareFunc
	ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type CreateAgent200JSONResponse Agent

type CreateAgent201JSONResponse Agent

type CreateAgent400ApplicationProblemPlusJSONResponse Error

type CreateAgent409ApplicationProblemPlusJSONResponse Error

type CreateAgentJSONRequestBody = AgentRegistrationRequest

type CreateAgentRequestObject struct {
	Body *CreateAgentJSONRequestBody
}

type CreateAgentResponseObject interface {
	VisitCreateAgentResponse(w http.ResponseWriter) error
}

type CreateAgentdefaultApplicationProblemPlusJSONResponse struct {
	Body       Error
	StatusCode int
}

type Error struct {
	// Detail Human-readable explanation specific to this occurrence
	Detail *string `json:"detail,omitempty"`

	// Instance URI reference for this specific error occurrence
	Instance *string `json:"instance,omitempty"`

	// Status HTTP status code
	Status *int `json:"status,omitempty"`

	// Title Short human-readable summary of the problem
	Title string `json:"title"`

	// Type URI reference identifying the error type
	Type string `json:"type"`
}

type GetAgent200JSONResponse Agent

type GetAgent400ApplicationProblemPlusJSONResponse Error

type GetAgent404ApplicationProblemPlusJSONResponse Error

type GetAgentRequestObject struct {
	AgentId AgentIdPath `json:"agentId"`
}

type GetAgentResponseObject interface {
	VisitGetAgentResponse(w http.ResponseWriter) error
}

type GetAgentdefaultApplicationProblemPlusJSONResponse struct {
	Body       Error
	StatusCode int
}

type HeartbeatRequest struct {
	// ConsumerLag Number of unprocessed messages in the agent's NATS consumer
	ConsumerLag int64 `json:"consumer_lag"`

	// Timestamp Timestamp of this heartbeat (used for monotonicity check)
	Timestamp time.Time `json:"timestamp"`
}

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

type ListAgents200JSONResponse AgentList

type ListAgents400ApplicationProblemPlusJSONResponse Error

type ListAgentsParams struct {
	// HealthStatus Filter agents by health status
	HealthStatus *ListAgentsParamsHealthStatus `form:"health_status,omitempty" json:"health_status,omitempty"`

	// MaxPageSize Maximum number of results per page
	MaxPageSize *int `form:"max_page_size,omitempty" json:"max_page_size,omitempty"`

	// PageToken Token for pagination
	PageToken *string `form:"page_token,omitempty" json:"page_token,omitempty"`
}

type ListAgentsParamsHealthStatus string

type ListAgentsRequestObject struct {
	Params ListAgentsParams
}

type ListAgentsResponseObject interface {
	VisitListAgentsResponse(w http.ResponseWriter) error
}

type ListAgentsdefaultApplicationProblemPlusJSONResponse struct {
	Body       Error
	StatusCode int
}

type MiddlewareFunc func(http.Handler) http.Handler

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

type RequiredParamError struct {
	ParamName string
}

type ServerInterface interface {
	// List all agents
	// (GET /agents)
	ListAgents(w http.ResponseWriter, r *http.Request, params ListAgentsParams)
	// Register an agent
	// (POST /agents)
	CreateAgent(w http.ResponseWriter, r *http.Request)
	// Get an agent
	// (GET /agents/{agentId})
	GetAgent(w http.ResponseWriter, r *http.Request, agentId AgentIdPath)
	// Send agent heartbeat
	// (PUT /agents/{agentId}/heartbeat)
	AgentHeartbeat(w http.ResponseWriter, r *http.Request, agentId AgentIdPath)
}

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandlerFunc   func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictHTTPServerOptions struct {
	RequestErrorHandlerFunc  func(w http.ResponseWriter, r *http.Request, err error)
	ResponseErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictHandlerFunc func(ctx context.Context, w http.ResponseWriter, r *http.Request, request any) (any, error)

type StrictMiddlewareFunc func(f StrictHandlerFunc, operationID string) StrictHandlerFunc

type StrictServerInterface interface {
	// List all agents
	// (GET /agents)
	ListAgents(ctx context.Context, request ListAgentsRequestObject) (ListAgentsResponseObject, error)
	// Register an agent
	// (POST /agents)
	CreateAgent(ctx context.Context, request CreateAgentRequestObject) (CreateAgentResponseObject, error)
	// Get an agent
	// (GET /agents/{agentId})
	GetAgent(ctx context.Context, request GetAgentRequestObject) (GetAgentResponseObject, error)
	// Send agent heartbeat
	// (PUT /agents/{agentId}/heartbeat)
	AgentHeartbeat(ctx context.Context, request AgentHeartbeatRequestObject) (AgentHeartbeatResponseObject, error)
}

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

type Unimplemented struct{}

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}