LogDog: Add collector service implementation.

server/logdog/storage/bigtable/bigtable_test.go

Index: server/logdog/storage/bigtable/bigtable_test.go
diff --git a/server/logdog/storage/bigtable/bigtable_test.go b/server/logdog/storage/bigtable/bigtable_test.go
index 88634e5fdcea4fb099d94efed7d041e90409438d..dbdb711004951bdb1c973a3f158c5b4592c85d96 100644
--- a/server/logdog/storage/bigtable/bigtable_test.go
+++ b/server/logdog/storage/bigtable/bigtable_test.go
@@ -5,10 +5,10 @@
 package bigtable
 
 import (
-	"fmt"
 	"testing"
 
 	"github.com/luci/luci-go/common/errors"
+	"github.com/luci/luci-go/common/grpcutil"
 	. "github.com/smartystreets/goconvey/convey"
 )
 
@@ -20,10 +20,12 @@ func TestBigTable(t *testing.T) {
 	})
 
 	Convey(`A regular error is not marked transient.`, t, func() {
-		So(errors.IsTransient(wrapTransient(fmt.Errorf("boring error"))), ShouldBeFalse)
+		So(grpcutil.IsTransient(grpcutil.Canceled), ShouldBeFalse)
+		So(errors.IsTransient(wrapTransient(grpcutil.Canceled)), ShouldBeFalse)
 	})
 
-	Convey(`An error containing "Internal error encountered" is marked transient.`, t, func() {
-		So(errors.IsTransient(wrapTransient(fmt.Errorf("Hey, Internal error encountered!"))), ShouldBeTrue)
+	Convey(`An gRPC transient error is marked transient.`, t, func() {
+		So(grpcutil.IsTransient(grpcutil.Internal), ShouldBeTrue)
+		So(errors.IsTransient(wrapTransient(grpcutil.Internal)), ShouldBeTrue)
 	})
 }