Add server/cache support to gaeconfig.

logdog/server/collector/collector.go

 // Copyright 2016 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package collector
 
 import (
         "bytes"
         "time"
 
-        "github.com/golang/protobuf/proto"
         "github.com/luci/luci-go/common/clock"
         "github.com/luci/luci-go/common/errors"
         log "github.com/luci/luci-go/common/logging"
         "github.com/luci/luci-go/common/sync/parallel"
         "github.com/luci/luci-go/common/tsmon/distribution"
         "github.com/luci/luci-go/common/tsmon/field"
         "github.com/luci/luci-go/common/tsmon/metric"
         tsmon_types "github.com/luci/luci-go/common/tsmon/types"
         "github.com/luci/luci-go/logdog/api/logpb"
         "github.com/luci/luci-go/logdog/client/butlerproto"
         "github.com/luci/luci-go/logdog/common/storage"
         "github.com/luci/luci-go/logdog/common/types"
         "github.com/luci/luci-go/logdog/server/collector/coordinator"
         "github.com/luci/luci-go/luci_config/common/cfgtypes"
+
+        "github.com/golang/protobuf/proto"
         "golang.org/x/net/context"
 )
 
 const (
         // DefaultMaxMessageWorkers is the default number of concurrent worker
         // goroutones to employ for a single message.
         DefaultMaxMessageWorkers = 4
 )
 
 var (
@@ skipping 410 matching lines @@
                 }
         })
 }
 
 func streamType(desc *logpb.LogStreamDescriptor) string {
         if desc == nil {
                 return "UNKNOWN"
         }
         return desc.StreamType.String()
 }