util

Documentation

Index

• Constants
• Variables
• func CalculateSha256ByOutput(pods []*PodExec, output string) (string, error)
• func CalculateSha256ByTaskID(pods []*PodExec, taskID string) (string, error)
• func CheckFilesExist(pods []*PodExec, taskID string) bool
• func CriCtlCommand(arg ...string) *exec.Cmd
• func DockerCommand(arg ...string) *exec.Cmd
• func DockerCopy(dst, src string) *exec.Cmd
• func GetClientPodNameInMaster() (string, error)
• func GetClientPodNameInWorker() (string, error)
• func GetFileURL(filePath string) string
• func GetManagerPodName(n int) (string, error)
• func GetOutputPath(fileName string) string
• func GetSeedClientPodName(n int) (string, error)
• func GitCommand(arg ...string) *exec.Cmd
• func KubeCtlCommand(arg ...string) *exec.Cmd
• func KubeCtlCopyCommand(ns, pod, source, target string) *exec.Cmd
• func UploadArtifactPrevStdout(namespace, podName, logDirName, logPrefix string) error
• func UploadArtifactStdout(namespace, podName, logDirName, logPrefix string) error
• type FileMetadata
• type PodExec
  • func ClientExec() (*PodExec, error)
  • func ManagerExec(n int) (*PodExec, error)
  • func NewPodExec(namespace string, name string, container string) *PodExec
  • func SeedClientExec(n int) (*PodExec, error)
  • func (p *PodExec) Command(arg ...string) *exec.Cmd
  • func (p *PodExec) CurlCommand(method string, header map[string]string, data map[string]any, target string) *exec.Cmd
• type TaskMetadata

Constants

const (
	ManagerServerName    = "manager"
	SchedulerServerName  = "scheduler"
	SeedClientServerName = "seed-client"
	ClientServerName     = "client"
)

const (
	DragonflyNamespace = "dragonfly-system"
)

Variables

var Servers = map[string]server{
	ManagerServerName: {
		Name:       ManagerServerName,
		Namespace:  DragonflyNamespace,
		LogDirName: ManagerServerName,
		Replicas:   1,
	},
	SchedulerServerName: {
		Name:       SchedulerServerName,
		Namespace:  DragonflyNamespace,
		LogDirName: SchedulerServerName,
		Replicas:   3,
	},
	SeedClientServerName: {
		Name:       SeedClientServerName,
		Namespace:  DragonflyNamespace,
		LogDirName: "dfdaemon",
		Replicas:   3,
	},
	ClientServerName: {
		Name:       ClientServerName,
		Namespace:  DragonflyNamespace,
		LogDirName: "dfdaemon",
		Replicas:   2,
	},
}

Functions

func CalculateSha256ByOutput

func CalculateSha256ByOutput(pods []*PodExec, output string) (string, error)

func CalculateSha256ByTaskID

func CalculateSha256ByTaskID(pods []*PodExec, taskID string) (string, error)

func CheckFilesExist

func CheckFilesExist(pods []*PodExec, taskID string) bool

Check files is exist or not.

func CriCtlCommand

func CriCtlCommand(arg ...string) *exec.Cmd

func DockerCommand

func DockerCommand(arg ...string) *exec.Cmd

func DockerCopy

func DockerCopy(dst, src string) *exec.Cmd

func GetClientPodNameInMaster

func GetClientPodNameInMaster() (string, error)

func GetClientPodNameInWorker

func GetClientPodNameInWorker() (string, error)

func GetFileURL

func GetFileURL(filePath string) string

func GetManagerPodName

func GetManagerPodName(n int) (string, error)

func GetOutputPath

func GetOutputPath(fileName string) string

func GetSeedClientPodName

func GetSeedClientPodName(n int) (string, error)

func GitCommand

func GitCommand(arg ...string) *exec.Cmd

func KubeCtlCommand

func KubeCtlCommand(arg ...string) *exec.Cmd

func KubeCtlCopyCommand

func KubeCtlCopyCommand(ns, pod, source, target string) *exec.Cmd

func UploadArtifactPrevStdout

func UploadArtifactPrevStdout(namespace, podName, logDirName, logPrefix string) error

func UploadArtifactStdout

func UploadArtifactStdout(namespace, podName, logDirName, logPrefix string) error

Types

type FileMetadata

type FileMetadata struct {
	ID     string
	Sha256 string
}

type PodExec

type PodExec struct {
	// contains filtered or unexported fields
}

func ClientExec

func ClientExec() (*PodExec, error)

func ManagerExec

func ManagerExec(n int) (*PodExec, error)

func NewPodExec

func NewPodExec(namespace string, name string, container string) *PodExec

func SeedClientExec

func SeedClientExec(n int) (*PodExec, error)

func (*PodExec) Command

func (p *PodExec) Command(arg ...string) *exec.Cmd

func (*PodExec) CurlCommand

func (p *PodExec) CurlCommand(method string, header map[string]string, data map[string]any, target string) *exec.Cmd

type TaskMetadata

type TaskMetadata struct {
	ID     string
	Sha256 string
}