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 83956923c67bc7d202ee3462cd01754a2663d65f..657f568d945fdb0443dc14f69db3222b3f22e485 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)