api

type APIKey struct {
	// CreatedAt Creation timestamp
	CreatedAt time.Time `json:"createdAt"`

	// CreatedBy Creator user ID
	CreatedBy string `json:"createdBy"`

	// Description Purpose description
	Description *string `json:"description,omitempty"`

	// Id Unique identifier
	Id string `json:"id"`

	// KeyPrefix First 8 characters for identification
	KeyPrefix string `json:"keyPrefix"`

	// LastUsedAt Last authentication timestamp
	LastUsedAt *time.Time `json:"lastUsedAt"`

	// Name Human-readable name
	Name string `json:"name"`

	// Role User role determining access permissions. admin: full access including user management, manager: DAG CRUD and execution, operator: DAG execution only, viewer: read-only
	Role UserRole `json:"role"`

	// UpdatedAt Last update timestamp
	UpdatedAt time.Time `json:"updatedAt"`
}

type APIKeyId = string

type APIKeyResponse struct {
	// ApiKey API key information
	ApiKey APIKey `json:"apiKey"`
}

type APIKeysListResponse struct {
	ApiKeys []APIKey `json:"apiKeys"`
}

type ApproveDAGRunStep200JSONResponse ApproveStepResponse

type ApproveDAGRunStep400JSONResponse Error

type ApproveDAGRunStep404JSONResponse Error

type ApproveDAGRunStepJSONRequestBody = ApproveStepRequest

type ApproveDAGRunStepParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type ApproveDAGRunStepRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	StepName StepName `json:"stepName"`
	Params   ApproveDAGRunStepParams
	Body     *ApproveDAGRunStepJSONRequestBody
}

type ApproveDAGRunStepResponseObject interface {
	VisitApproveDAGRunStepResponse(w http.ResponseWriter) error
}

type ApproveDAGRunStepdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type ApproveStepRequest struct {
	// Inputs Key-value parameters to provide. These will be available as environment variables in subsequent steps.
	Inputs *map[string]string `json:"inputs,omitempty"`
}

type ApproveStepResponse struct {
	// DagRunId The DAG run ID
	DagRunId string `json:"dagRunId"`

	// Resumed Whether the DAG run was re-enqueued for execution
	Resumed bool `json:"resumed"`

	// StepName The approved step name
	StepName string `json:"stepName"`
}

type ApproveSubDAGRunStep200JSONResponse ApproveStepResponse

type ApproveSubDAGRunStep400JSONResponse Error

type ApproveSubDAGRunStep404JSONResponse Error

type ApproveSubDAGRunStepJSONRequestBody = ApproveStepRequest

type ApproveSubDAGRunStepParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type ApproveSubDAGRunStepRequestObject struct {
	Name        DAGName  `json:"name"`
	DagRunId    DAGRunId `json:"dagRunId"`
	SubDAGRunId string   `json:"subDAGRunId"`
	StepName    StepName `json:"stepName"`
	Params      ApproveSubDAGRunStepParams
	Body        *ApproveSubDAGRunStepJSONRequestBody
}

type ApproveSubDAGRunStepResponseObject interface {
	VisitApproveSubDAGRunStepResponse(w http.ResponseWriter) error
}

type ApproveSubDAGRunStepdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type ChangePassword200JSONResponse SuccessResponse

type ChangePassword400JSONResponse Error

type ChangePassword401JSONResponse Error

type ChangePasswordJSONRequestBody = ChangePasswordRequest

type ChangePasswordRequest struct {
	// CurrentPassword Current password for verification
	CurrentPassword string `json:"currentPassword"`

	// NewPassword New password to set
	NewPassword string `json:"newPassword"`
}

type ChangePasswordRequestObject struct {
	Body *ChangePasswordJSONRequestBody
}

type ChangePasswordResponseObject interface {
	VisitChangePasswordResponse(w http.ResponseWriter) error
}

type ChangePassworddefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

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

type CommandEntry struct {
	// Args Arguments for the command
	Args *[]string `json:"args,omitempty"`

	// Command The command to execute
	Command string `json:"command"`
}

type Condition struct {
	// Condition Expression or check to evaluate
	Condition string `json:"condition"`

	// Error Error message if the condition is not met
	Error *string `json:"error,omitempty"`

	// Expected Expected result of the condition evaluation
	Expected *string `json:"expected,omitempty"`

	// Matched Whether the condition was met
	Matched *bool `json:"matched,omitempty"`

	// Negate If true, inverts the condition result (run when condition does NOT match)
	Negate *bool `json:"negate,omitempty"`
}

type CoordinatorInstance struct {
	// Host Hostname where coordinator is running
	Host string `json:"host"`

	// InstanceId Unique identifier of the coordinator instance
	InstanceId string `json:"instanceId"`

	// Port Port number the coordinator is listening on
	Port int `json:"port"`

	// StartedAt RFC3339 timestamp when coordinator started
	StartedAt string `json:"startedAt"`

	// Status Coordinator status
	Status CoordinatorInstanceStatus `json:"status"`
}

