mrgo

Documentation

Index

• type HeadNode
  • func (head *HeadNode) InitHostInfo()
• type Host
  • func (h *Host) GetHostState()
  • func (h *Host) RunCommand(user, command string) error
  • func (h *Host) StartCommand(user, command string) error
  • func (h *Host) String() string
• type HostState
  • func (hs HostState) String() string
• type MrGoConfig
  • func (mgc *MrGoConfig) ReadConfig(filename string)
• type Task
  • func (t *Task) Run()
• type TaskState
  • func (ts TaskState) String() string

Types

type HeadNode

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

func (*HeadNode) InitHostInfo

func (head *HeadNode) InitHostInfo()

type Host

type Host struct {
	Id    int
	Name  string
	State HostState
}

func (*Host) GetHostState

func (h *Host) GetHostState()

func (*Host) RunCommand

func (h *Host) RunCommand(user, command string) error

func (*Host) StartCommand

func (h *Host) StartCommand(user, command string) error

func (*Host) String

func (h *Host) String() string

type HostState

type HostState int

const (
	HOST_NULL HostState = iota
	HOST_LIVE
	HOST_DEAD
	HOST_XXXX
)

func (HostState) String

func (hs HostState) String() string

type MrGoConfig

type MrGoConfig struct {
	// paths
	Base,
	Input,
	Temp,
	Output string

	// hosts
	HostFile string
	MaxNodes int
}

func (*MrGoConfig) ReadConfig

func (mgc *MrGoConfig) ReadConfig(filename string)

type Task

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

func (*Task) Run

func (t *Task) Run()

type TaskState

type TaskState int

const (
	TASK_NULL TaskState = iota
	TASK_RUNNING
	TASK_DONE
	TASK_FAIL
)

func (TaskState) String

func (ts TaskState) String() string