Create unbuffered Tumble entry point for LogDog.

logdog/appengine/coordinator/mutations/createArchiveTask.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 mutations
 
 import (
         "fmt"
         "time"
 
@@ skipping 84 matching lines @@
         return ds.KeyForObj(c, m.logStream())
 }
 
 // ProcessAfter implements tumble.DelayedMutation.
 func (m *CreateArchiveTask) ProcessAfter() time.Time { return m.Expiration }
 
 // HighPriority implements tumble.DelayedMutation.
 func (m *CreateArchiveTask) HighPriority() bool { return false }
 
 // TaskName returns the task's name, which is derived from its log stream ID.
-func (m *CreateArchiveTask) TaskName(c context.Context) (*ds.Key, string) {
-        return ds.KeyForObj(c, m.logStream()), fmt.Sprintf("archive-expired-%s", m.ID)
+func (m *CreateArchiveTask) TaskName(c context.Context) string {
+        return fmt.Sprintf("archive-expired-%s", m.ID)
 }
 
 // logStream returns the log stream associated with this task.
 func (m *CreateArchiveTask) logStream() *coordinator.LogStream {
         return &coordinator.LogStream{
                 ID: m.ID,
         }
 }
 
 func init() {
         tumble.Register((*CreateArchiveTask)(nil))
 }