logdog: Use gRPC credentials when creating PubSub client, not http.Client.

logdog/appengine/coordinator/coordinatorTest/archival.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package coordinatorTest
 
 import (
+        "fmt"
         "sort"
         "sync"
 
         "github.com/luci/luci-go/logdog/api/endpoints/coordinator/services/v1"
         "github.com/luci/luci-go/logdog/appengine/coordinator"
         "golang.org/x/net/context"
 )
 
 // ArchivalPublisher is a testing implementation of a
 // coordinator.ArchivalPublisher. It records which archival tasks were
 // scheduled and offers accessors to facilitate test assertions.
 type ArchivalPublisher struct {
         sync.Mutex
 
         // Err, if not nil, is the error returned by Publish.
         Err error
 
+        closed        bool
         tasks         []*logdog.ArchiveTask
         archivalIndex uint64
 }
 
 var _ coordinator.ArchivalPublisher = (*ArchivalPublisher)(nil)
 
+func (ap *ArchivalPublisher) Close() error {
+        ap.Lock()
+        defer ap.Unlock()
+
+        if ap.closed {
+                return fmt.Errorf("already closed")
+        }
+        ap.closed = true
+
+        return nil
+}
+
 // Publish implements coordinator.ArchivalPublisher.
 func (ap *ArchivalPublisher) Publish(c context.Context, at *logdog.ArchiveTask) error {
         ap.Lock()
         defer ap.Unlock()
 
+        if ap.closed {
+                return fmt.Errorf("closed")
+        }
+
         if err := ap.Err; err != nil {
                 return err
         }
 
         ap.tasks = append(ap.tasks, at)
         return nil
 }
 
 // NewPublishIndex implements coordinator.ArchivalPublisher.
 func (ap *ArchivalPublisher) NewPublishIndex() uint64 {
@@ skipping 30 matching lines @@
         sort.Strings(taskHashes)
         return taskHashes
 }
 
 // Clear clears recorded tasks.
 func (ap *ArchivalPublisher) Clear() {
         ap.Lock()
         defer ap.Unlock()
         ap.tasks = nil
 }