LogDog: Implement RegisterPrefix RPC.

appengine/logdog/coordinator/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 coordinator
 
 import (
         "errors"
         "fmt"
         "strings"
@@ skipping 80 matching lines @@
         // Timestamp is the Descriptor's recorded client-side timestamp.
         Timestamp time.Time
 
         // Tags is a set of arbitrary key/value tags associated with this stream. Tags
         // can be queried against.
         //
         // The serialization/deserialization is handled manually in order to enable
         // key/value queries.
         Tags TagMap `gae:"-"`
 
-        // Source is the set of source strings sent by the Butler.
-        Source []string
-
         // extra causes datastore to ignore unrecognized fields and strip them in
         // future writes.
         extra ds.PropertyMap `gae:"-,extra"`
 
         // noDSValidate is a testing parameter to instruct the LogStream not to
         // validate before reading/writing to datastore. It can be controlled by
         // calling SetDSValidate().
         noDSValidate bool
 }
 
@@ skipping 348 matching lines @@
 // were created before the supplied time.
 func AddOlderFilter(q *ds.Query, t time.Time) *ds.Query {
         return q.Lt("Created", t.UTC()).Order("-Created")
 }
 
 // AddNewerFilter adds a filter to queries that restricts them to results that
 // were created after the supplied time.
 func AddNewerFilter(q *ds.Query, t time.Time) *ds.Query {
         return q.Gt("Created", t.UTC()).Order("-Created")
 }