Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoAvailableWorker = errors.New("no available worker")
Functions ¶
func SelectWorker ¶
func SelectWorker( ctx context.Context, k8sClient client.Client, workload *tfv1.TensorFusionWorkload, maxSkew int32, ) (*tfv1.WorkerStatus, error)
Types ¶
type WorkerGenerator ¶
type WorkerGenerator struct {
WorkerConfig *tfv1.WorkerConfig
}
func (*WorkerGenerator) GenerateWorkerPod ¶
func (wg *WorkerGenerator) GenerateWorkerPod( workload *tfv1.TensorFusionWorkload, ) (*v1.Pod, error)
func (*WorkerGenerator) PodTemplateHash ¶ added in v1.23.0
func (wg *WorkerGenerator) PodTemplateHash(workloadSpec any) (string, error)
Source Files
Click to show internal directories.
Click to hide internal directories.