type CoordinatorInstanceStatus string

type CoordinatorStatusResponse struct {
	// Coordinators List of all registered coordinator instances
	Coordinators []CoordinatorInstance `json:"coordinators"`
}

type CreateAPIKey201JSONResponse CreateAPIKeyResponse

type CreateAPIKey400JSONResponse Error

type CreateAPIKey401JSONResponse Error

type CreateAPIKey403JSONResponse Error

type CreateAPIKey409JSONResponse Error

type CreateAPIKeyJSONRequestBody = CreateAPIKeyRequest

type CreateAPIKeyRequest struct {
	// Description Purpose description
	Description *string `json:"description,omitempty"`

	// Name Human-readable name
	Name string `json:"name"`

	// Role User role determining access permissions. admin: full access including user management, manager: DAG CRUD and execution, operator: DAG execution only, viewer: read-only
	Role UserRole `json:"role"`
}

type CreateAPIKeyRequestObject struct {
	Body *CreateAPIKeyJSONRequestBody
}

type CreateAPIKeyResponse struct {
	// ApiKey API key information
	ApiKey APIKey `json:"apiKey"`

	// Key Full key secret, only returned once
	Key string `json:"key"`
}

type CreateAPIKeyResponseObject interface {
	VisitCreateAPIKeyResponse(w http.ResponseWriter) error
}

type CreateAPIKeydefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type CreateDAGWebhook201JSONResponse WebhookCreateResponse

type CreateDAGWebhook409JSONResponse Error

type CreateDAGWebhookParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type CreateDAGWebhookRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   CreateDAGWebhookParams
}

type CreateDAGWebhookResponseObject interface {
	VisitCreateDAGWebhookResponse(w http.ResponseWriter) error
}

type CreateDAGWebhookdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type CreateNewDAG201JSONResponse struct {
	// Name Name of the newly created DAG
	Name string `json:"name"`
}

type CreateNewDAG400JSONResponse Error

type CreateNewDAGJSONBody struct {
	// Name Name of the DAG
	Name DAGName `json:"name"`

	// Spec Optional DAG spec in YAML format to initialize the DAG. If provided, the spec will be validated before creation.
	Spec *string `json:"spec,omitempty"`
}

type CreateNewDAGJSONRequestBody CreateNewDAGJSONBody

type CreateNewDAGParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type CreateNewDAGRequestObject struct {
	Params CreateNewDAGParams
	Body   *CreateNewDAGJSONRequestBody
}

type CreateNewDAGResponseObject interface {
	VisitCreateNewDAGResponse(w http.ResponseWriter) error
}

type CreateNewDAGdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type CreateUser201JSONResponse UserResponse

type CreateUser400JSONResponse Error

type CreateUser401JSONResponse Error

type CreateUser403JSONResponse Error

type CreateUser409JSONResponse Error

type CreateUserJSONRequestBody = CreateUserRequest

type CreateUserRequest struct {
	// Password User's password
	Password string `json:"password"`

	// Role User role determining access permissions. admin: full access including user management, manager: DAG CRUD and execution, operator: DAG execution only, viewer: read-only
	Role UserRole `json:"role"`

	// Username Unique username
	Username string `json:"username"`
}

type CreateUserRequestObject struct {
	Body *CreateUserJSONRequestBody
}

type CreateUserResponseObject interface {
	VisitCreateUserResponse(w http.ResponseWriter) error
}

type CreateUserdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type DAG struct {
	// DefaultParams Default parameter values in JSON format if not specified at DAG-run creation
	DefaultParams *string `json:"defaultParams,omitempty"`

	// Description Human-readable description of the DAG's purpose and behavior
	Description *string `json:"description,omitempty"`

	// Group Logical grouping of related DAGs for organizational purposes
	Group *string `json:"group,omitempty"`

	// MaxActiveRuns Maximum number of concurrent DAG-runs allowed from this DAG
	MaxActiveRuns *int `json:"maxActiveRuns,omitempty"`

	// Name Logical name of the DAG
	Name string `json:"name"`

	// Params List of parameter names that can be passed to DAG-runs created from this DAG
	Params *[]string `json:"params,omitempty"`

	// Queue Name of the queue this DAG is assigned to. If not specified, the DAG name itself becomes the queue name
	Queue *string `json:"queue,omitempty"`

	// RunConfig Configuration for controlling user interactions when starting DAG runs
	RunConfig *RunConfig `json:"runConfig,omitempty"`

	// Schedule List of scheduling expressions defining when DAG-runs should be created from this DAG
	Schedule *[]Schedule `json:"schedule,omitempty"`

	// Tags List of tags for categorizing and filtering DAGs
	Tags *[]string `json:"tags,omitempty"`
}

