dmtcp

Documentation

Index

• func CheckpointArgs(coordinatorPort string) []string
• func GetPaths() ([]string, []string, error)
• func InjectArgs(config apptainerConfig.DMTCPConfig, argv []string) []string
• func LaunchArgs() []string
• func QuickInstallationCheck()
• func RestartArgs() []string
• type Config
• type Entry
  • func (e *Entry) BindPath() apptainerConfig.BindPath
  • func (e *Entry) CoordinatorPort() (string, error)
  • func (e *Entry) Name() string
  • func (e *Entry) Path() string
• type Manager
  • func NewManager() Manager

Functions

func CheckpointArgs

func CheckpointArgs(coordinatorPort string) []string

func GetPaths

func GetPaths() ([]string, []string, error)

func InjectArgs

func InjectArgs(config apptainerConfig.DMTCPConfig, argv []string) []string

func LaunchArgs

func LaunchArgs() []string

func QuickInstallationCheck

func QuickInstallationCheck()

QuickInstallationCheck is a quick smoke test to see if dmtcp is installed on the host for injection by checking for one of the well known dmtcp executables in the PATH. If not found a warning is emitted.

func RestartArgs

func RestartArgs() []string

Types

type Config

type Config struct {
	Bins []string `yaml:"bins"`
	Libs []string `yaml:"libs"`
}

type Entry

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

func (*Entry) BindPath

func (e *Entry) BindPath() apptainerConfig.BindPath

func (*Entry) CoordinatorPort

func (e *Entry) CoordinatorPort() (string, error)

func (*Entry) Name

func (e *Entry) Name() string

func (*Entry) Path

func (e *Entry) Path() string

type Manager

type Manager interface {
	Create(string) (*Entry, error) // create checkpoint directory for dmtcp state
	Get(string) (*Entry, error)    // ensure directory with dmtcp state exists
	List() ([]*Entry, error)       // list checkpoint directories for dmtcp state
	Delete(string) error           // delete checkpoint directory for dmtcp state
}

func NewManager

func NewManager() Manager