Documentation ¶
Index ¶
- func ExecuteJuice(exe string, cmdArgs []string) bytes.Buffer
- func ExecuteMaple(exe string, content string) bytes.Buffer
- type Job
- type JobResult
- type JuiceChan
- type MasterService
- func (master *MasterService) HandleJuiceRequest(job *Job, reply *int) error
- func (master *MasterService) HandleJuiceResult(result *JobResult, reply *int) error
- func (master *MasterService) HandleMapleRequest(job *Job, reply *int) error
- func (master *MasterService) HandleMapleResult(result *JobResult, reply *int) error
- func (master *MasterService) StartService(fs *F.FileSystemService) error
- func (master *MasterService) SubmitJuice(strList []string) error
- func (master *MasterService) SubmitMaple(strList []string) error
- type WorkerService
- func (worker *WorkerService) RunJuiceTask(job *Job, reply *int) error
- func (worker *WorkerService) RunMapleTask(job *Job, reply *int) error
- func (worker *WorkerService) StartService(fs *F.FileSystemService) error
- func (worker *WorkerService) SubmitJuice(strList []string) error
- func (worker *WorkerService) SubmitMaple(strList []string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Job ¶
type Job struct { Type int // 0 for Maple, 1 for Juice Exe string IntermediateFilePrefix string SrcDirectory []string NumWorkers int DestFile string DeleteInput bool Partitioner string }
Job is a generic representation of a Maple or Juice job
type MasterService ¶
type MasterService struct {
// contains filtered or unexported fields
}
MasterService provides services of MapleJuice's master
func (*MasterService) HandleJuiceRequest ¶
func (master *MasterService) HandleJuiceRequest(job *Job, reply *int) error
HandleJuiceRequest handles requests of Juice tasks
func (*MasterService) HandleJuiceResult ¶
func (master *MasterService) HandleJuiceResult(result *JobResult, reply *int) error
HandleJuiceResult gathers results from Juice tasks
func (*MasterService) HandleMapleRequest ¶
func (master *MasterService) HandleMapleRequest(job *Job, reply *int) error
HandleMapleRequest handles requests of Maple tasks
func (*MasterService) HandleMapleResult ¶
func (master *MasterService) HandleMapleResult(result *JobResult, reply *int) error
HandleMapleResult gathers results from Maple tasks
func (*MasterService) StartService ¶
func (master *MasterService) StartService(fs *F.FileSystemService) error
StartService starts master service of MapleJuice
func (*MasterService) SubmitJuice ¶
func (master *MasterService) SubmitJuice(strList []string) error
SubmitJuice submits a Juice job
func (*MasterService) SubmitMaple ¶
func (master *MasterService) SubmitMaple(strList []string) error
SubmitMaple submits a Maple job
type WorkerService ¶
type WorkerService struct {
// contains filtered or unexported fields
}
WorkerService provides services of MapleJuice's worker
func (*WorkerService) RunJuiceTask ¶
func (worker *WorkerService) RunJuiceTask(job *Job, reply *int) error
func (*WorkerService) RunMapleTask ¶
func (worker *WorkerService) RunMapleTask(job *Job, reply *int) error
func (*WorkerService) StartService ¶
func (worker *WorkerService) StartService(fs *F.FileSystemService) error
StartService starts master service of MapleJuice
func (*WorkerService) SubmitJuice ¶
func (worker *WorkerService) SubmitJuice(strList []string) error
func (*WorkerService) SubmitMaple ¶
func (worker *WorkerService) SubmitMaple(strList []string) error
Click to show internal directories.
Click to hide internal directories.