api

func CheckDeploymentStatus ¶

func CheckDeploymentStatus(deployments []common.Deployment, repository *common.DeploymentsRepository, check func(common.DeploymentStatusCode) bool, msgContext string) error

func DeprovisionLoadDeployments ¶

func DeprovisionLoadDeployments(loadName string) error

func GetContainerStatus ¶

func GetContainerStatus(containerName string) (containerd.Status, error)

func GetHealthStatus ¶

func GetHealthStatus() (map[string]any, error)

GetHealthStatus returns the health status of all monitored services

func GetLoadsDeployments ¶

func GetLoadsDeployments() (*dto.LoadsDeployments, error)

func GetNode ¶

func GetNode(nodeName *string) (*dto.NodeResponse, error)

GetNode returns the node state (CPU, memory, etc) and status If a node is provided, it will be used to query the node state. Otherwise, the self node is used.

func GetNodeConfig ¶ added in v0.2.5

func GetNodeConfig() (*common.NodeDriverConfig, error)

func GetSystemInfo ¶

func GetSystemInfo() (*dto.SystemInfo, error)

GetSystemInfo returns static system information about the host

func GetVersion ¶

func GetVersion() (string, error)

GetVersion returns the agent version

func KillLoadDeployments ¶

func KillLoadDeployments(loadName string) error

func ListContainers ¶

func ListContainers() (map[string]containers.ContainerInfo, error)

ListContainers returns a list of all containers with their status

func LoadNodeConfig ¶ added in v0.2.5

func LoadNodeConfig(node *common.Node) error

func PowerOffNode ¶ added in v0.2.5

func PowerOffNode(nodeName *string) error

func PowerOnNode ¶ added in v0.2.5

func PowerOnNode(node *common.Node) error

func ProvisionLoad ¶

func ProvisionLoad(load *common.Load) (*dto.ProvisionLoadInfo, error)

func ReadLoadStderr ¶

func ReadLoadStderr(loadName string, offset int64) ([]byte, int64, error)

func ReadLoadStdout ¶

func ReadLoadStdout(loadName string, offset int64) ([]byte, int64, error)

func RestartNode ¶

func RestartNode(nodeName *string, message string, time uint32) error

func RunJob ¶ added in v0.2.5

func RunJob(request dto.JobRequest) (*dto.JobResult, error)

func ShutdownNode ¶ added in v0.2.5

func ShutdownNode(nodeName *string, message string, time uint32) error

func StartLoadDeployments ¶

func StartLoadDeployments(loadName string) error

func StopLoadDeployments ¶

func StopLoadDeployments(loadName string) error

func StreamLoadStderr ¶

func StreamLoadStderr(loadName string, w io.Writer) error

func StreamLoadStdout ¶

func StreamLoadStdout(loadName string, w io.Writer) error

func UnloadGuestNodeConfig ¶ added in v0.2.5

func UnloadGuestNodeConfig(nodeName string) error

func UnloadNodeConfig ¶ added in v0.2.5

func UnloadNodeConfig() error

func ValidateNodeConfig ¶ added in v0.2.5

func ValidateNodeConfig(node *common.Node) error