LogDog: Support per-namespace expired archival.

appengine/logdog/coordinator/archival.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 (
         "crypto/sha256"
         "errors"
         "fmt"
@@ skipping 40 matching lines @@
 // If the task is created successfully, this will return nil. If the LogStream
 // already had a task dispatched, it will return ErrArchiveTasked.
 func (p *ArchivalParams) PublishTask(c context.Context, ap ArchivalPublisher, ls *LogStream) error {
         if ls.State >= LSArchiveTasked {
                 // An archival task has already been dispatched for this log stream.
                 return ErrArchiveTasked
         }
 
         path := string(ls.Path())
         msg := logdog.ArchiveTask{
-                Path: path,
-                Key:  p.createArchivalKey(path),
+                Project: string(Project(c)),

[iannucci, 2016/04/29 20:09:42]

it's unfortunate that "Project" (as in: working on a project) is the same
spelling as "Project" (as in: projecting video on a wall, or projection queries)

[dnj, 2016/04/29 23:04:20]

Hah yeah, acknowledged.

+                Path:    path,
+                Key:     p.createArchivalKey(path),
         }
         if p.SettleDelay > 0 {
                 msg.SettleDelay = google.NewDuration(p.SettleDelay)
         }
         if p.CompletePeriod > 0 {
                 msg.CompletePeriod = google.NewDuration(p.CompletePeriod)
         }
 
         // Publish an archival request.
         if err := ap.Publish(c, &msg); err != nil {
                 return err
         }
 
         // Update our LogStream's ArchiveState to reflect that an archival task has
         // been dispatched.
         ls.State = LSArchiveTasked
         ls.ArchivalKey = msg.Key
         return nil
 }
 
 // createArchivalKey returns a unique archival request key
 func (p *ArchivalParams) createArchivalKey(path string) []byte {
         index := atomic.AddInt32(&p.keyIndex, 1)
         hash := sha256.Sum256([]byte(fmt.Sprintf("%s-%s-%d", p.RequestID, path, index)))
         return hash[:]
 }