Documentation
¶
Index ¶
- Variables
- type WorkerClient
- func (WorkerClient) Connect(workerIP string) (*grpc.ClientConn, rpc.WorkerClient)
- func (WorkerClient) End(workerIP string) bool
- func (WorkerClient) Health(workerIP string) int
- func (WorkerClient) Map(workerIP string, m *rpc.MapInfo) bool
- func (WorkerClient) Reduce(workerIP string, m *rpc.ReduceInfo) bool
Constants ¶
This section is empty.
Variables ¶
View Source
var Counter int
View Source
var Request interface{}
View Source
var Result bool
Functions ¶
This section is empty.
Types ¶
type WorkerClient ¶
type WorkerClient struct{}
func (WorkerClient) Connect ¶
func (WorkerClient) Connect(workerIP string) (*grpc.ClientConn, rpc.WorkerClient)
func (WorkerClient) End ¶
func (WorkerClient) End(workerIP string) bool
func (WorkerClient) Health ¶
func (WorkerClient) Health(workerIP string) int
func (WorkerClient) Reduce ¶
func (WorkerClient) Reduce(workerIP string, m *rpc.ReduceInfo) bool
Source Files
Click to show internal directories.
Click to hide internal directories.