slave

package
v0.0.0-...-8a25df6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 12, 2014 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Port string

Functions

func Run

func Run(configFile string, port string)

Types

type Args

type Args struct{}

type CombineCollector

type CombineCollector struct {
	Key   interface{}
	Value interface{}
}

type Job

type Job struct {
	NumMap         int
	NumReduce      int
	MapRunning     int
	MapDone        int
	ReduceRunning  int
	ReduceDone     int
	ReduceDataPort int
	Master         string
	// contains filtered or unexported fields
}

func (*Job) Map

func (t *Job) Map(args Args, reply *int) error

func (*Job) Reduce

func (t *Job) Reduce(args Args, reply *int) error

func (*Job) SetPath

func (t *Job) SetPath(args PathArgs, reply *int) error

func (*Job) Status

func (t *Job) Status(args StatusArgs, reply *StatusResult) error

type PathArgs

type PathArgs struct {
	Path string
}

type ReduceArgs

type ReduceArgs struct{}

type StatusArgs

type StatusArgs struct{}

type StatusResult

type StatusResult struct {
	NumMap        int
	NumReduce     int
	MapRunning    int
	MapDone       int
	ReduceRunning int
	ReduceDone    int
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL