sync

type AgentCommandSender interface {
	SendCommand(ctx context.Context, agentID string, commandType string, params map[string]string) (success bool, output string, err error)
}

type BasicResponse struct {
	ErrorMsg string      `json:"error_msg"`
	Data     interface{} `json:"data"`
}

type CancelByRefRequest struct {
	ExternalRef      string `json:"external_ref"`
	AttachGeneration int    `json:"attach_generation"`
}

type CancelJobRequest struct {
	StopWithSavepoint bool `json:"stop_with_savepoint"`
}

type CheckpointSnapshot struct {
	JobInstanceID uint                      `json:"job_instance_id"`
	PlatformJobID string                    `json:"platform_job_id"`
	EngineJobID   string                    `json:"engine_job_id"`
	Status        string                    `json:"status"`
	EmptyReason   string                    `json:"empty_reason,omitempty"`
	Message       string                    `json:"message,omitempty"`
	Overview      *EngineCheckpointOverview `json:"overview,omitempty"`
	History       []*EngineCheckpointRecord `json:"history,omitempty"`
}

type CheckpointSnapshotResponse struct {
	ErrorMsg string              `json:"error_msg"`
	Data     *CheckpointSnapshot `json:"data"`
}

type ClusterLogProvider interface {
	GetNodeLogs(ctx context.Context, clusterID uint, nodeID uint, req *clusterapp.GetNodeLogsRequest) (string, error)
	GetJobLogMode(ctx context.Context, clusterID uint) (string, error)
}

type ClusterRuntimeResolver interface {
	ResolveEngineEndpoint(ctx context.Context, clusterID uint, taskDefinition JSONMap) (*EngineEndpoint, error)
}

type ClusterVersionProvider interface {
	GetClusterVersion(ctx context.Context, clusterID uint) (string, error)
}

type ConfigToolClient interface {
	InspectDAG(ctx context.Context, endpoint string, req *ConfigToolContentRequest) (*ConfigToolDAGResponse, error)
	InspectWebUIDAG(ctx context.Context, endpoint string, req *ConfigToolContentRequest) (*ConfigToolWebUIDAGResponse, error)
	ValidateConfig(ctx context.Context, endpoint string, req *ConfigToolValidateRequest) (*ConfigToolValidateResponse, error)
	DeriveSourcePreview(ctx context.Context, endpoint string, req *ConfigToolPreviewRequest) (*ConfigToolPreviewResponse, error)
	DeriveTransformPreview(ctx context.Context, endpoint string, req *ConfigToolPreviewRequest) (*ConfigToolPreviewResponse, error)
	ListPlugins(ctx context.Context, endpoint string, req *ConfigToolPluginListRequest) (*ConfigToolPluginListResponse, error)
	GetPluginOptions(ctx context.Context, endpoint string, req *ConfigToolPluginOptionsRequest) (*ConfigToolPluginOptionsResponse, error)
	RenderPluginTemplate(ctx context.Context, endpoint string, req *ConfigToolPluginTemplateRequest) (*ConfigToolPluginTemplateResponse, error)
	ListPluginEnumValues(ctx context.Context, endpoint string, req *ConfigToolPluginEnumValuesRequest) (*ConfigToolPluginEnumValuesResponse, error)
	PreviewSinkSaveMode(ctx context.Context, endpoint string, req *ConfigToolSinkSaveModePreviewRequest) (*ConfigToolSinkSaveModePreviewResponse, error)
}

type ConfigToolContentRequest struct {
	Content       string   `json:"content,omitempty"`
	ContentFormat string   `json:"contentFormat,omitempty"`
	FilePath      string   `json:"filePath,omitempty"`
	Variables     []string `json:"variables,omitempty"`
}

type ConfigToolDAGResponse struct {
	OK             bool            `json:"ok"`
	Message        string          `json:"message,omitempty"`
	SimpleGraph    bool            `json:"simpleGraph"`
	SourceCount    int             `json:"sourceCount"`
	TransformCount int             `json:"transformCount"`
	SinkCount      int             `json:"sinkCount"`
	Warnings       []string        `json:"warnings"`
	Graph          ConfigToolGraph `json:"graph"`
}

type ConfigToolError struct {
	StatusCode int
	Path       string
	Message    string
	RawBody    string
	ErrorType  string
}

type ConfigToolGraph struct {
	Nodes []map[string]interface{} `json:"nodes"`
	Edges []map[string]interface{} `json:"edges"`
}

type ConfigToolPluginEnumValuesRequest struct {
	PluginType        string   `json:"pluginType"`
	FactoryIdentifier string   `json:"factoryIdentifier"`
	OptionKey         string   `json:"optionKey"`
	PluginJars        []string `json:"pluginJars,omitempty"`
	IncludeSupplement bool     `json:"includeSupplement"`
}

type ConfigToolPluginEnumValuesResponse struct {
	OK                bool     `json:"ok"`
	PluginType        string   `json:"pluginType"`
	FactoryIdentifier string   `json:"factoryIdentifier"`
	OptionKey         string   `json:"optionKey"`
	EnumValues        []string `json:"enumValues"`
	Warnings          []string `json:"warnings"`
}

type ConfigToolPluginFactoryInfo struct {
	FactoryIdentifier string `json:"factoryIdentifier"`
	ClassName         string `json:"className,omitempty"`
	Origin            string `json:"origin,omitempty"`
}

type ConfigToolPluginListRequest struct {
	PluginType string   `json:"pluginType"`
	PluginJars []string `json:"pluginJars,omitempty"`
}

type ConfigToolPluginListResponse struct {
	OK         bool                          `json:"ok"`
	PluginType string                        `json:"pluginType"`
	Plugins    []ConfigToolPluginFactoryInfo `json:"plugins"`
	Warnings   []string                      `json:"warnings"`
}

type ConfigToolPluginOptionDescriptor struct {
	Key                 string      `json:"key"`
	Type                string      `json:"type,omitempty"`
	ElementType         string      `json:"elementType,omitempty"`
	DefaultValue        interface{} `json:"defaultValue,omitempty"`
	Description         string      `json:"description,omitempty"`
	FallbackKeys        []string    `json:"fallbackKeys,omitempty"`
	EnumValues          []string    `json:"enumValues,omitempty"`
	EnumDisplayValues   []string    `json:"enumDisplayValues,omitempty"`
	RequiredMode        string      `json:"requiredMode,omitempty"`
	ConditionExpression string      `json:"conditionExpression,omitempty"`
	ConstraintGroup     string      `json:"constraintGroup,omitempty"`
	Origins             []string    `json:"origins,omitempty"`
	DeclaredClasses     []string    `json:"declaredClasses,omitempty"`
	Advanced            bool        `json:"advanced"`
}

type ConfigToolPluginOptionsRequest struct {
	PluginType        string   `json:"pluginType"`
	FactoryIdentifier string   `json:"factoryIdentifier"`
	PluginJars        []string `json:"pluginJars,omitempty"`
	IncludeSupplement bool     `json:"includeSupplement"`
}

type ConfigToolPluginOptionsResponse struct {
	OK                bool                               `json:"ok"`
	PluginType        string                             `json:"pluginType"`
	FactoryIdentifier string                             `json:"factoryIdentifier"`
	Options           []ConfigToolPluginOptionDescriptor `json:"options"`
	ValueConstraints  []map[string]interface{}           `json:"valueConstraints,omitempty"`
	ConditionRules    []map[string]interface{}           `json:"conditionRules,omitempty"`
	Warnings          []string                           `json:"warnings"`
}

type ConfigToolPluginTemplateRequest struct {
	PluginType        string   `json:"pluginType"`
	FactoryIdentifier string   `json:"factoryIdentifier"`
	PluginJars        []string `json:"pluginJars,omitempty"`
	IncludeSupplement bool     `json:"includeSupplement"`
	IncludeComments   bool     `json:"includeComments"`
	IncludeAdvanced   bool     `json:"includeAdvanced"`
}

type ConfigToolPluginTemplateResponse struct {
	OK                bool     `json:"ok"`
	PluginType        string   `json:"pluginType"`
	FactoryIdentifier string   `json:"factoryIdentifier"`
	ContentFormat     string   `json:"contentFormat"`
	Template          string   `json:"template"`
	Warnings          []string `json:"warnings"`
}

type ConfigToolPreviewRequest struct {
	ConfigToolContentRequest
	SourceNodeID          string                 `json:"sourceNodeId,omitempty"`
	SourceIndex           *int                   `json:"sourceIndex,omitempty"`
	TransformNodeID       string                 `json:"transformNodeId,omitempty"`
	TransformIndex        *int                   `json:"transformIndex,omitempty"`
	PlatformJobID         string                 `json:"platformJobId,omitempty"`
	EngineJobID           string                 `json:"engineJobId,omitempty"`
	PreviewRowLimit       *int                   `json:"previewRowLimit,omitempty"`
	OutputFormat          string                 `json:"outputFormat,omitempty"`
	MetadataOutputDataset string                 `json:"metadataOutputDataset,omitempty"`
	MetadataFields        map[string]interface{} `json:"metadataFields,omitempty"`
	EnvOverrides          map[string]interface{} `json:"envOverrides,omitempty"`
	HttpSink              map[string]interface{} `json:"httpSink,omitempty"`
}

type ConfigToolPreviewResponse struct {
	OK             bool                   `json:"ok"`
	Message        string                 `json:"message,omitempty"`
	Mode           string                 `json:"mode,omitempty"`
	SelectedNodeID string                 `json:"selectedNodeId,omitempty"`
	SelectedIndex  int                    `json:"selectedIndex,omitempty"`
	Warnings       []string               `json:"warnings"`
	Content        string                 `json:"content,omitempty"`
	ContentFormat  string                 `json:"contentFormat,omitempty"`
	Config         map[string]interface{} `json:"config,omitempty"`
	Graph          ConfigToolGraph        `json:"graph"`
	SimpleGraph    bool                   `json:"simpleGraph"`
}

type ConfigToolResolver interface {
	ResolveConfigToolEndpoint(ctx context.Context, clusterID uint, taskDefinition JSONMap) (string, error)
}

type ConfigToolSinkSaveModePreviewAction struct {
	Phase      string `json:"phase,omitempty"`
	ActionType string `json:"actionType,omitempty"`
	ResultType string `json:"resultType,omitempty"`
	Content    string `json:"content,omitempty"`
	Native     bool   `json:"native"`
}

type ConfigToolSinkSaveModePreviewRequest struct {
	ConfigToolContentRequest
	SinkIndex          *int     `json:"sinkIndex,omitempty"`
	SinkNodeID         string   `json:"sinkNodeId,omitempty"`
	PluginJars         []string `json:"pluginJars,omitempty"`
	IncludeInfoPreview bool     `json:"includeInfoPreview"`
}

type ConfigToolSinkSaveModePreviewResponse struct {
	OK             bool                                  `json:"ok"`
	Connector      string                                `json:"connector,omitempty"`
	SinkIndex      int                                   `json:"sinkIndex,omitempty"`
	Supported      bool                                  `json:"supported"`
	Completeness   string                                `json:"completeness,omitempty"`
	SchemaSaveMode string                                `json:"schemaSaveMode,omitempty"`
	DataSaveMode   string                                `json:"dataSaveMode,omitempty"`
	TablePath      string                                `json:"tablePath,omitempty"`
	Actions        []ConfigToolSinkSaveModePreviewAction `json:"actions,omitempty"`
	Tables         []ConfigToolSinkSaveModePreviewTable  `json:"tables,omitempty"`
	Warnings       []string                              `json:"warnings,omitempty"`
}

type ConfigToolSinkSaveModePreviewTable struct {
	TablePath      string                                `json:"tablePath,omitempty"`
	Supported      bool                                  `json:"supported"`
	Completeness   string                                `json:"completeness,omitempty"`
	SchemaSaveMode string                                `json:"schemaSaveMode,omitempty"`
	DataSaveMode   string                                `json:"dataSaveMode,omitempty"`
	Actions        []ConfigToolSinkSaveModePreviewAction `json:"actions,omitempty"`
	Warnings       []string                              `json:"warnings,omitempty"`
}

type ConfigToolValidateRequest struct {
	ConfigToolContentRequest
	TestConnection bool `json:"testConnection"`
}

type ConfigToolValidateResponse struct {
	OK       bool                        `json:"ok"`
	Valid    bool                        `json:"valid"`
	Summary  string                      `json:"summary"`
	Errors   []string                    `json:"errors"`
	Warnings []string                    `json:"warnings"`
	Checks   []ConfigToolValidationCheck `json:"checks"`
}

type ConfigToolValidationCheck struct {
	NodeID        string `json:"nodeId"`
	Kind          string `json:"kind"`
	ConnectorType string `json:"connectorType"`
	Target        string `json:"target"`
	Status        string `json:"status"`
	Message       string `json:"message"`
}

type ConfigToolWebUIDAGEdge struct {
	InputVertexID  int `json:"inputVertexId"`
	TargetVertexID int `json:"targetVertexId"`
}

type ConfigToolWebUIDAGResponse struct {
	JobID          string                 `json:"jobId"`
	JobName        string                 `json:"jobName"`
	JobStatus      string                 `json:"jobStatus"`
	ErrorMsg       string                 `json:"errorMsg"`
	CreateTime     string                 `json:"createTime"`
	FinishTime     string                 `json:"finishTime"`
	JobDag         ConfigToolWebUIJobDAG  `json:"jobDag"`
	Metrics        map[string]interface{} `json:"metrics"`
	PluginJarsUrls []string               `json:"pluginJarsUrls"`
	SimpleGraph    bool                   `json:"simpleGraph"`
	Warnings       []string               `json:"warnings"`
}

type ConfigToolWebUIDAGVertexInfo struct {
	VertexID         int                                           `json:"vertexId"`
	Type             string                                        `json:"type"`
	ConnectorType    string                                        `json:"connectorType"`
	TablePaths       []string                                      `json:"tablePaths"`
	TableColumns     map[string][]string                           `json:"tableColumns"`
	TableSchemas     map[string]map[string]interface{}             `json:"tableSchemas"`
	SaveModePreviews map[string]ConfigToolSinkSaveModePreviewTable `json:"saveModePreviews,omitempty"`
	SaveModeWarnings []string                                      `json:"saveModeWarnings,omitempty"`
}

type ConfigToolWebUIJobDAG struct {
	JobID         string                                  `json:"jobId"`
	PipelineEdges map[string][]ConfigToolWebUIDAGEdge     `json:"pipelineEdges"`
	VertexInfoMap map[string]ConfigToolWebUIDAGVertexInfo `json:"vertexInfoMap"`
	EnvOptions    map[string]interface{}                  `json:"envOptions"`
}

type ContentFormat string

type CreateCuratedTemplateRequest struct {
	Name        string   `json:"name" binding:"required"`
	Description string   `json:"description"`
	Section     string   `json:"section"`
	Mode        string   `json:"mode"`
	Pattern     string   `json:"pattern"`
	Connectors  []string `json:"connectors"`
	Content     string   `json:"content" binding:"required"`
	BuiltinID   string   `json:"builtin_id"`
}

type CreateGlobalVariableRequest struct {
	Key         string `json:"key" binding:"required"`
	Value       string `json:"value"`
	ValueType   string `json:"value_type"`
	Description string `json:"description"`
}

type CreateTaskRequest struct {
	ParentID      *uint   `json:"parent_id"`
	NodeType      string  `json:"node_type"`
	Name          string  `json:"name" binding:"required"`
	Description   string  `json:"description"`
	ClusterID     uint    `json:"cluster_id"`
	EngineVersion string  `json:"engine_version"`
	Mode          string  `json:"mode"`
	ContentFormat string  `json:"content_format"`
	Content       string  `json:"content"`
	JobName       string  `json:"job_name"`
	SortOrder     int     `json:"sort_order"`
	Definition    JSONMap `json:"definition"`
}

type CuratedComboParseData struct {
	Env       string   `json:"env"`
	Source    string   `json:"source"`
	Transform string   `json:"transform"`
	Sink      string   `json:"sink"`
	Present   []string `json:"present"`
	Combined  string   `json:"combined"`
}

type CuratedComboParseResponse struct {
	ErrorMsg string                 `json:"error_msg"`
	Data     *CuratedComboParseData `json:"data"`
}

