LogDog: Implement prefix expiration.

appengine/logdog/coordinator/coordinatorTest/logStream.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 (
         "bytes"
         "fmt"
         "time"
@@ skipping 35 matching lines @@
 // MakeStream builds a new TestStream with the supplied parameters.
 func MakeStream(c context.Context, project config.ProjectName, path types.StreamPath) *TestStream {
         prefix, name := path.Split()
 
         now := clock.Now(c).UTC()
         secret := TestSecret()
 
         ts := TestStream{
                 Project: project,
                 Prefix: &coordinator.LogPrefix{
-                        ID:      "", // Filled in by Reload.
-                        Created: ds.RoundTime(now),
-                        Prefix:  "", // Filled in by Reload.
-                        Source:  []string{"test suite"},
-                        Secret:  secret,
+                        ID:         "", // Filled in by Reload.
+                        Created:    ds.RoundTime(now),
+                        Prefix:     "", // Filled in by Reload.
+                        Source:     []string{"test suite"},
+                        Expiration: ds.RoundTime(now.Add(24 * time.Hour)),
+                        Secret:     secret,
                 },
                 Desc: &logpb.LogStreamDescriptor{
                         Prefix:      string(prefix),
                         Name:        string(name),
                         StreamType:  logpb.StreamType_TEXT,
                         ContentType: "application/text",
                         Timestamp:   google.NewTimestamp(now),
                 },
                 State: &coordinator.LogStreamState{
                         Parent:        nil, // Filled in by Reload.
@@ skipping 96 matching lines @@
                 }
         }
         return &le
 }
 
 // WithProjectNamespace runs f in proj's namespace, bypassing authentication
 // checks.
 func (ts *TestStream) WithProjectNamespace(c context.Context, f func(context.Context)) {
         WithProjectNamespace(c, ts.Project, f)
 }