Create unbuffered Tumble entry point for LogDog.

logdog/appengine/coordinator/endpoints/services/terminateStream.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 (
         "crypto/subtle"
 
         ds "github.com/luci/gae/service/datastore"
@@ skipping 99 matching lines @@
                         cat := mutations.CreateArchiveTask{
                                 ID: id,
 
                                 // Optimistic parameters.
                                 SettleDelay:    params.SettleDelay,
                                 CompletePeriod: params.CompletePeriod,
 
                                 // Schedule this mutation to execute after our settle delay.
                                 Expiration: now.Add(params.SettleDelay),
                         }
-                        aeParent, aeName := cat.TaskName(c)
+
+                        aeParent, aeName := ds.KeyForObj(c, lst), cat.TaskName(c)
                         if err := tumble.PutNamedMutations(c, aeParent, map[string]tumble.Mutation{aeName: &cat}); err != nil {
                                 log.WithError(err).Errorf(c, "Failed to replace archive expiration mutation.")
                                 return grpcutil.Internal
                         }
 
                         log.Fields{
                                 "terminalIndex":  lst.TerminalIndex,
                                 "settleDelay":    cat.SettleDelay,
                                 "completePeriod": cat.CompletePeriod,
                                 "scheduledAt":    cat.Expiration,
@@ skipping 10 matching lines @@
 
         return &google.Empty{}, nil
 }
 
 func standardArchivalParams(cfg *config.Config, pcfg *svcconfig.ProjectConfig) *coordinator.ArchivalParams {
         return &coordinator.ArchivalParams{
                 SettleDelay:    cfg.Coordinator.ArchiveSettleDelay.Duration(),
                 CompletePeriod: endpoints.MinDuration(cfg.Coordinator.ArchiveDelayMax, pcfg.MaxStreamAge),
         }
 }