job

Documentation

Index

• type Envs
• type Job
  • func (j Job) CreateAllProcs(pl plan.PeerList) []Proc
  • func (j Job) CreateProcs(pl plan.PeerList, host uint32) []Proc
  • func (j Job) NewProc(peer plan.PeerID, localRank int, checkpoint string, pl plan.PeerList) Proc
• type Proc
  • func (p Proc) Cmd() *exec.Cmd
  • func (p Proc) Script() string

Types

type Envs

type Envs map[string]string

type Job

type Job struct {
	Strategy  kb.Strategy
	Parent    plan.PeerID
	HostList  plan.HostList
	PortRange plan.PortRange
	Prog      string
	Args      []string
	LogDir    string
}

func (Job) CreateAllProcs

func (j Job) CreateAllProcs(pl plan.PeerList) []Proc

func (Job) CreateProcs

func (j Job) CreateProcs(pl plan.PeerList, host uint32) []Proc

func (Job) NewProc

func (j Job) NewProc(peer plan.PeerID, localRank int, checkpoint string, pl plan.PeerList) Proc

type Proc

type Proc struct {
	Name    string
	Prog    string
	Args    []string
	Envs    Envs
	IPv4    uint32
	PubAddr string
	LogDir  string
}

Proc represents a process

func (Proc) Cmd

func (p Proc) Cmd() *exec.Cmd

func (Proc) Script

func (p Proc) Script() string