Versions in this module Expand all Collapse all v0 v0.1.3 Mar 3, 2024 v0.1.2 Nov 8, 2023 v0.1.1 Oct 1, 2023 Changes in this version + func TaskCompleted(ctx context.Context, task *mapreduce.MapReduceTask) (reply *mapreduce.MasterTaskCompletedResp, err error) + func Worker(ctx context.Context, mapf func(string, string) []*types.KeyValue, ...)