api

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

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

type CreateDAG400JSONResponse Error

type CreateDAGJSONBody struct {
	// Action Action to perform upon creation (if any)
	Action string `json:"action"`

	// Value Associated value for the action
	Value string `json:"value"`
}

type CreateDAGJSONRequestBody CreateDAGJSONBody

type CreateDAGRequestObject struct {
	Body *CreateDAGJSONRequestBody
}

type CreateDAGResponseObject interface {
	VisitCreateDAGResponse(w http.ResponseWriter) error
}

type CreateDAGdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type DAG struct {
	// DefaultParams Default parameter values in JSON format if not specified at runtime
	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"`

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

	// Params List of parameter names that can be passed to the DAG at runtime
	Params *[]string `json:"Params,omitempty"`

	// Schedule List of scheduling expressions defining when the DAG should run
	Schedule *[]Schedule `json:"Schedule,omitempty"`

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

type DAGAction string

type DAGDetailTab string

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

	// Delay Time in seconds to wait before starting the DAG
	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
	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
	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 steps to run
	MaxActiveRuns *int `json:"MaxActiveRuns,omitempty"`

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

	// Params List of parameter names that can be passed to the DAG at runtime
	Params *[]string `json:"Params,omitempty"`

	// Preconditions Conditions that must be met before the DAG can start
	Preconditions *[]Precondition `json:"Preconditions,omitempty"`

	// Schedule List of scheduling expressions defining when the DAG should run
	Schedule *[]Schedule `json:"Schedule,omitempty"`

	// Steps List of steps to execute in the DAG
	Steps *[]Step `json:"Steps,omitempty"`

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

type DAGHistoryData struct {
	// GridData Grid data for visualization
	GridData []DAGLogGridItem `json:"GridData"`

	// Logs Detailed status information for each run
	Logs []DAGLogStatusFile `json:"Logs"`
}

type DAGLogGridItem struct {
	// Name Name of the step
	Name string `json:"Name"`

	// Vals Status of the step ordered by time
	Vals []NodeStatus `json:"Vals"`
}

type DAGLogStatusFile struct {
	// File Path to the log file
	File string `json:"File"`

	// Status Detailed status of a dag-run including child nodes
	Status DAGStatusDetails `json:"Status"`
}

type DAGStatus struct {
	// FinishedAt RFC 3339 timestamp when the dag-run finished
	FinishedAt string `json:"FinishedAt"`

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

	// Name Name of the DAG being executed
	Name string `json:"Name"`

	// Params Runtime parameters passed to the DAG in JSON format
	Params *string `json:"Params,omitempty"`

	// RequestId Unique identifier for the dag-run request
	RequestId string `json:"RequestId"`

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

	// Status Numeric status code indicating current run state:
	// 0: "Not started"
	// 1: "Running"
	// 2: "Failed"
	// 3: "Aborted"
	// 4: "Success"
	// 6: "Partial Success"
	Status RunStatus `json:"Status"`

	// StatusText Human-readable status description for the dag-run
	StatusText RunStatusText `json:"StatusText"`
}

type DAGStatusDetails struct {
	// FinishedAt RFC3339 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 string `json:"Name"`

	// Nodes Status of individual steps within the DAG
	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 Parameters in JSON format
	Params *string `json:"Params,omitempty"`

	// RequestId Unique identifier for the run request
	RequestId string `json:"RequestId"`

	// StartedAt RFC3339 timestamp when the dag-run started
	StartedAt string `json:"StartedAt"`

	// Status Numeric status code indicating current run state:
	// 0: "Not started"
	// 1: "Running"
	// 2: "Failed"
	// 3: "Aborted"
	// 4: "Success"
	// 6: "Partial Success"
	Status RunStatus `json:"Status"`

	// StatusText Human-readable status description for the dag-run
	StatusText RunStatusText `json:"StatusText"`
}

type DAGStatusFile struct {
	// DAG Core DAG configuration containing dag-run definition and metadata
	DAG DAG `json:"DAG"`

	// Error Error message if any
	Error *string `json:"Error,omitempty"`

	// File Path to the DAG file
	File string `json:"File"`

	// Status Current status of a dag-run
	Status DAGStatus `json:"Status"`

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

type DAGStatusFileDetails struct {
	// DAG Detailed DAG configuration information
	DAG DAGDetails `json:"DAG"`

	// Error Error message if any
	Error *string `json:"Error,omitempty"`

	// File Path to the DAG file
	File string `json:"File"`

	// Status Detailed status of a dag-run including child nodes
	Status DAGStatusDetails `json:"Status"`

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

type DeleteDAG204Response struct {
}

type DeleteDAG404JSONResponse Error

type DeleteDAGRequestObject struct {
	Name string `json:"name"`
}

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

type DeleteDAGdefaultJSONResponse 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 GetDAGDetails200JSONResponse struct {
	// DAG Detailed status information for a DAG instance
	DAG DAGStatusFileDetails `json:"DAG"`

	// Definition DAG definition
	Definition *string `json:"Definition,omitempty"`

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

	// LogData Historical run data for a DAG
	LogData *DAGHistoryData `json:"LogData,omitempty"`

	// LogUrl URL to access logs directly
	LogUrl *string `json:"LogUrl,omitempty"`

	// ScLog Log information for the scheduler
	ScLog *SchedulerLog `json:"ScLog,omitempty"`

	// StepLog Log information for a specific step
	StepLog *StepLog `json:"StepLog,omitempty"`

	// Title Title of the Page
	Title string `json:"Title"`
}

type GetDAGDetails404JSONResponse Error

type GetDAGDetailsParams struct {
	// Tab Specific part of the DAG to retrieve
	Tab  *DAGDetailTab `form:"tab,omitempty" json:"tab,omitempty"`
	File *string       `form:"file,omitempty" json:"file,omitempty"`

	// Step Step name within the DAG
	Step *string `form:"step,omitempty" json:"step,omitempty"`
}

type GetDAGDetailsRequestObject struct {
	Name   string `json:"name"`
	Params GetDAGDetailsParams
}

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

type GetDAGDetailsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type GetHealth200JSONResponse HealthResponse

type GetHealth503JSONResponse HealthResponse

type GetHealthRequestObject struct {
}

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

type GetHealthdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type HandlerOn struct {
	// Cancel Individual task within a DAG that performs a specific operation
	Cancel *Step `json:"Cancel,omitempty"`

	// Exit Individual task within a DAG that performs a specific operation
	Exit *Step `json:"Exit,omitempty"`

	// Failure Individual task within a DAG that performs a specific operation
	Failure *Step `json:"Failure,omitempty"`

	// Success Individual task within a DAG that performs a specific operation
	Success *Step `json:"Success,omitempty"`
}

type HealthResponse struct {
	// Status Overall health status of the server
	Status HealthResponseStatus `json:"status"`

	// Timestamp Current server time
	Timestamp string `json:"timestamp"`

	// Uptime Server uptime in seconds
	Uptime int `json:"uptime"`

	// Version Current version of the server
	Version string `json:"version"`
}

type HealthResponseStatus string

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

type ListDAGs200JSONResponse struct {
	// DAGs List of DAGs with their status and metadata
	DAGs []DAGStatusFile `json:"DAGs"`

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

	// HasError Whether any errors were encountered
	HasError bool `json:"HasError"`

	// PageCount Total number of pages available
	PageCount int `json:"PageCount"`
}

type ListDAGs400JSONResponse Error

type ListDAGsParams struct {
	// Page Page number (for pagination)
	Page *int `form:"page,omitempty" json:"page,omitempty"`

	// Limit Number of items to return per page
	Limit *int `form:"limit,omitempty" json:"limit,omitempty"`

	// SearchName Filter DAGs by name
	SearchName *string `form:"searchName,omitempty" json:"searchName,omitempty"`

	// SearchTag Filter DAGs by tag
	SearchTag *string `form:"searchTag,omitempty" json:"searchTag,omitempty"`
}

type ListDAGsRequestObject struct {
	Params ListDAGsParams
}

type ListDAGsResponseObject interface {
	VisitListDAGsResponse(w http.ResponseWriter) error
}

type ListDAGsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

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

	// Tags List of unique tags
	Tags []string `json:"Tags"`
}

type ListTags200JSONResponse ListTagResponse

type ListTagsRequestObject struct {
}

type ListTagsResponseObject interface {
	VisitListTagsResponse(w http.ResponseWriter) error
}

type ListTagsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type MiddlewareFunc func(http.Handler) http.Handler

type Node struct {
	// DoneCount Number of successful completions for repeating steps
	DoneCount int `json:"DoneCount"`

	// Error Error message if the step failed
	Error *string `json:"Error,omitempty"`

	// FinishedAt RFC3339 timestamp when the step finished
	FinishedAt string `json:"FinishedAt"`

	// Log Path to step-specific log file
	Log string `json:"Log"`

	// RetryCount Number of retry attempts made for this step
	RetryCount int `json:"RetryCount"`

	// StartedAt RFC3339 timestamp when the step started
	StartedAt string `json:"StartedAt"`

	// Status Numeric status code indicating current node state:
	// 0: "Not started"
	// 1: "Running"
	// 2: "Failed"
	// 3: "Aborted"
	// 4: "Success"
	// 5: "Skipped"
	// 6: "Partial Success"
	Status NodeStatus `json:"Status"`

	// StatusText Human-readable status description for the node
	StatusText NodeStatusText `json:"StatusText"`

	// Step Individual task within a DAG that performs a specific operation
	Step Step `json:"Step"`
}

type NodeStatus int

type NodeStatusText string

type PostDAGAction200JSONResponse PostDAGActionResponse

type PostDAGActionJSONBody struct {
	// Action Action to be performed on the DAG. Possible values include:
	// - start: Start the DAG
	// - suspend: Suspend the DAG
	// - stop: Stop the DAG
	// - retry: Retry the last run
	// - mark-success: Mark the last run as successful
	// - mark-failed: Mark the last run as failed
	// - save: Save the current state of the DAG
	// - rename: Rename the DAG
	Action DAGAction `json:"action"`

	// Params Additional parameters for the action in JSON format
	Params *string `json:"params,omitempty"`

	// RequestId Unique request ID for the action
	RequestId *string `json:"requestId,omitempty"`

	// Step Step name if the action targets a specific step
	Step *string `json:"step,omitempty"`

	// Value Optional extra value for the action
	Value *string `json:"value,omitempty"`
}

type PostDAGActionJSONRequestBody PostDAGActionJSONBody

type PostDAGActionRequestObject struct {
	Name string `json:"name"`
	Body *PostDAGActionJSONRequestBody
}

type PostDAGActionResponse struct {
	// NewName New DAG name, if the action resulted in a new DAG
	NewName *string `json:"NewName,omitempty"`
}

type PostDAGActionResponseObject interface {
	VisitPostDAGActionResponse(w http.ResponseWriter) error
}

type PostDAGActiondefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type Precondition struct {
	// Condition Expression or check to evaluate
	Condition *string `json:"Condition,omitempty"`

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

type RepeatPolicy struct {
	Backoff *RepeatPolicy_Backoff `json:"Backoff,omitempty"`

	// Interval Time in seconds to wait between retry attempts
	Interval *int `json:"Interval,omitempty"`

	// MaxIntervalSec Maximum interval in seconds (caps exponential growth)
	MaxIntervalSec *int `json:"MaxIntervalSec,omitempty"`

	// Repeat Whether the step should be retried on failure
	Repeat *bool `json:"Repeat,omitempty"`
}

type RepeatPolicyBackoff0 = bool

type RepeatPolicyBackoff1 = float32

type RepeatPolicy_Backoff struct {
	// contains filtered or unexported fields
}

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

type RequiredParamError struct {
	ParamName string
}

type RunStatus int

type RunStatusText string

type Schedule struct {
	// Expression Cron expression or schedule pattern
	Expression string `json:"Expression"`
}

type SchedulerLog struct {
	// Content Log content
	Content string `json:"Content"`

	// LogFile Path to the scheduler log file
	LogFile string `json:"LogFile"`
}

type SearchDAGs200JSONResponse struct {
	// Errors Errors encountered during the search
	Errors []string `json:"Errors"`

	// Results Search results matching the query
	Results []SearchDAGsResultItem `json:"Results"`
}

type SearchDAGsMatchItem struct {
	// Line Matching line content
	Line string `json:"Line"`

	// LineNumber Line number where match was found
	LineNumber int `json:"LineNumber"`

	// StartLine Start line for context
	StartLine int `json:"StartLine"`
}

type SearchDAGsParams struct {
	// Q A search query string
	Q string `form:"q" json:"q"`
}

type SearchDAGsRequestObject struct {
	Params SearchDAGsParams
}

type SearchDAGsResponseObject interface {
	VisitSearchDAGsResponse(w http.ResponseWriter) error
}

type SearchDAGsResultItem struct {
	// DAG Core DAG configuration containing dag-run definition and metadata
	DAG DAG `json:"DAG"`

	// Matches Details of where matches were found
	Matches []SearchDAGsMatchItem `json:"Matches"`

	// Name Name of the matching DAG
	Name string `json:"Name"`
}

type SearchDAGsdefaultJSONResponse struct {
	Body       Error
	StatusCode int
}

type ServerInterface interface {
	// List all DAGs
	// (GET /dags)
	ListDAGs(w http.ResponseWriter, r *http.Request, params ListDAGsParams)
	// Create a new DAG
	// (POST /dags)
	CreateDAG(w http.ResponseWriter, r *http.Request)
	// Delete a DAG
	// (DELETE /dags/{name})
	DeleteDAG(w http.ResponseWriter, r *http.Request, name string)
	// Get DAG details
	// (GET /dags/{name})
	GetDAGDetails(w http.ResponseWriter, r *http.Request, name string, params GetDAGDetailsParams)
	// Perform an action on a DAG
	// (POST /dags/{name})
	PostDAGAction(w http.ResponseWriter, r *http.Request, name string)
	// Health check endpoint
	// (GET /health)
	GetHealth(w http.ResponseWriter, r *http.Request)
	// Search DAGs
	// (GET /search)
	SearchDAGs(w http.ResponseWriter, r *http.Request, params SearchDAGsParams)
	// List all tags
	// (GET /tags)
	ListTags(w http.ResponseWriter, r *http.Request)
}

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

type Step struct {
	// Args List of arguments to pass to the command
	Args *[]string `json:"Args,omitempty"`

	// CmdWithArgs Complete command string including arguments to execute
	CmdWithArgs *string `json:"CmdWithArgs,omitempty"`

	// Command Base command to execute without arguments
	Command *string `json:"Command,omitempty"`

	// Depends List of step names that must complete before this step can start
	Depends *[]string `json:"Depends,omitempty"`

	// Description Human-readable description of what the step does
	Description *string `json:"Description,omitempty"`

	// Dir Working directory for executing the step's command
	Dir *string `json:"Dir,omitempty"`

	// MailOnError Whether to send email notifications on step failure
	MailOnError *bool `json:"MailOnError,omitempty"`

	// Name Unique identifier for the step within the DAG
	Name string `json:"Name"`

	// Output Variable name to store the step's output
	Output *string `json:"Output,omitempty"`

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

	// Preconditions Conditions that must be met before the step can start
	Preconditions *[]Precondition `json:"Preconditions,omitempty"`

	// RepeatPolicy Configuration for step retry behavior
	RepeatPolicy *RepeatPolicy `json:"RepeatPolicy,omitempty"`

	// Run Sub DAG to run
	Run *string `json:"Run,omitempty"`

	// Script Script content if the step executes a script file
	Script *string `json:"Script,omitempty"`

	// Stderr File path for capturing standard error
	Stderr *string `json:"Stderr,omitempty"`

	// Stdout File path for capturing standard output
	Stdout *string `json:"Stdout,omitempty"`
}

type StepLog struct {
	// Content Log content
	Content string `json:"Content"`

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

	// Step Status of an individual step within a dag-run
	Step Node `json:"Step"`
}

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 = strictnethttp.StrictHTTPHandlerFunc

type StrictMiddlewareFunc = strictnethttp.StrictHTTPMiddlewareFunc

type StrictServerInterface interface {
	// List all DAGs
	// (GET /dags)
	ListDAGs(ctx context.Context, request ListDAGsRequestObject) (ListDAGsResponseObject, error)
	// Create a new DAG
	// (POST /dags)
	CreateDAG(ctx context.Context, request CreateDAGRequestObject) (CreateDAGResponseObject, error)
	// Delete a DAG
	// (DELETE /dags/{name})
	DeleteDAG(ctx context.Context, request DeleteDAGRequestObject) (DeleteDAGResponseObject, error)
	// Get DAG details
	// (GET /dags/{name})
	GetDAGDetails(ctx context.Context, request GetDAGDetailsRequestObject) (GetDAGDetailsResponseObject, error)
	// Perform an action on a DAG
	// (POST /dags/{name})
	PostDAGAction(ctx context.Context, request PostDAGActionRequestObject) (PostDAGActionResponseObject, error)
	// Health check endpoint
	// (GET /health)
	GetHealth(ctx context.Context, request GetHealthRequestObject) (GetHealthResponseObject, error)
	// Search DAGs
	// (GET /search)
	SearchDAGs(ctx context.Context, request SearchDAGsRequestObject) (SearchDAGsResponseObject, error)
	// List all tags
	// (GET /tags)
	ListTags(ctx context.Context, request ListTagsRequestObject) (ListTagsResponseObject, 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
}