in go/grpshuffle_client/lib/core.go [63:80]
func Shuffle(cc *grpshuffle.ComputeClient, divide uint64, targets []string) ([]*grpshuffle.Combination, error) {
ctx, cancel := context.WithCancel(context.Background())
go func(cancel func()) {
time.Sleep(2500 * time.Millisecond)
cancel()
}(cancel)
res, err := (*cc).Shuffle(ctx, &grpshuffle.ShuffleRequest{
Targets: targets,
Divide: divide,
})
if err != nil {
return nil, err
}
return res.Combinations, nil
}