util

Documentation

Index

• Constants
• Variables
• func CalculateSha256ByOutput(pods []*PodExec, output string) (string, error)
• func CalculateSha256ByTaskID(pods []*PodExec, taskID string) (string, error)
• func CriCtlCommand(arg ...string) *exec.Cmd
• func DockerCommand(arg ...string) *exec.Cmd
• func DockerCopy(dst, src string) *exec.Cmd
• func GetFileURL(filePath string) string
• func GetOutputPath(fileName string) string
• 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:   1,
	},
}

Functions

func CalculateSha256ByOutput

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

func CalculateSha256ByTaskID

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

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 GetFileURL

func GetFileURL(filePath string) string

func GetOutputPath

func GetOutputPath(fileName string) string

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
}