type DAGDetails struct {
	// DefaultParams Default parameter values in JSON format if not specified at DAG-run creation
	DefaultParams *string `json:"defaultParams,omitempty"`

	// Delay Time in seconds to wait before starting a DAG-run
	Delay *int `json:"delay,omitempty"`

	// Description Human-readable description of the DAG's purpose and behavior
	Description *string `json:"description,omitempty"`

	// Env List of environment variables to set before executing a DAG-run
	Env *[]string `json:"env,omitempty"`

	// Group Logical grouping of related DAGs for organizational purposes
	Group *string `json:"group,omitempty"`

	// HandlerOn Configuration for event handlers in a DAG-run
	HandlerOn *HandlerOn `json:"handlerOn,omitempty"`

	// HistRetentionDays Number of days to retain historical logs
	HistRetentionDays *int `json:"histRetentionDays,omitempty"`

	// LogDir Directory path for storing log files
	LogDir *string `json:"logDir,omitempty"`

	// MaxActiveRuns Maximum number of concurrent DAG-runs allowed from this DAG
	MaxActiveRuns *int `json:"maxActiveRuns,omitempty"`

	// MaxActiveSteps Maximum number of concurrent steps allowed in a DAG run
	MaxActiveSteps *int `json:"maxActiveSteps,omitempty"`

	// Name Unique identifier for the DAG within its group
	Name string `json:"name"`

	// Params List of parameter names that can be passed to DAG-runs created from this DAG
	Params *[]string `json:"params,omitempty"`

	// Preconditions Conditions that must be met before a DAG-run can start
	Preconditions *[]Condition `json:"preconditions,omitempty"`

	// Queue Name of the queue this DAG is assigned to. If not specified, the DAG name itself becomes the queue name
	Queue *string `json:"queue,omitempty"`

	// RunConfig Configuration for controlling user interactions when starting DAG runs
	RunConfig *RunConfig `json:"runConfig,omitempty"`

	// Schedule List of scheduling expressions defining when DAG-runs should be created from this DAG
	Schedule *[]Schedule `json:"schedule,omitempty"`

	// Steps List of steps to execute in DAG-runs created from this DAG
	Steps *[]Step `json:"steps,omitempty"`

	// Tags List of tags for categorizing and filtering DAGs
	Tags *[]string `json:"tags,omitempty"`
}

type DAGFile struct {
	// Dag Core DAG configuration containing definition and metadata
	Dag DAG `json:"dag"`

	// Errors List of errors encountered during the request
	Errors []string `json:"errors"`

	// FileName File ID of the DAG file
	FileName string `json:"fileName"`

	// LatestDAGRun Current status of a DAG-run
	LatestDAGRun DAGRunSummary `json:"latestDAGRun"`

	// Suspended Whether the DAG is suspended
	Suspended bool `json:"suspended"`
}

type DAGFileName = string

type DAGGridItem struct {
	// History Status of the step ordered by time
	History []NodeStatus `json:"history"`

	// Name Name of the step
	Name string `json:"name"`
}

type DAGName = string

type DAGRunDetails struct {
	// DagRunId Unique identifier for the DAG-run. The special value 'latest' can be used to reference the most recent DAG-run.
	DagRunId DAGRunId `json:"dagRunId"`

	// FinishedAt RFC 3339 timestamp when the DAG-run finished
	FinishedAt string `json:"finishedAt"`

	// Log Path to the log file
	Log string `json:"log"`

	// Name Name of the DAG
	Name DAGName `json:"name"`

	// Nodes Status of individual steps within the DAG-run
	Nodes []Node `json:"nodes"`

	// OnCancel Status of an individual step within a DAG-run
	OnCancel *Node `json:"onCancel,omitempty"`

	// OnExit Status of an individual step within a DAG-run
	OnExit *Node `json:"onExit,omitempty"`

	// OnFailure Status of an individual step within a DAG-run
	OnFailure *Node `json:"onFailure,omitempty"`

	// OnSuccess Status of an individual step within a DAG-run
	OnSuccess *Node `json:"onSuccess,omitempty"`

	// Params Runtime parameters passed to the DAG-run in JSON format
	Params         *string `json:"params,omitempty"`
	ParentDAGRunId *string `json:"parentDAGRunId,omitempty"`

	// ParentDAGRunName Name of the parent DAG-run
	ParentDAGRunName *string `json:"parentDAGRunName,omitempty"`

	// Preconditions List of preconditions that must be met before the DAG-run can start
	Preconditions *[]Condition `json:"preconditions,omitempty"`

	// QueuedAt RFC 3339 timestamp when the DAG-run was queued
	QueuedAt     *string `json:"queuedAt,omitempty"`
	RootDAGRunId string  `json:"rootDAGRunId"`

	// RootDAGRunName Name of the root DAG-run
	RootDAGRunName string `json:"rootDAGRunName"`

	// StartedAt RFC 3339 timestamp when the DAG-run started
	StartedAt string `json:"startedAt"`

	// Status Numeric status code indicating current DAG-run state:
	// 0: "Not started"
	// 1: "Running"
	// 2: "Failed"
	// 3: "Aborted"
	// 4: "Success"
	// 5: "Queued"
	// 6: "Partial Success"
	// 7: "Waiting for approval"
	// 8: "Rejected"
	Status Status `json:"status"`

	// StatusLabel Human-readable status description for the DAG-run
	StatusLabel StatusLabel `json:"statusLabel"`

	// WorkerId ID of the worker that executed this DAG-run ('local' for local execution)
	WorkerId *string `json:"workerId,omitempty"`
}