type CuratedTemplate struct {
	ID          uint            `json:"id" gorm:"primaryKey;autoIncrement"`
	BuiltinID   string          `json:"builtin_id" gorm:"size:120;index"`
	OwnerUserID uint            `json:"owner_user_id" gorm:"index;not null"`
	Name        string          `json:"name" gorm:"size:200;not null"`
	Description string          `json:"description" gorm:"type:text"`
	Section     string          `json:"section" gorm:"size:32;not null;index"`
	Mode        string          `json:"mode" gorm:"size:32;not null;default:'ANY'"`
	Pattern     string          `json:"pattern" gorm:"size:32;not null;default:'other'"`
	Connectors  JSONStringSlice `json:"connectors" gorm:"type:json"`
	// Content 精选模板脚本正文；MySQL 用 MEDIUMTEXT，PG/SQLite 用 TEXT。
	// Content is curated template script body; MySQL uses MEDIUMTEXT, PG/SQLite use TEXT.
	Content   db.ScriptText `json:"content" gorm:"not null"`
	Enabled   bool          `json:"enabled" gorm:"not null;default:true"`
	CreatedAt time.Time     `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt time.Time     `json:"updated_at" gorm:"autoUpdateTime"`
}

type CuratedTemplateListData struct {
	Items []*CuratedTemplateView `json:"items"`
	Total int                    `json:"total"`
}

type CuratedTemplateListResponse struct {
	ErrorMsg string                   `json:"error_msg"`
	Data     *CuratedTemplateListData `json:"data"`
}

type CuratedTemplateResponse struct {
	ErrorMsg string               `json:"error_msg"`
	Data     *CuratedTemplateView `json:"data"`
}

type CuratedTemplateView struct {
	ID          uint     `json:"id,omitempty"`
	BuiltinID   string   `json:"builtin_id,omitempty"`
	Name        string   `json:"name"`
	Description string   `json:"description"`
	Section     string   `json:"section"`
	Mode        string   `json:"mode"`
	Pattern     string   `json:"pattern"`
	Connectors  []string `json:"connectors"`
	Content     string   `json:"content"`
	Enabled     bool     `json:"enabled"`
	Origin      string   `json:"origin"` // builtin|user|override
	HasOverride bool     `json:"has_override"`
	OwnerUserID uint     `json:"owner_user_id,omitempty"`
}

type DAGResponse struct {
	ErrorMsg string     `json:"error_msg"`
	Data     *DAGResult `json:"data"`
}

type DAGResult struct {
	Nodes       []JSONMap `json:"nodes"`
	Edges       []JSONMap `json:"edges"`
	WebUIJob    JSONMap   `json:"webui_job,omitempty"`
	SimpleGraph bool      `json:"simple_graph,omitempty"`
	Warnings    []string  `json:"warnings,omitempty"`
}

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

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

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

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

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

type DolphinProject struct {
	Code int64  `json:"code"`
	Name string `json:"name"`
}

type DolphinProjectListResponse struct {
	ErrorMsg string           `json:"error_msg"`
	Data     []DolphinProject `json:"data"`
}

type DolphinPushRequest struct {
	Mode               string  `json:"mode"`
	ConnectionID       uint    `json:"connection_id"`
	ProjectCode        int64   `json:"project_code"`
	WorkflowName       string  `json:"workflow_name"`
	WorkflowCode       int64   `json:"workflow_code"`
	Upstreams          []int64 `json:"upstreams"`
	Downstreams        []int64 `json:"downstreams"`
	UseBuiltinSchedule bool    `json:"use_builtin_schedule"`
	// Timeout 已忽略：生成脚本不再写入 --timeout，保留字段只为兼容旧请求体。
	// Timeout is ignored: generated scripts omit --timeout; kept only for old request bodies.
	Timeout         string            `json:"timeout"`
	Variables       map[string]string `json:"variables"`
	WorkerGroup     string            `json:"worker_group"`
	Environment     string            `json:"environment"`
	DryRun          bool              `json:"dry_run"`
	ExpectedVersion int               `json:"expected_version"`
}

type DolphinPushResponse struct {
	ErrorMsg string             `json:"error_msg"`
	Data     *DolphinPushResult `json:"data"`
}

type DolphinPushResult struct {
	DryRun       bool                  `json:"dry_run"`
	Mode         string                `json:"mode"`
	Script       *DolphinScriptResult  `json:"script,omitempty"`
	Binding      *TaskSchedulerBinding `json:"binding,omitempty"`
	WorkflowCode int64                 `json:"workflow_code,omitempty"`
	TaskCode     int64                 `json:"task_code,omitempty"`
	Version      int                   `json:"version,omitempty"`
	ReleaseState string                `json:"release_state,omitempty"`
	WouldOffline bool                  `json:"would_offline,omitempty"`
	Cycle        bool                  `json:"cycle"`
	Message      string                `json:"message,omitempty"`
	Warning      string                `json:"warning,omitempty"`
}

type DolphinScriptResponse struct {
	ErrorMsg string               `json:"error_msg"`
	Data     *DolphinScriptResult `json:"data"`
}

type DolphinScriptResult struct {
	Script      string            `json:"script"`
	EnvNotes    string            `json:"env_notes"`
	Timeout     string            `json:"timeout,omitempty"`
	WorkerGroup string            `json:"worker_group"`
	Environment string            `json:"environment"`
	Variables   map[string]string `json:"variables,omitempty"`
}

type DolphinTaskStatus struct {
	Binding       *TaskSchedulerBinding `json:"binding"`
	Connection    *SchedulerConnection  `json:"connection,omitempty"`
	Script        *DolphinScriptResult  `json:"script,omitempty"`
	RecentJobs    []*JobInstance        `json:"recent_jobs"`
	BuiltinLocked bool                  `json:"builtin_locked"`
	// PublishedVersion 是任务当前已发布版本；PushedVersion 是上次推到 Dolphin 的版本。
	// PublishedVersion is the task's current published version; PushedVersion is the last version pushed to Dolphin.
	PublishedVersion int `json:"published_version"`
	PushedVersion    int `json:"pushed_version"`
}

type DolphinTaskStatusResponse struct {
	ErrorMsg string             `json:"error_msg"`
	Data     *DolphinTaskStatus `json:"data"`
}

type DolphinWorkflowDetail struct {
	Code         int64                     `json:"code"`
	Name         string                    `json:"name"`
	Version      int                       `json:"version"`
	ReleaseState string                    `json:"release_state"`
	Tasks        []DolphinWorkflowTask     `json:"tasks"`
	Relations    []DolphinWorkflowRelation `json:"relations"`
}

type DolphinWorkflowDetailResponse struct {
	ErrorMsg string                 `json:"error_msg"`
	Data     *DolphinWorkflowDetail `json:"data"`
}

type DolphinWorkflowListResponse struct {
	ErrorMsg string                   `json:"error_msg"`
	Data     []DolphinWorkflowSummary `json:"data"`
}

type DolphinWorkflowRelation struct {
	PreTaskCode  int64 `json:"pre_task_code"`
	PostTaskCode int64 `json:"post_task_code"`
}

type DolphinWorkflowSummary struct {
	Code         int64  `json:"code"`
	Name         string `json:"name"`
	ReleaseState string `json:"release_state"`
	Version      int    `json:"version"`
}

type DolphinWorkflowTask struct {
	Code      int64  `json:"code"`
	Name      string `json:"name"`
	TaskType  string `json:"task_type"`
	RawScript string `json:"raw_script,omitempty"`
}

type EngineCheckpoint struct {
	CheckpointID       int64  `json:"checkpointId"`
	CheckpointType     string `json:"checkpointType"`
	Status             string `json:"status"`
	TriggerTimestamp   int64  `json:"triggerTimestamp"`
	CompletedTimestamp int64  `json:"completedTimestamp,omitempty"`
	DurationMillis     int64  `json:"durationMillis,omitempty"`
	StateSize          int64  `json:"stateSize,omitempty"`
	FailureReason      string `json:"failureReason,omitempty"`
}

type EngineCheckpointInProgress struct {
	CheckpointID     int64  `json:"checkpointId"`
	CheckpointType   string `json:"checkpointType"`
	TriggerTimestamp int64  `json:"triggerTimestamp"`
	Acknowledged     int64  `json:"acknowledged"`
	Total            int64  `json:"total"`
}

type EngineCheckpointOverview struct {
	JobID     string                      `json:"jobId"`
	UpdatedAt int64                       `json:"updatedAt"`
	Pipelines []*EngineCheckpointPipeline `json:"pipelines"`
}

type EngineCheckpointPipeline struct {
	PipelineID      int                           `json:"pipelineId"`
	Counts          map[string]int64              `json:"counts"`
	LatestCompleted *EngineCheckpoint             `json:"latestCompleted,omitempty"`
	LatestFailed    *EngineCheckpoint             `json:"latestFailed,omitempty"`
	LatestSavepoint *EngineCheckpoint             `json:"latestSavepoint,omitempty"`
	InProgress      []*EngineCheckpointInProgress `json:"inProgress,omitempty"`
	History         []*EngineCheckpointRecord     `json:"history,omitempty"`
}

type EngineCheckpointRecord struct {
	PipelineID int               `json:"pipelineId"`
	Checkpoint *EngineCheckpoint `json:"checkpoint"`
}

type EngineClient interface {
	Submit(ctx context.Context, req *EngineSubmitRequest) (*EngineSubmitResponse, error)
	GetJobInfo(ctx context.Context, endpoint *EngineEndpoint, jobID string) (*EngineJobInfo, error)
	ListRunningJobs(ctx context.Context, endpoint *EngineEndpoint) ([]*EngineJobListItem, error)
	ListFinishedJobs(ctx context.Context, endpoint *EngineEndpoint, state string) ([]*EngineJobListItem, error)
	GetJobCheckpointOverview(ctx context.Context, endpoint *EngineEndpoint, jobID string) (*EngineCheckpointOverview, error)
	GetJobCheckpointHistory(ctx context.Context, endpoint *EngineEndpoint, jobID string, pipelineID *int, limit int, status string) ([]*EngineCheckpointRecord, error)
	StopJob(ctx context.Context, endpoint *EngineEndpoint, jobID string, stopWithSavepoint bool) error
	GetJobLogs(ctx context.Context, endpoint *EngineEndpoint, jobID string) (string, error)
}

type EngineEndpoint struct {
	BaseURL     string
	ContextPath string
	LegacyURL   string
	APIMode     string
}

type EngineJobInfo struct {
	JobID        string                 `json:"jobId"`
	JobName      string                 `json:"jobName"`
	JobStatus    string                 `json:"jobStatus"`
	CreateTime   string                 `json:"createTime"`
	FinishedTime string                 `json:"finishTime"`
	ErrorMsg     interface{}            `json:"errorMsg"`
	JobDag       map[string]interface{} `json:"jobDag"`
	Metrics      map[string]interface{} `json:"metrics"`
}

type EngineJobListItem struct {
	JobID        string      `json:"jobId"`
	JobName      string      `json:"jobName"`
	JobStatus    string      `json:"jobStatus"`
	CreateTime   string      `json:"createTime"`
	FinishedTime string      `json:"finishTime"`
	ErrorMsg     interface{} `json:"errorMsg"`
}

type EngineSubmitRequest struct {
	Endpoint           *EngineEndpoint
	Format             string
	JobID              string
	JobName            string
	StartWithSavepoint bool
	Body               []byte
}

type EngineSubmitResponse struct {
	JobID           string `json:"jobId"`
	JobName         string `json:"jobName"`
	APIMode         string `json:"apiMode,omitempty"`
	EndpointBaseURL string `json:"endpointBaseUrl,omitempty"`
	EngineURL       string `json:"engineUrl,omitempty"`
	EngineMethod    string `json:"engineMethod,omitempty"`
}

type ExecutionRequest struct {
	RequestID      string
	IdempotencyKey string
	RequestHash    string
	ClientType     string
}

type ExecutionTarget struct {
	ClusterID     uint
	NodeID        uint
	HostID        uint
	AgentID       string
	InstallDir    string
	Role          string
	HostIP        string
	APIPort       int
	HazelcastPort int
}

type ExecutionTargetResolver interface {
	ResolveExecutionTarget(ctx context.Context, clusterID uint, definition JSONMap) (*ExecutionTarget, error)
	ResolveExecutionTargets(ctx context.Context, clusterID uint, definition JSONMap) ([]*ExecutionTarget, error)
}

type ForkCuratedTemplateRequest struct {
	BuiltinID   string `json:"builtin_id" binding:"required"`
	Name        string `json:"name"`
	Description string `json:"description"`
}

type GetSyncPluginOptionsRequest struct {
	ClusterID         uint   `json:"cluster_id" binding:"required"`
	PluginType        string `json:"plugin_type" binding:"required"`
	FactoryIdentifier string `json:"factory_identifier" binding:"required"`
	IncludeSupplement *bool  `json:"include_supplement,omitempty"`
}

type GlobalVariable struct {
	ID          uint      `json:"id" gorm:"primaryKey;autoIncrement"`
	Key         string    `json:"key" gorm:"size:120;not null;uniqueIndex"`
	Value       string    `json:"value" gorm:"type:text"`
	ValueType   string    `json:"value_type" gorm:"size:32;not null;default:'string'"`
	Description string    `json:"description" gorm:"type:text"`
	CreatedBy   uint      `json:"created_by"`
	CreatedAt   time.Time `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt   time.Time `json:"updated_at" gorm:"autoUpdateTime"`
}

type GlobalVariableListData struct {
	Total int64             `json:"total"`
	Items []*GlobalVariable `json:"items"`
}

type GlobalVariableListResponse struct {
	ErrorMsg string                  `json:"error_msg"`
	Data     *GlobalVariableListData `json:"data"`
}

type GlobalVariableResponse struct {
	ErrorMsg string          `json:"error_msg"`
	Data     *GlobalVariable `json:"data"`
}

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

type JSONMap map[string]interface{}

type JSONStringSlice []string

type JobFilter struct {
	TaskID        uint
	RunType       RunType
	PlatformJobID string
	EngineJobID   string
	OwnerUserID   uint
	IncludeAll    bool
	Page          int
	Size          int
}

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

type JobInstance struct {
	ID                      uint      `json:"id" gorm:"primaryKey;autoIncrement"`
	ExecutionID             string    `json:"execution_id" gorm:"size:36;index"`
	TaskID                  uint      `json:"task_id" gorm:"index;not null"`
	TaskVersion             int       `json:"task_version" gorm:"not null"`
	RunType                 RunType   `json:"run_type" gorm:"size:20;not null;index"`
	PlatformJobID           string    `json:"platform_job_id" gorm:"size:32;index"`
	EngineJobID             string    `json:"engine_job_id" gorm:"size:255;index"`
	RecoveredFromInstanceID *uint     `json:"recovered_from_instance_id,omitempty" gorm:"index"`
	Status                  JobStatus `json:"status" gorm:"size:20;default:pending;index"`
	// LastSyncedAt 记录最近一次成功向 SeaTunnel 对齐状态的时间（UTC）。
	// LastSyncedAt is when STX last successfully synced runtime state from SeaTunnel (UTC).
	LastSyncedAt *time.Time `json:"last_synced_at,omitempty"`
	// SyncState 表示观察面新鲜度：ok / degraded / stale / unknown。
	// SyncState indicates observation freshness: ok / degraded / stale / unknown.
	SyncState JobSyncState `json:"sync_state" gorm:"size:20;default:unknown;index"`
	// SyncFailCount 连续问引擎失败次数，成功对齐后归零。
	// SyncFailCount counts consecutive engine sync failures; reset after a successful sync.
	SyncFailCount int `json:"sync_fail_count" gorm:"not null;default:0"`
	// SyncLagMs 由 API 根据 last_synced_at 派生，不落库。
	// SyncLagMs is derived from last_synced_at at read time and is not persisted.
	SyncLagMs int64 `json:"sync_lag_ms,omitempty" gorm:"-"`
	// Mode 从提交快照回填，供 CLI --wait 区分批任务和实时任务，不落库。
	// Mode is copied from the submit snapshot so CLI --wait can tell batch from streaming; it is not persisted.
	Mode          string     `json:"mode,omitempty" gorm:"-"`
	SubmitSpec    JSONMap    `json:"submit_spec" gorm:"type:json"`
	ResultPreview JSONMap    `json:"result_preview" gorm:"type:json"`
	ErrorMessage  string     `json:"error_message" gorm:"type:text"`
	StartedAt     *time.Time `json:"started_at"`
	FinishedAt    *time.Time `json:"finished_at"`
	CreatedBy     uint       `json:"created_by"`
	CreatedAt     time.Time  `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt     time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
	// ExternalRef 记录外部调度器这次运行的引用，例如 ds:{工作流实例}:{节点 code}。
	// ExternalRef stores the external scheduler run identity such as ds:{workflowInstance}:{taskCode}.
	ExternalRef string `json:"external_ref,omitempty" gorm:"size:255;index"`
	// AttachGeneration 在同一 external_ref 被 CLI 接管时递增，用来忽略过期停止请求。
	// AttachGeneration increments when another CLI attaches to the same external_ref so stale cancel requests are ignored.
	AttachGeneration int `json:"attach_generation" gorm:"not null;default:0"`
}

type JobListData struct {
	Total int64          `json:"total"`
	Items []*JobInstance `json:"items"`
}

type JobListResponse struct {
	ErrorMsg string       `json:"error_msg"`
	Data     *JobListData `json:"data"`
}

type JobLogsResponse struct {
	ErrorMsg string         `json:"error_msg"`
	Data     *JobLogsResult `json:"data"`
}

type JobLogsResult struct {
	Mode   string `json:"mode"`
	Source string `json:"source"`
	Logs   string `json:"logs"`
	// MetricsLog 为基于 result_preview.metrics 的最新可读快照，不计入 offset。
	// MetricsLog is the latest human-readable metrics snapshot from result_preview; not covered by offset.
	MetricsLog        string `json:"metrics_log,omitempty"`
	EmptyReason       string `json:"empty_reason,omitempty"`
	ClusterJobLogMode string `json:"cluster_job_log_mode,omitempty"`
	ClusterID         uint   `json:"cluster_id,omitempty"`
	NextOffset        string `json:"next_offset,omitempty"`
	FileSize          int64  `json:"file_size,omitempty"`
	UpdatedAt         string `json:"updated_at"`
}

type JobResponse struct {
	ErrorMsg string       `json:"error_msg"`
	Data     *JobInstance `json:"data"`
}

type JobStatus string

type JobSyncState string

type ListCuratedTemplatesRequest struct {
	Section string `json:"section"`
	Mode    string `json:"mode"`
	Q       string `json:"q"`
	Origin  string `json:"origin"` // builtin|user|all
}

type ListSyncPluginEnumCatalogRequest struct {
	ClusterID         uint  `json:"cluster_id" binding:"required"`
	IncludeSupplement *bool `json:"include_supplement,omitempty"`
}

type ListSyncPluginEnumValuesRequest struct {
	ClusterID         uint   `json:"cluster_id" binding:"required"`
	PluginType        string `json:"plugin_type" binding:"required"`
	FactoryIdentifier string `json:"factory_identifier" binding:"required"`
	OptionKey         string `json:"option_key" binding:"required"`
	IncludeSupplement *bool  `json:"include_supplement,omitempty"`
}

type ListSyncPluginFactoriesRequest struct {
	ClusterID  uint   `json:"cluster_id" binding:"required"`
	PluginType string `json:"plugin_type" binding:"required"`
}

type LocalRunResponse struct {
	PID        int    `json:"pid"`
	ConfigFile string `json:"config_file"`
	LogFile    string `json:"log_file,omitempty"`
	StatusFile string `json:"status_file,omitempty"`
}

type LocalStatusResponse struct {
	Running    bool   `json:"running"`
	Status     string `json:"status"`
	ExitCode   int    `json:"exit_code"`
	Message    string `json:"message"`
	FinishedAt string `json:"finished_at,omitempty"`
}

type ParseCuratedComboRequest struct {
	Content string `json:"content" binding:"required"`
}

type PluginEnumCatalogResponse struct {
	ErrorMsg string                       `json:"error_msg"`
	Data     *SyncPluginEnumCatalogResult `json:"data"`
}

type PluginEnumValuesResponse struct {
	ErrorMsg string                      `json:"error_msg"`
	Data     *SyncPluginEnumValuesResult `json:"data"`
}

type PluginFactoryListResponse struct {
	ErrorMsg string                       `json:"error_msg"`
	Data     *SyncPluginFactoryListResult `json:"data"`
}

type PluginOptionSchemaResponse struct {
	ErrorMsg string                        `json:"error_msg"`
	Data     *SyncPluginOptionSchemaResult `json:"data"`
}

type PluginTemplateResponse struct {
	ErrorMsg string                    `json:"error_msg"`
	Data     *SyncPluginTemplateResult `json:"data"`
}

type PreviewCollectRequest struct {
	PlatformJobID string                   `json:"platform_job_id"`
	EngineJobID   string                   `json:"engine_job_id"`
	Dataset       string                   `json:"dataset"`
	Catalog       map[string]interface{}   `json:"catalog"`
	Columns       []interface{}            `json:"columns"`
	Rows          []map[string]interface{} `json:"rows"`
	RowLimit      int                      `json:"row_limit"`
	Page          int                      `json:"page"`
	PageSize      int                      `json:"page_size"`
	Total         int                      `json:"total"`
	Replace       bool                     `json:"replace"`
}

type PreviewRow struct {
	ID        uint      `json:"id" gorm:"primaryKey;autoIncrement"`
	SessionID uint      `json:"session_id" gorm:"index;not null"`
	TableID   uint      `json:"table_id" gorm:"index;not null"`
	RowIndex  int       `json:"row_index" gorm:"index;not null"`
	RowData   JSONMap   `json:"row_data" gorm:"type:json"`
	CreatedAt time.Time `json:"created_at" gorm:"autoCreateTime"`
}

type PreviewSession struct {
	ID             uint       `json:"id" gorm:"primaryKey;autoIncrement"`
	JobInstanceID  uint       `json:"job_instance_id" gorm:"uniqueIndex;not null"`
	TaskID         uint       `json:"task_id" gorm:"index;not null"`
	PlatformJobID  string     `json:"platform_job_id" gorm:"size:32;index"`
	EngineJobID    string     `json:"engine_job_id" gorm:"size:255;index"`
	RowLimit       int        `json:"row_limit" gorm:"not null;default:100"`
	TimeoutMinutes int        `json:"timeout_minutes" gorm:"not null;default:10"`
	Status         string     `json:"status" gorm:"size:32;not null;default:collecting;index"`
	TotalRows      int        `json:"total_rows" gorm:"not null;default:0"`
	TableCount     int        `json:"table_count" gorm:"not null;default:0"`
	Truncated      bool       `json:"truncated" gorm:"not null;default:false"`
	LastError      string     `json:"last_error" gorm:"type:text"`
	StartedAt      *time.Time `json:"started_at"`
	FinishedAt     *time.Time `json:"finished_at"`
	CreatedAt      time.Time  `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt      time.Time  `json:"updated_at" gorm:"autoUpdateTime"`
}

