LogDog: BigTable batching schema.

appengine/logdog/coordinator/endpoints/logs/get_test.go

Index: appengine/logdog/coordinator/endpoints/logs/get_test.go
diff --git a/appengine/logdog/coordinator/endpoints/logs/get_test.go b/appengine/logdog/coordinator/endpoints/logs/get_test.go
index a09a071fbe088c9a862effa7e00c57e6b563a5ae..1974a0a053fd3f0b8f48b36992cd0e04c3846d0c 100644
--- a/appengine/logdog/coordinator/endpoints/logs/get_test.go
+++ b/appengine/logdog/coordinator/endpoints/logs/get_test.go
@@ -255,10 +255,10 @@ func TestGet(t *testing.T) {
 				if !v {
 					// Add the logs to the in-memory temporary storage.
 					for _, le := range entries {
-						err := ms.Put(&storage.PutRequest{
-							Path:  ls.Path(),
-							Index: types.MessageIndex(le.StreamIndex),
-							Value: protobufs[le.StreamIndex],
+						err := ms.Put(storage.PutRequest{
+							Path:   ls.Path(),
+							Index:  types.MessageIndex(le.StreamIndex),
+							Values: [][]byte{protobufs[le.StreamIndex]},
 						})
 						if err != nil {
 							panic(fmt.Errorf("failed to Put() LogEntry: %v", err))
@@ -441,10 +441,10 @@ func TestGet(t *testing.T) {
 						} else {
 							// Add corrupted entry to Storage. Create a new entry here, since
 							// the storage will reject a duplicate/overwrite.
-							err := ms.Put(&storage.PutRequest{
-								Path:  types.StreamPath(req.Path),
-								Index: 666,
-								Value: []byte{0x00}, // Invalid protobuf, zero tag.
+							err := ms.Put(storage.PutRequest{
+								Path:   types.StreamPath(req.Path),
+								Index:  666,
+								Values: [][]byte{{0x00}}, // Invalid protobuf, zero tag.
 							})
 							if err != nil {
 								panic(err)