type DAGRunId = string

type DAGRunIdSearch = DAGRunId

type DAGRunName = string

type DAGRunOutputs struct {
	// Metadata Execution context metadata for the outputs
	Metadata OutputsMetadata `json:"metadata"`

	// Outputs Collected step outputs as key-value pairs. Keys are output names (UPPER_CASE converted to camelCase by default, or custom key if specified) and values are the captured output strings. Empty object if no outputs were captured.
	Outputs map[string]string `json:"outputs"`
}

type DAGRunSummary struct {
	// DagRunId Unique identifier for the DAG-run. The special value 'latest' can be used to reference the most recent DAG-run.
	DagRunId DAGRunId `json:"dagRunId"`

	// FinishedAt RFC 3339 timestamp when the DAG-run finished
	FinishedAt string `json:"finishedAt"`

	// Log Path to the log file
	Log string `json:"log"`

	// Name Name of the DAG
	Name DAGName `json:"name"`

	// Params Runtime parameters passed to the DAG-run in JSON format
	Params         *string `json:"params,omitempty"`
	ParentDAGRunId *string `json:"parentDAGRunId,omitempty"`

	// ParentDAGRunName Name of the parent DAG-run
	ParentDAGRunName *string `json:"parentDAGRunName,omitempty"`

	// QueuedAt RFC 3339 timestamp when the DAG-run was queued
	QueuedAt     *string `json:"queuedAt,omitempty"`
	RootDAGRunId string  `json:"rootDAGRunId"`

	// RootDAGRunName Name of the root DAG-run
	RootDAGRunName string `json:"rootDAGRunName"`

	// StartedAt RFC 3339 timestamp when the DAG-run started
	StartedAt string `json:"startedAt"`

	// Status Numeric status code indicating current DAG-run state:
	// 0: "Not started"
	// 1: "Running"
	// 2: "Failed"
	// 3: "Aborted"
	// 4: "Success"
	// 5: "Queued"
	// 6: "Partial Success"
	// 7: "Waiting for approval"
	// 8: "Rejected"
	Status Status `json:"status"`

	// StatusLabel Human-readable status description for the DAG-run
	StatusLabel StatusLabel `json:"statusLabel"`

	// WorkerId ID of the worker that executed this DAG-run ('local' for local execution)
	WorkerId *string `json:"workerId,omitempty"`
}

type DateTimeFrom = UnixTimestamp

type DateTimeTo = UnixTimestamp

type DeleteAPIKey204Response struct {
}

type DeleteAPIKey401JSONResponse Error

type DeleteAPIKey403JSONResponse Error

type DeleteAPIKey404JSONResponse Error

type DeleteAPIKeyRequestObject struct {
	KeyId APIKeyId `json:"keyId"`
}

type DeleteAPIKeyResponseObject interface {
	VisitDeleteAPIKeyResponse(w http.ResponseWriter) error
}

type DeleteAPIKeydefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type DeleteDAG204Response struct {
}

type DeleteDAG404JSONResponse Error

type DeleteDAGParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type DeleteDAGRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   DeleteDAGParams
}

type DeleteDAGResponseObject interface {
	VisitDeleteDAGResponse(w http.ResponseWriter) error
}

type DeleteDAGWebhook204Response struct {
}

type DeleteDAGWebhook404JSONResponse Error

type DeleteDAGWebhookParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type DeleteDAGWebhookRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   DeleteDAGWebhookParams
}

type DeleteDAGWebhookResponseObject interface {
	VisitDeleteDAGWebhookResponse(w http.ResponseWriter) error
}

type DeleteDAGWebhookdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type DeleteDAGdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type DeleteUser204Response struct {
}

type DeleteUser401JSONResponse Error

type DeleteUser403JSONResponse Error

type DeleteUser404JSONResponse Error

type DeleteUserRequestObject struct {
	UserId UserId `json:"userId"`
}

type DeleteUserResponseObject interface {
	VisitDeleteUserResponse(w http.ResponseWriter) error
}

type DeleteUserdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type DequeueDAGRun200Response struct {
}

type DequeueDAGRun404JSONResponse Error

type DequeueDAGRunParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type DequeueDAGRunRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	Params   DequeueDAGRunParams
}

type DequeueDAGRunResponseObject interface {
	VisitDequeueDAGRunResponse(w http.ResponseWriter) error
}

type DequeueDAGRundefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type EnqueueDAGDAGRun200JSONResponse struct {
	// DagRunId Unique identifier for the DAG-run. The special value 'latest' can be used to reference the most recent DAG-run.
	DagRunId DAGRunId `json:"dagRunId"`
}

type EnqueueDAGDAGRun409JSONResponse Error

type EnqueueDAGDAGRunJSONBody struct {
	// DagName Optional DAG name override to use for the queued dag-run
	DagName  *string `json:"dagName,omitempty"`
	DagRunId *string `json:"dagRunId,omitempty"`

	// Params Parameters to pass to the DAG-run in JSON format
	Params *string `json:"params,omitempty"`

	// Queue Override the DAG-level queue definition
	Queue *string `json:"queue,omitempty"`

	// Singleton If true, prevent enqueuing if DAG is already running or queued (returns 409 conflict)
	Singleton *bool `json:"singleton,omitempty"`
}

type EnqueueDAGDAGRunJSONRequestBody EnqueueDAGDAGRunJSONBody

type EnqueueDAGDAGRunParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type EnqueueDAGDAGRunRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   EnqueueDAGDAGRunParams
	Body     *EnqueueDAGDAGRunJSONRequestBody
}

type EnqueueDAGDAGRunResponseObject interface {
	VisitEnqueueDAGDAGRunResponse(w http.ResponseWriter) error
}

type EnqueueDAGDAGRundefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type EnqueueDAGRunFromSpec200JSONResponse struct {
	// DagRunId Unique identifier for the DAG-run. The special value 'latest' can be used to reference the most recent DAG-run.
	DagRunId DAGRunId `json:"dagRunId"`
}

type EnqueueDAGRunFromSpec400JSONResponse Error

type EnqueueDAGRunFromSpec409JSONResponse Error

type EnqueueDAGRunFromSpecJSONBody struct {
	DagRunId *string `json:"dagRunId,omitempty"`

	// Name Optional name to use when the spec omits a name
	Name *string `json:"name,omitempty"`

	// Params Parameters to persist with the queued DAG-run in JSON format
	Params *string `json:"params,omitempty"`

	// Queue Override the queue to use for this DAG-run
	Queue *string `json:"queue,omitempty"`

	// Spec DAG specification in YAML format
	Spec string `json:"spec"`
}

type EnqueueDAGRunFromSpecJSONRequestBody EnqueueDAGRunFromSpecJSONBody

type EnqueueDAGRunFromSpecParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type EnqueueDAGRunFromSpecRequestObject struct {
	Params EnqueueDAGRunFromSpecParams
	Body   *EnqueueDAGRunFromSpecJSONRequestBody
}

type EnqueueDAGRunFromSpecResponseObject interface {
	VisitEnqueueDAGRunFromSpecResponse(w http.ResponseWriter) error
}

type EnqueueDAGRunFromSpecdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type Error struct {
	// Code Error code indicating the type of error
	Code ErrorCode `json:"code"`

	// Details Additional error details
	Details *map[string]interface{} `json:"details,omitempty"`

	// Message Short error message
	Message string `json:"message"`
}

type ErrorCode string

type ExecuteDAG200JSONResponse struct {
	// DagRunId Unique identifier for the DAG-run. The special value 'latest' can be used to reference the most recent DAG-run.
	DagRunId DAGRunId `json:"dagRunId"`
}

type ExecuteDAG409JSONResponse Error

type ExecuteDAGJSONBody struct {
	// DagName Optional DAG name override to use for the created dag-run
	DagName  *string `json:"dagName,omitempty"`
	DagRunId *string `json:"dagRunId,omitempty"`

	// Params Parameters to pass to the DAG-run in JSON format
	Params *string `json:"params,omitempty"`

	// Singleton If true, prevent starting if DAG is already running (returns 409 conflict)
	Singleton *bool `json:"singleton,omitempty"`
}

type ExecuteDAGJSONRequestBody ExecuteDAGJSONBody

type ExecuteDAGParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type ExecuteDAGRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   ExecuteDAGParams
	Body     *ExecuteDAGJSONRequestBody
}

type ExecuteDAGResponseObject interface {
	VisitExecuteDAGResponse(w http.ResponseWriter) error
}

type ExecuteDAGRunFromSpec200JSONResponse struct {
	// DagRunId Unique identifier for the DAG-run. The special value 'latest' can be used to reference the most recent DAG-run.
	DagRunId DAGRunId `json:"dagRunId"`
}

