LogDog: BigTable batching schema.

common/gcloud/pubsub/subscriber/subscriber_test.go

Index: common/gcloud/pubsub/subscriber/subscriber_test.go
diff --git a/common/gcloud/pubsub/subscriber/subscriber_test.go b/common/gcloud/pubsub/subscriber/subscriber_test.go
index 5ae1c7fa492745a0b40a0c0099fd6a4aef68a56f..ae52f1a2c1849ffe235a85e4c643a51710e2bfb7 100644
--- a/common/gcloud/pubsub/subscriber/subscriber_test.go
+++ b/common/gcloud/pubsub/subscriber/subscriber_test.go
@@ -31,7 +31,7 @@ type testSource struct {
 	eventC chan event
 }
 
-func (s *testSource) Pull(c context.Context) ([]*pubsub.Message, error) {
+func (s *testSource) Pull(c context.Context, batch int) ([]*pubsub.Message, error) {
 	select {
 	case <-c.Done():
 		return nil, c.Err()
@@ -114,9 +114,9 @@ func TestSubscriber(t *testing.T) {
 		}
 		ack := &testACK{}
 		s := Subscriber{
-			S:           src,
-			A:           ack,
-			PullWorkers: 8,
+			S:       src,
+			A:       ack,
+			Workers: 8,
 		}
 
 		var seenMu sync.Mutex