LogDog: BigTable batching schema.

server/internal/logdog/archivist/archivist.go

 // Copyright 2016 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 archivist
 
 import (
         "fmt"
 
         "github.com/golang/protobuf/proto"
@@ skipping 337 matching lines @@
         hasMissingEntries bool // true if some log entries were missing.
 }
 
 func (s *storageSource) bufferEntries(start types.MessageIndex) error {
         bytes := 0
 
         req := storage.GetRequest{
                 Path:  s.path,
                 Index: start,
         }
-        return s.st.Get(&req, func(idx types.MessageIndex, d []byte) bool {
+        return s.st.Get(req, func(idx types.MessageIndex, d []byte) bool {
                 le := logpb.LogEntry{}
                 if err := proto.Unmarshal(d, &le); err != nil {
                         log.Fields{
                                 log.ErrorKey:  err,
                                 "streamIndex": idx,
                         }.Errorf(s, "Failed to unmarshal LogEntry.")
                         return false
                 }
                 s.buf = append(s.buf, &le)
 
@@ skipping 49 matching lines @@
                 log.Fields{
                         "index":         sidx,
                         "terminalIndex": s.terminalIndex,
                 }.Warningf(s, "Discarding log entries beyond expected terminal index.")
                 return nil, archive.ErrEndOfStream
         }
 
         s.lastIndex = sidx
         return le, nil
 }