type PreviewSnapshot struct {
	SessionID      uint                `json:"session_id"`
	JobInstanceID  uint                `json:"job_instance_id"`
	PlatformJobID  string              `json:"platform_job_id"`
	EngineJobID    string              `json:"engine_job_id"`
	Status         string              `json:"status"`
	EmptyReason    string              `json:"empty_reason,omitempty"`
	RowLimit       int                 `json:"row_limit"`
	TimeoutMinutes int                 `json:"timeout_minutes"`
	TotalRows      int                 `json:"total_rows"`
	TableCount     int                 `json:"table_count"`
	Truncated      bool                `json:"truncated"`
	InjectedScript string              `json:"injected_script,omitempty"`
	ContentFormat  string              `json:"content_format,omitempty"`
	Tables         []*PreviewTableData `json:"tables"`
	SelectedTable  *PreviewTableData   `json:"selected_table,omitempty"`
	Warnings       []string            `json:"warnings,omitempty"`
}

type PreviewSnapshotResponse struct {
	ErrorMsg string           `json:"error_msg"`
	Data     *PreviewSnapshot `json:"data"`
}

type PreviewSyncSinkSaveModeRequest struct {
	ClusterID          uint              `json:"cluster_id" binding:"required"`
	SinkIndex          *int              `json:"sink_index,omitempty"`
	SinkNodeID         string            `json:"sink_node_id,omitempty"`
	IncludeInfoPreview *bool             `json:"include_info_preview,omitempty"`
	Draft              *TaskDraftPayload `json:"draft,omitempty"`
}

type PreviewTable struct {
	ID          uint            `json:"id" gorm:"primaryKey;autoIncrement"`
	SessionID   uint            `json:"session_id" gorm:"index;not null"`
	TablePath   string          `json:"table_path" gorm:"size:512;index;not null"`
	DisplayName string          `json:"display_name" gorm:"size:512"`
	Columns     JSONStringSlice `json:"columns" gorm:"type:json"`
	RowCount    int             `json:"row_count" gorm:"not null;default:0"`
	CreatedAt   time.Time       `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt   time.Time       `json:"updated_at" gorm:"autoUpdateTime"`
}

type PreviewTableData struct {
	ID        uint                     `json:"id"`
	TablePath string                   `json:"table_path"`
	Columns   []string                 `json:"columns"`
	RowCount  int                      `json:"row_count"`
	Rows      []map[string]interface{} `json:"rows,omitempty"`
}

type PreviewTaskRequest struct {
	RowLimit        int               `json:"row_limit"`
	TimeoutMinutes  int               `json:"timeout_minutes"`
	SourceNodeID    string            `json:"source_node_id,omitempty"`
	SourceIndex     *int              `json:"source_index,omitempty"`
	TransformNodeID string            `json:"transform_node_id,omitempty"`
	TransformIndex  *int              `json:"transform_index,omitempty"`
	Mode            string            `json:"mode,omitempty"`
	Draft           *TaskDraftPayload `json:"draft,omitempty"`
}

type PublishTaskRequest struct {
	Comment string `json:"comment"`
}

type RecoverJobRequest struct {
	Draft *TaskDraftPayload `json:"draft,omitempty"`
}

type RecoverTaskRequest struct {
	Comment string `json:"comment,omitempty"`
}

type RenderSyncPluginTemplateRequest struct {
	ClusterID         uint   `json:"cluster_id" binding:"required"`
	PluginType        string `json:"plugin_type" binding:"required"`
	FactoryIdentifier string `json:"factory_identifier" binding:"required"`
	IncludeSupplement *bool  `json:"include_supplement,omitempty"`
	IncludeComments   *bool  `json:"include_comments,omitempty"`
	IncludeAdvanced   *bool  `json:"include_advanced,omitempty"`
}

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

type RunType string

type SchedulerConnection struct {
	ID                 uint   `json:"id" gorm:"primaryKey;autoIncrement"`
	Name               string `json:"name" gorm:"size:120;not null"`
	Kind               string `json:"kind" gorm:"size:32;not null;index;default:dolphin"`
	BaseURL            string `json:"base_url" gorm:"size:512;not null"`
	Token              string `json:"-" gorm:"type:text"`
	TokenSet           bool   `json:"token_set" gorm:"-"`
	DefaultProjectCode int64  `json:"default_project_code"`
	APIStyle           string `json:"api_style" gorm:"size:32;not null;default:auto"`
	// DolphinVersion 可选，例如 3.2.2 / 3.3.1；空则运行时探测 3.1/3.2 与 3.3+ 路径。
	// DolphinVersion is optional, e.g. 3.2.2 / 3.3.1; empty means probe 3.1/3.2 vs 3.3+ paths at runtime.
	DolphinVersion string    `json:"dolphin_version,omitempty" gorm:"size:32"`
	CreatedBy      uint      `json:"created_by"`
	CreatedAt      time.Time `json:"created_at" gorm:"autoCreateTime"`
	UpdatedAt      time.Time `json:"updated_at" gorm:"autoUpdateTime"`
}

type SchedulerConnectionListData struct {
	Items []*SchedulerConnection `json:"items"`
}

type SchedulerConnectionListResponse struct {
	ErrorMsg string                       `json:"error_msg"`
	Data     *SchedulerConnectionListData `json:"data"`
}

type SchedulerConnectionRequest struct {
	Name               string `json:"name"`
	Kind               string `json:"kind"`
	BaseURL            string `json:"base_url"`
	Token              string `json:"token"`
	DefaultProjectCode int64  `json:"default_project_code"`
	APIStyle           string `json:"api_style"`
	DolphinVersion     string `json:"dolphin_version"`
}

type SchedulerConnectionResponse struct {
	ErrorMsg string               `json:"error_msg"`
	Data     *SchedulerConnection `json:"data"`
}

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

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