LogDog: Implement prefix expiration.

appengine/logdog/coordinator/logPrefix.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 coordinator
 
 import (
         "errors"
         "fmt"
         "time"
@@ skipping 26 matching lines @@
         // Prefix is this log stream's prefix value. Log streams with the same prefix
         // are logically grouped.
         //
         // This value should not be changed once populated, as it will invalidate the
         // HashID.
         Prefix string `gae:",noindex"`
 
         // Source is the (indexed) set of source strings sent by the prefix registrar.
         Source []string
 
+        // Expiration is the time when this log prefix expires. Stream registrations
+        // for this prefix will fail after this point.
+        Expiration time.Time
+
         // Secret is the Butler secret value for this prefix. All streams within
         // the prefix share this secret value.
         //
         // This value may only be returned to LogDog services; it is not user-visible.
         Secret []byte `gae:",noindex"`
 
         // extra causes datastore to ignore unrecognized fields and strip them in
         // future writes.
         extra ds.PropertyMap `gae:"-,extra"`
 }
@@ skipping 66 matching lines @@
                 return fmt.Errorf("invalid prefix: %s", err)
         }
         if err := types.PrefixSecret(p.Secret).Validate(); err != nil {
                 return fmt.Errorf("invalid prefix secret: %s", err)
         }
         if p.Created.IsZero() {
                 return errors.New("created time is not set")
         }
         return nil
 }