task_scheduler

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

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

type TaskRequest struct {
	ID          string                 `json:"id"`
	Name        string                 `json:"name"`
	Description string                 `json:"description"`
	Command     []string               `json:"command"`
	Args        []string               `json:"args"`
	Image       string                 `json:"image"`
	Env         map[string]string      `json:"env"`
	Timeout     time.Duration          `json:"timeout"`
	Retry       TaskRetryConfig        `json:"retry"`
	Resources   TaskResourceConfig     `json:"resources"`
	Volumes     []TaskVolumeConfig     `json:"volumes,omitempty"`
	Metadata    map[string]interface{} `json:"metadata"`
}

type TaskResourceConfig struct {
	CPU    string `json:"cpu"`
	Memory string `json:"memory"`
}

type TaskRetryConfig struct {
	MaxRetries      int           `json:"maxRetries"`
	RetryDelay      time.Duration `json:"retryDelay"`
	BackoffStrategy string        `json:"backoffStrategy"`
}

type TaskStatistics struct {
	TotalTasks      int64  `json:"totalTasks"`
	CompletedTasks  int64  `json:"completedTasks"`
	FailedTasks     int64  `json:"failedTasks"`
	RunningTasks    int64  `json:"runningTasks"`
	ScheduledTasks  int64  `json:"scheduledTasks"`
	LastTaskTime    string `json:"lastTaskTime"`
	AverageTaskTime string `json:"averageTaskTime"`
}

type TaskStatus struct {
	ID             string                 `json:"id"`
	Phase          string                 `json:"phase"`
	StartTime      *time.Time             `json:"startTime,omitempty"`
	CompletionTime *time.Time             `json:"completionTime,omitempty"`
	Message        string                 `json:"message"`
	Reason         string                 `json:"reason"`
	ExitCode       *int32                 `json:"exitCode,omitempty"`
	JobName        string                 `json:"jobName"`
	PodName        string                 `json:"podName"`
	Logs           string                 `json:"logs,omitempty"`
	Metadata       map[string]interface{} `json:"metadata"`
}

type TaskVolumeConfig struct {
	// Name of the volume
	Name string `json:"name"`
	// Mount path in the container
	MountPath string `json:"mountPath"`
	// Volume type (pvc, configmap, secret, emptyDir)
	Type string `json:"type"`
	// Source configuration (depends on type)
	Source TaskVolumeSource `json:"source"`
	// ReadOnly mount
	ReadOnly bool `json:"readOnly,omitempty"`
}

type TaskVolumeConfigMap struct {
	// ConfigMap name
	Name string `json:"name"`
	// Items to project from configMap
	Items []TaskVolumeConfigMapItem `json:"items,omitempty"`
}

type TaskVolumeConfigMapItem struct {
	// Key in configMap
	Key string `json:"key"`
	// Path to mount the key
	Path string `json:"path"`
}

type TaskVolumeEmptyDir struct {
	// Size limit for emptyDir
	SizeLimit string `json:"sizeLimit,omitempty"`
	// Medium (Memory for tmpfs)
	Medium string `json:"medium,omitempty"`
}

type TaskVolumePVC struct {
	// Claim name (if existing) or auto-generated if empty
	ClaimName string `json:"claimName,omitempty"`
	// Size for auto-created PVC
	Size string `json:"size,omitempty"`
	// Storage class for auto-created PVC
	StorageClass string `json:"storageClass,omitempty"`
	// Access modes for auto-created PVC
	AccessModes []string `json:"accessModes,omitempty"`
	// Auto-delete PVC after job completion
	AutoDelete bool `json:"autoDelete,omitempty"`
}

type TaskVolumeSource struct {
	// PVC configuration (for type: pvc)
	PVC *TaskVolumePVC `json:"pvc,omitempty"`
	// EmptyDir configuration (for type: emptyDir)
	EmptyDir *TaskVolumeEmptyDir `json:"emptyDir,omitempty"`
	// ConfigMap configuration (for type: configmap)
	ConfigMap *TaskVolumeConfigMap `json:"configMap,omitempty"`
}