| 18 | type ReduceFormat (func(string, []string, MrContext)) |
| 19 | |
| 20 | type Worker struct { |
| 21 | UUID string |
| 22 | ID int |
| 23 | nReduce int |
| 24 | Mapf MapFormat |
| 25 | Reducef ReduceFormat |
| 26 | Chan MrContext |
| 27 | EndChan chan bool |
| 28 | storeInRAM bool |
| 29 | State rpc.WorkerState_State |
| 30 | mux sync.Mutex |
| 31 | rpc.UnimplementedWorkerServer |
| 32 | } |
| 33 | |
| 34 | func newWorker(nReduce int, inRAM bool) rpc.WorkerServer { |
| 35 | return &Worker{ |
nothing calls this directly
no outgoing calls
no test coverage detected