type ExecuteDAGRunFromSpec400JSONResponse Error

type ExecuteDAGRunFromSpec409JSONResponse Error

type ExecuteDAGRunFromSpecJSONBody struct {
	DagRunId *string `json:"dagRunId,omitempty"`

	// Name Optional name to use when the spec omits a name
	Name *string `json:"name,omitempty"`

	// Params Parameters to pass to the DAG-run in JSON format
	Params *string `json:"params,omitempty"`

	// Singleton If true, prevent starting if a DAG with the same name is already running (returns 409)
	Singleton *bool `json:"singleton,omitempty"`

	// Spec DAG specification in YAML format
	Spec string `json:"spec"`
}

type ExecuteDAGRunFromSpecJSONRequestBody ExecuteDAGRunFromSpecJSONBody

type ExecuteDAGRunFromSpecParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type ExecuteDAGRunFromSpecRequestObject struct {
	Params ExecuteDAGRunFromSpecParams
	Body   *ExecuteDAGRunFromSpecJSONRequestBody
}

type ExecuteDAGRunFromSpecResponseObject interface {
	VisitExecuteDAGRunFromSpecResponse(w http.ResponseWriter) error
}

type ExecuteDAGRunFromSpecdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type ExecuteDAGdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetAPIKey200JSONResponse APIKeyResponse

type GetAPIKey401JSONResponse Error

type GetAPIKey403JSONResponse Error

type GetAPIKey404JSONResponse Error

type GetAPIKeyRequestObject struct {
	KeyId APIKeyId `json:"keyId"`
}

type GetAPIKeyResponseObject interface {
	VisitGetAPIKeyResponse(w http.ResponseWriter) error
}

type GetAPIKeydefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetAllDAGTags200JSONResponse ListTagResponse

type GetAllDAGTagsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetAllDAGTagsRequestObject struct {
	Params GetAllDAGTagsParams
}

type GetAllDAGTagsResponseObject interface {
	VisitGetAllDAGTagsResponse(w http.ResponseWriter) error
}

type GetAllDAGTagsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetCoordinatorStatus200JSONResponse CoordinatorStatusResponse

type GetCoordinatorStatusParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetCoordinatorStatusRequestObject struct {
	Params GetCoordinatorStatusParams
}

type GetCoordinatorStatusResponseObject interface {
	VisitGetCoordinatorStatusResponse(w http.ResponseWriter) error
}

type GetCoordinatorStatusdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetCurrentUser200JSONResponse UserResponse

type GetCurrentUser401JSONResponse Error

type GetCurrentUserRequestObject struct {
}

type GetCurrentUserResponseObject interface {
	VisitGetCurrentUserResponse(w http.ResponseWriter) error
}

type GetCurrentUserdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGDAGRunDetails200JSONResponse struct {
	// DagRun Detailed status of a DAG-run including sub DAG-run nodes
	DagRun DAGRunDetails `json:"dagRun"`
}

type GetDAGDAGRunDetailsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGDAGRunDetailsRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	DagRunId DAGRunId    `json:"dagRunId"`
	Params   GetDAGDAGRunDetailsParams
}

type GetDAGDAGRunDetailsResponseObject interface {
	VisitGetDAGDAGRunDetailsResponse(w http.ResponseWriter) error
}

type GetDAGDAGRunDetailsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGDAGRunHistory200JSONResponse struct {
	// DagRuns List of historical DAG-runs created from this DAG
	DagRuns []DAGRunDetails `json:"dagRuns"`

	// GridData Grid data for visualization
	GridData []DAGGridItem `json:"gridData"`
}

type GetDAGDAGRunHistoryParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGDAGRunHistoryRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   GetDAGDAGRunHistoryParams
}

type GetDAGDAGRunHistoryResponseObject interface {
	VisitGetDAGDAGRunHistoryResponse(w http.ResponseWriter) error
}

type GetDAGDAGRunHistorydefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGDetails200JSONResponse struct {
	// Dag Detailed DAG configuration information
	Dag *DAGDetails `json:"dag,omitempty"`

	// Errors List of errors encountered during the request
	Errors []string `json:"errors"`

	// LatestDAGRun Detailed status of a DAG-run including sub DAG-run nodes
	LatestDAGRun DAGRunDetails `json:"latestDAGRun"`

	// LocalDags List of local DAGs that are part of this DAG
	LocalDags []LocalDag `json:"localDags"`

	// Suspended Whether the DAG is suspended
	Suspended bool `json:"suspended"`
}

type GetDAGDetailsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGDetailsRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   GetDAGDetailsParams
}

type GetDAGDetailsResponseObject interface {
	VisitGetDAGDetailsResponse(w http.ResponseWriter) error
}

type GetDAGDetailsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGRunDetails200JSONResponse struct {
	// DagRunDetails Detailed status of a DAG-run including sub DAG-run nodes
	DagRunDetails DAGRunDetails `json:"dagRunDetails"`
}

type GetDAGRunDetails404JSONResponse Error

type GetDAGRunDetailsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGRunDetailsRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	Params   GetDAGRunDetailsParams
}

type GetDAGRunDetailsResponseObject interface {
	VisitGetDAGRunDetailsResponse(w http.ResponseWriter) error
}

type GetDAGRunDetailsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGRunLog200JSONResponse Log

type GetDAGRunLog404JSONResponse Error

type GetDAGRunLogParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`

	// Tail Number of lines to return from the end of the file
	Tail *Tail `form:"tail,omitempty" json:"tail,omitempty"`

	// Head Number of lines to return from the beginning of the file
	Head *Head `form:"head,omitempty" json:"head,omitempty"`

	// Offset Line number to start reading from (1-based)
	Offset *Offset `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit Maximum number of lines to return
	Limit *Limit `form:"limit,omitempty" json:"limit,omitempty"`
}

type GetDAGRunLogRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	Params   GetDAGRunLogParams
}

type GetDAGRunLogResponseObject interface {
	VisitGetDAGRunLogResponse(w http.ResponseWriter) error
}

type GetDAGRunLogdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGRunOutputs200JSONResponse DAGRunOutputs

type GetDAGRunOutputs404JSONResponse Error

type GetDAGRunOutputsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGRunOutputsRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	Params   GetDAGRunOutputsParams
}

type GetDAGRunOutputsResponseObject interface {
	VisitGetDAGRunOutputsResponse(w http.ResponseWriter) error
}

type GetDAGRunOutputsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGRunSpec200JSONResponse struct {
	// Spec The DAG spec in YAML format
	Spec string `json:"spec"`
}

type GetDAGRunSpec404JSONResponse Error

type GetDAGRunSpecParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGRunSpecRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	Params   GetDAGRunSpecParams
}

type GetDAGRunSpecResponseObject interface {
	VisitGetDAGRunSpecResponse(w http.ResponseWriter) error
}

type GetDAGRunSpecdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGRunStepLog200JSONResponse Log

type GetDAGRunStepLog404JSONResponse Error

type GetDAGRunStepLogParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`

	// Tail Number of lines to return from the end of the file
	Tail *Tail `form:"tail,omitempty" json:"tail,omitempty"`

	// Head Number of lines to return from the beginning of the file
	Head *Head `form:"head,omitempty" json:"head,omitempty"`

	// Offset Line number to start reading from (1-based)
	Offset *Offset `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit Maximum number of lines to return
	Limit *Limit `form:"limit,omitempty" json:"limit,omitempty"`

	// Stream Whether to return stdout or stderr logs
	Stream *Stream `form:"stream,omitempty" json:"stream,omitempty"`
}

type GetDAGRunStepLogRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	StepName StepName `json:"stepName"`
	Params   GetDAGRunStepLogParams
}

type GetDAGRunStepLogResponseObject interface {
	VisitGetDAGRunStepLogResponse(w http.ResponseWriter) error
}

type GetDAGRunStepLogdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGSpec200JSONResponse struct {
	// Dag Detailed DAG configuration information
	Dag *DAGDetails `json:"dag,omitempty"`

	// Errors List of errors in the spec
	Errors []string `json:"errors"`

	// Spec The DAG spec in YAML format
	Spec string `json:"spec"`
}

type GetDAGSpecParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGSpecRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   GetDAGSpecParams
}

type GetDAGSpecResponseObject interface {
	VisitGetDAGSpecResponse(w http.ResponseWriter) error
}

type GetDAGSpecdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetDAGWebhook200JSONResponse WebhookDetails

type GetDAGWebhook404JSONResponse Error

type GetDAGWebhookParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetDAGWebhookRequestObject struct {
	FileName DAGFileName `json:"fileName"`
	Params   GetDAGWebhookParams
}

type GetDAGWebhookResponseObject interface {
	VisitGetDAGWebhookResponse(w http.ResponseWriter) error
}

type GetDAGWebhookdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetHealthStatus200JSONResponse HealthResponse

type GetHealthStatusRequestObject struct {
}

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

type GetHealthStatusdefaultResponse struct {
	StatusCode int
}

type GetMetrics200TextResponse string

type GetMetricsRequestObject struct {
}

type GetMetricsResponseObject interface {
	VisitGetMetricsResponse(w http.ResponseWriter) error
}

type GetMetricsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetResourceHistory200JSONResponse ResourceHistory

type GetResourceHistoryParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`

	// Duration Duration of history to retrieve (e.g., 30m, 1h)
	Duration *string `form:"duration,omitempty" json:"duration,omitempty"`
}

type GetResourceHistoryRequestObject struct {
	Params GetResourceHistoryParams
}

type GetResourceHistoryResponseObject interface {
	VisitGetResourceHistoryResponse(w http.ResponseWriter) error
}

type GetResourceHistorydefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetSchedulerStatus200JSONResponse SchedulerStatusResponse

type GetSchedulerStatusParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetSchedulerStatusRequestObject struct {
	Params GetSchedulerStatusParams
}

type GetSchedulerStatusResponseObject interface {
	VisitGetSchedulerStatusResponse(w http.ResponseWriter) error
}

type GetSchedulerStatusdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetSubDAGRunDetails200JSONResponse struct {
	// DagRunDetails Detailed status of a DAG-run including sub DAG-run nodes
	DagRunDetails DAGRunDetails `json:"dagRunDetails"`
}

type GetSubDAGRunDetails404JSONResponse Error

type GetSubDAGRunDetailsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`
}

type GetSubDAGRunDetailsRequestObject struct {
	Name        DAGName  `json:"name"`
	DagRunId    DAGRunId `json:"dagRunId"`
	SubDAGRunId string   `json:"subDAGRunId"`
	Params      GetSubDAGRunDetailsParams
}

type GetSubDAGRunDetailsResponseObject interface {
	VisitGetSubDAGRunDetailsResponse(w http.ResponseWriter) error
}

type GetSubDAGRunDetailsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetSubDAGRunLog200JSONResponse Log

type GetSubDAGRunLog404JSONResponse Error

type GetSubDAGRunLogParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`

	// Tail Number of lines to return from the end of the file
	Tail *Tail `form:"tail,omitempty" json:"tail,omitempty"`

	// Head Number of lines to return from the beginning of the file
	Head *Head `form:"head,omitempty" json:"head,omitempty"`

	// Offset Line number to start reading from (1-based)
	Offset *Offset `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit Maximum number of lines to return
	Limit *Limit `form:"limit,omitempty" json:"limit,omitempty"`
}

type GetSubDAGRunLogRequestObject struct {
	Name        DAGName  `json:"name"`
	DagRunId    DAGRunId `json:"dagRunId"`
	SubDAGRunId string   `json:"subDAGRunId"`
	Params      GetSubDAGRunLogParams
}

type GetSubDAGRunLogResponseObject interface {
	VisitGetSubDAGRunLogResponse(w http.ResponseWriter) error
}

type GetSubDAGRunLogdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetSubDAGRunStepLog200JSONResponse Log

type GetSubDAGRunStepLog404JSONResponse Error

type GetSubDAGRunStepLogParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`

	// Tail Number of lines to return from the end of the file
	Tail *Tail `form:"tail,omitempty" json:"tail,omitempty"`

	// Head Number of lines to return from the beginning of the file
	Head *Head `form:"head,omitempty" json:"head,omitempty"`

	// Offset Line number to start reading from (1-based)
	Offset *Offset `form:"offset,omitempty" json:"offset,omitempty"`

	// Limit Maximum number of lines to return
	Limit *Limit `form:"limit,omitempty" json:"limit,omitempty"`

	// Stream Whether to return stdout or stderr logs
	Stream *Stream `form:"stream,omitempty" json:"stream,omitempty"`
}

type GetSubDAGRunStepLogRequestObject struct {
	Name        DAGName  `json:"name"`
	DagRunId    DAGRunId `json:"dagRunId"`
	SubDAGRunId string   `json:"subDAGRunId"`
	StepName    StepName `json:"stepName"`
	Params      GetSubDAGRunStepLogParams
}

type GetSubDAGRunStepLogResponseObject interface {
	VisitGetSubDAGRunStepLogResponse(w http.ResponseWriter) error
}

type GetSubDAGRunStepLogdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetSubDAGRuns200JSONResponse struct {
	SubRuns []SubDAGRunDetail `json:"subRuns"`
}

type GetSubDAGRuns404JSONResponse Error

type GetSubDAGRunsParams struct {
	// RemoteNode name of the remote node
	RemoteNode *RemoteNode `form:"remoteNode,omitempty" json:"remoteNode,omitempty"`

	// ParentSubDAGRunId Optional parent sub DAG run ID. When provided, returns sub-runs of this specific sub DAG run instead of the root DAG run. Used for multi-level nested DAGs.
	ParentSubDAGRunId *string `form:"parentSubDAGRunId,omitempty" json:"parentSubDAGRunId,omitempty"`
}

type GetSubDAGRunsRequestObject struct {
	Name     DAGName  `json:"name"`
	DagRunId DAGRunId `json:"dagRunId"`
	Params   GetSubDAGRunsParams
}

type GetSubDAGRunsResponseObject interface {
	VisitGetSubDAGRunsResponse(w http.ResponseWriter) error
}