Cache 与快照机制

type Cache interface {
    // 生命周期
    Run(stopCh <-chan struct{})
    WaitForCacheSync(stopCh <-chan struct{})

    // 快照
    Snapshot() *api.ClusterInfo

    // 绑定与驱逐
    AddBindTask(bindCtx *BindContext) error
    Evict(task *api.TaskInfo, reason string) error

    // 状态更新
    RecordJobStatusEvent(job *api.JobInfo, updatePG bool)
    UpdateJobStatus(job *api.JobInfo, ...) (*api.JobInfo, error)
    UpdateQueueStatus(queue *api.QueueInfo) error

    // 客户端
    Client() kubernetes.Interface
    VCClient() vcclient.Interface
    SharedInformerFactory() informers.SharedInformerFactory
    EventRecorder() record.EventRecorder

    // 会话钩子
    OnSessionOpen()
    OnSessionClose()

    // ... 其他方法
}

// 核心状态（Mutex 保护）
Jobs   map[JobID]*JobInfo       // 所有 Job 及其 Task
Nodes  map[string]*NodeInfo     // 所有节点
Queues map[QueueID]*QueueInfo   // 所有队列

// 辅助数据
NodeList         []string                          // 有序节点名列表
PriorityClasses  map[string]*PriorityClass         // 优先级类
HyperNodesInfo   *HyperNodesInfo                   // 网络拓扑
CSINodesStatus   map[string]*CSINodeStatusInfo      // CSI 驱动状态
imageStates      map[string]*imageState             // 镜像可用性缓存

errTasks       workqueue.RateLimitingInterface  // 需要重试的 Task
nodeQueue      workqueue.RateLimitingInterface  // 待同步的 Node
DeletedJobs    workqueue.RateLimitingInterface  // 待清理的 Job
hyperNodesQueue workqueue.Interface              // HyperNode 同步
BindFlowChannel chan *BindContext                // 绑定请求通道

Binder        Binder         // Pod 绑定到 Node（调用 API Server）
Evictor       Evictor        // Pod 驱逐（删除 Pod）
StatusUpdater StatusUpdater  // 更新 Pod/PodGroup/Queue 状态

func (sc *SchedulerCache) Run(stopCh <-chan struct{}) {
    // 1. 启动 Informer Factory
    sc.informerFactory.Start(stopCh)
    sc.vcInformerFactory.Start(stopCh)

    // 2. 等待所有 Informer 同步完成
    sc.WaitForCacheSync(stopCh)

    // 3. 启动 Node Worker（默认 20 个）
    for i := 0; i < sc.nodeWorkers; i++ {
        go wait.Until(sc.runNodeWorker, 0, stopCh)
    }

    // 4. 启动 HyperNode 同步
    go sc.runHyperNodeSyncWorker(stopCh)

    // 5. 启动错误 Task 重试
    go sc.runProcessResyncTask(stopCh)

    // 6. 启动 Job 清理
    go sc.runProcessCleanupJob(stopCh)

    // 7. 启动 Bind Worker（20ms 间隔批处理）
    go wait.Until(sc.processBindTask, 20*time.Millisecond, stopCh)

    // 8. 启动 Metrics 采集
    go wait.Until(sc.GetMetricsData, metricsInterval, stopCh)
}

type BindContext struct {
    TaskInfo   *api.TaskInfo                    // 待绑定的 Pod
    Extensions map[string]BindContextExtension  // Plugin 扩展数据
}

func (sc *SchedulerCache) Evict(task *api.TaskInfo, reason string) error {
    // 1. Lock
    // 2. 找到 Job 和 Task
    // 3. 验证 PodGroup 存在
    // 4. 更新 Task 状态为 Releasing
    // 5. 更新 Node 任务列表
    // 6. 异步执行 Evictor.Evict()
    // 7. 记录事件
}