LogDog: Support per-namespace expired archival.

appengine/logdog/coordinator/coordinatorTest/archival.go

 // Copyright 2015 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 coordinatorTest
 
 import (
         "sort"
         "sync"
 
@@ skipping 49 matching lines @@
         tasks := ap.Tasks()
 
         taskStreams := make([]string, len(tasks))
         for i, at := range tasks {
                 _, name := types.StreamPath(at.Path).Split()
                 taskStreams[i] = string(name)
         }
         sort.Strings(taskStreams)
         return taskStreams
 }
+
+// Clear clears recorded tasks.
+func (ap *ArchivalPublisher) Clear() {
+        ap.Lock()
+        defer ap.Unlock()
+        ap.tasks = nil
+}