LogDog: Support per-namespace expired archival.

appengine/logdog/coordinator/archivalPublisher.go

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package coordinator
 
 import (
         "time"
 
         "github.com/golang/protobuf/proto"
@@ skipping 23 matching lines @@
         }
 
         // TODO: Route this through some system (e.g., task queue, tumble) that can
         // impose a dispatch delay for the settle period.
         msg := gcps.Message{
                 Data: d,
         }
 
         return retry.Retry(c, retry.Default, func() error {
                 log.Fields{
-                        "path": t.Path,
-                        "key":  t.Key,
+                        "project": t.Project,
+                        "path":    t.Path,
+                        "key":     t.Key,
                 }.Infof(c, "Publishing archival message for stream.")
 
                 _, err := p.topic.Publish(c, &msg)
                 return err
         }, func(err error, d time.Duration) {
                 log.Fields{
                         log.ErrorKey: err,
                         "delay":      d,
                 }.Warningf(c, "Failed to publish task. Retrying...")
         })
 }