cruntimes

Documentation

Index

• func ArchiveMountPoints(ctx context.Context, req cproto.RunSpec, p events.Publisher[docker.Event], ...) ([]string, error)
• func BaseTempDirName(id string) (string, error)
• func CanonicalizeImage(image string) string
• func PprintCommand(ctx context.Context, command string, args []string, ...) error
• func PullImage(ctx context.Context, req docker.PullImage, p events.Publisher[docker.Event], ...) (err error)
• func ShipContainerCommandLogs(ctx context.Context, r io.ReadCloser, stdtype stdcopy.StdType, ...)

Functions

func ArchiveMountPoints

func ArchiveMountPoints(ctx context.Context,
	req cproto.RunSpec,
	p events.Publisher[docker.Event],
	archivesPath string,
	log *logrus.Entry,
) ([]string, error)

ArchiveMountPoints places the experiment archives and returns a list of mount points to be made available inside the container.

func BaseTempDirName

func BaseTempDirName(id string) (string, error)

BaseTempDirName returns a per-user directory name that is unique for the use and specified id (agentID), but consistently named between agent runs to enable cleanup of earlier tmp files.

func CanonicalizeImage

func CanonicalizeImage(image string) string

CanonicalizeImage returns the canonicalized image name.

func PprintCommand

func PprintCommand(
	ctx context.Context,
	command string,
	args []string,
	p events.Publisher[docker.Event],
	log *logrus.Entry,
) error

PprintCommand provides pretty printing of the given command to trace & log outputs.

func PullImage

func PullImage(
	ctx context.Context,
	req docker.PullImage,
	p events.Publisher[docker.Event],
	wg *waitgroupx.Group,
	log *logrus.Entry,
	getPullCommand func(docker.PullImage, string) (string, []string),
) (err error)

PullImage implements code sharing for singularity & podman.

func ShipContainerCommandLogs

func ShipContainerCommandLogs(
	ctx context.Context,
	r io.ReadCloser,
	stdtype stdcopy.StdType,
	p events.Publisher[docker.Event],
)

ShipContainerCommandLogs forwards the given output stream to the specified publisher. It is used to reveal the result of container command lines, e.g. podman pull...