Initial distributor implementation

appengine/cmd/dm/mutate/add_backdep_test.go

Index: appengine/cmd/dm/mutate/add_backdep_test.go
diff --git a/appengine/cmd/dm/mutate/add_backdep_test.go b/appengine/cmd/dm/mutate/add_backdep_test.go
index 59c2fb87bb88fd682950e0cd9c711f7c6a039df2..5cc43888f681fae0ad1d6e5071a3bcbd515752dd 100644
--- a/appengine/cmd/dm/mutate/add_backdep_test.go
+++ b/appengine/cmd/dm/mutate/add_backdep_test.go
@@ -58,8 +58,7 @@ func TestAddBackDep(t *testing.T) {
 					abd.NeedsAck = true
 					muts, err := abd.RollForward(c)
 					So(err, ShouldBeNil)
-					So(muts, ShouldResemble, []tumble.Mutation{
-						&AckFwdDep{abd.Dep, true}})
+					So(muts, ShouldResemble, []tumble.Mutation{&AckFwdDep{abd.Dep}})
 
 					So(ds.GetMulti([]interface{}{bdg, bd}), ShouldBeNil)
 					So(bd.Edge(), ShouldResemble, abd.Dep)
@@ -70,13 +69,12 @@ func TestAddBackDep(t *testing.T) {
 			Convey("attempt not finished, need completion", func() {
 				ex, err := ds.Exists(ds.KeyForObj(bdg))
 				So(err, ShouldBeNil)
-				So(ex, ShouldBeFalse)
+				So(ex.Any(), ShouldBeFalse)
 
 				abd.NeedsAck = true
 				muts, err := abd.RollForward(c)
 				So(err, ShouldBeNil)
-				So(muts, ShouldResemble, []tumble.Mutation{
-					&AckFwdDep{abd.Dep, false}})
+				So(muts, ShouldBeNil)
 
 				// Note that bdg was created as a side effect.
 				So(ds.GetMulti([]interface{}{bdg, bd}), ShouldBeNil)