Add server/cache support to gaeconfig.

logdog/common/storage/bigtable/storage.go

 // Copyright 2015 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 bigtable
 
 import (
         "bytes"
         "errors"
         "fmt"
@@ skipping 393 matching lines @@
         // If we have exceeded our threshold, report a failure.
         appended = (w.buf.Len() <= w.threshold)
         if appended {
                 w.count++
         }
         return
 }
 
 func (w *rowWriter) flush(ctx context.Context, raw btTable, index types.MessageIndex,
         project cfgtypes.ProjectName, path types.StreamPath) (int, error) {
+
         flushCount := w.count
         if flushCount == 0 {
                 return 0, nil
         }
 
         // Write the current set of buffered rows to the table. Index on the LAST
         // row index.
         lastIndex := int64(index) + int64(flushCount) - 1
         rk := newRowKey(string(project), string(path), lastIndex, int64(w.count))
 
         log.Fields{
                 "rowKey":    rk,
                 "project":   project,
                 "path":      path,
                 "index":     index,
                 "lastIndex": lastIndex,
                 "count":     w.count,
                 "size":      w.buf.Len(),
         }.Debugf(ctx, "Adding entries to BigTable.")
         if err := raw.putLogData(ctx, rk, w.buf.Bytes()); err != nil {
                 return 0, err
         }
 
         // Reset our buffer state.
         w.buf.Reset()
         w.count = 0
         return flushCount, nil
 }