worker

package

v1.41.1 Latest Latest Go to latest Published: Jul 21, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NexusGPU/tensor-fusion

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func SelectWorker(ctx context.Context, k8sClient client.Client, ...) (*tfv1.WorkerStatus, error)
type WorkerGenerator
- func (wg *WorkerGenerator) GenerateWorkerPod(ctx context.Context, workload *tfv1.TensorFusionWorkload) (*v1.Pod, error)
- func (wg *WorkerGenerator) PodTemplateHash(workloadSpec any) (string, error)

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
	HypervisorConfig *tfv1.HypervisorConfig
}

func (*WorkerGenerator) GenerateWorkerPod ¶

func (wg *WorkerGenerator) GenerateWorkerPod(
	ctx context.Context,
	workload *tfv1.TensorFusionWorkload,
) (*v1.Pod, error)

func (*WorkerGenerator) PodTemplateHash ¶ added in v1.23.0

func (wg *WorkerGenerator) PodTemplateHash(workloadSpec any) (string, error)

Source Files ¶

View all Source files

worker.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL