resource

package
v0.0.0-...-def24e1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 18, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewK8sClient 

func NewK8sClient() (*kubernetes.Clientset, error)

func NewK8sDynamicClient 

func NewK8sDynamicClient() (*dynamic.DynamicClient, error)

Types

type ClientInterface 

type ClientInterface interface {
	DeployTask(spec meta.TaskSpec)
	DeleteTask(spec meta.TaskSpec)
	IsTaskExist(spec meta.TaskSpec) bool
	IsTaskRunning(spec meta.TaskSpec) bool
	GetRuntimeInfos(spec meta.TaskSpec) *meta.RuntimeInfo
}

type DockerResourceClient 

type DockerResourceClient struct {
	DockerClient       *docker.DockerCli
	TaskManager        *TaskManager
	ContainerIDGpusMap map[string][]string
	LocalGpuStats      []*GpuStatsInfo
}

func NewDockerResourceClient 

func NewDockerResourceClient() *DockerResourceClient

func (*DockerResourceClient) DeleteTask 

func (d *DockerResourceClient) DeleteTask(spec meta.TaskSpec)

func (*DockerResourceClient) DeployTask 

func (d *DockerResourceClient) DeployTask(task meta.TaskSpec)

func (*DockerResourceClient) GetRuntimeInfos 

func (d *DockerResourceClient) GetRuntimeInfos(spec meta.TaskSpec) *meta.RuntimeInfo

func (*DockerResourceClient) IsTaskExist 

func (d *DockerResourceClient) IsTaskExist(spec meta.TaskSpec) bool

func (*DockerResourceClient) IsTaskRunning 

func (d *DockerResourceClient) IsTaskRunning(task meta.TaskSpec) bool

IsTaskRunning check all containers running

type GpuStatsInfo 

type GpuStatsInfo struct {
	GpuId  int
	Status string
}

type K8sResourceClient 

type K8sResourceClient struct {
	K8sCli *k8s.K8sCli
}

func NewK8sResourceClient 

func NewK8sResourceClient() *K8sResourceClient

func (*K8sResourceClient) DeleteTask 

func (c *K8sResourceClient) DeleteTask(spec meta.TaskSpec)

func (*K8sResourceClient) DeployTask 

func (c *K8sResourceClient) DeployTask(spec meta.TaskSpec)

DeployTask first check whether deployment existed or not start task or scale task

func (*K8sResourceClient) GetRuntimeInfos 

func (c *K8sResourceClient) GetRuntimeInfos(spec meta.TaskSpec) *meta.RuntimeInfo

func (*K8sResourceClient) IsTaskExist 

func (c *K8sResourceClient) IsTaskExist(spec meta.TaskSpec) bool

func (*K8sResourceClient) IsTaskRunning 

func (c *K8sResourceClient) IsTaskRunning(spec meta.TaskSpec) bool

type TaskManager 

type TaskManager struct {
	RedisClient *redis.RedisClient
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.