Create unbuffered Tumble entry point for LogDog.

logdog/appengine/coordinator/endpoints/services/terminateStream_test.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package services
 
 import (
         "errors"
         "testing"
         "time"
@@ skipping 53 matching lines @@
                         Convey(`A non-terminal registered stream, "testing/+/foo/bar"`, func() {
                                 tls.WithProjectNamespace(c, func(c context.Context) {
                                         So(tls.Put(c), ShouldBeNil)
 
                                         // Create an archival request for Tumble so we can ensure that it is
                                         // replaced on termination. This is normally done by RegisterStream.
                                         areq := mutations.CreateArchiveTask{
                                                 ID:         tls.Stream.ID,
                                                 Expiration: env.Clock.Now().Add(time.Hour),
                                         }
-                                        arParent, arName := areq.TaskName(c)
+                                        arParent, arName := ds.KeyForObj(c, tls.Stream), areq.TaskName(c)
                                         err := tumble.PutNamedMutations(c, arParent, map[string]tumble.Mutation{
                                                 arName: &areq,
                                         })
                                         if err != nil {
                                                 panic(err)
                                         }
                                 })
                                 ds.GetTestable(c).CatchupIndexes()
 
                                 Convey(`Can be marked terminal and schedules an archival mutation.`, func() {
@@ skipping 138 matching lines @@
                                 })
 
                                 So(getParams(), ShouldResemble, &coordinator.ArchivalParams{
                                         SettleDelay:    10 * time.Second,
                                         CompletePeriod: 0,
                                 })
                         })
                 })
         })
 }