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

logdog/appengine/coordinator/mutations/createArchiveTask.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 mutations
 
 import (
         "fmt"
         "time"
 
@@ skipping 29 matching lines @@
 // RollForward implements tumble.DelayedMutation.
 func (m *CreateArchiveTask) RollForward(c context.Context) ([]tumble.Mutation, error) {
         c = log.SetField(c, "id", m.ID)
 
         svc := coordinator.GetServices(c)
         ap, err := svc.ArchivalPublisher(c)
         if err != nil {
                 log.WithError(err).Errorf(c, "Failed to get archival publisher.")
                 return nil, err
         }
+        defer func() {
+                if err := ap.Close(); err != nil {
+                        log.WithError(err).Warningf(c, "Failed to close archival publisher.")
+                }
+        }()
 
         // Get the log stream.
         state := m.logStream().State(c)
 
         if err := ds.Get(c, state); err != nil {
                 if err == ds.ErrNoSuchEntity {
                         log.Warningf(c, "Log stream no longer exists.")
                         return nil, nil
                 }
 
@@ skipping 44 matching lines @@
 // logStream returns the log stream associated with this task.
 func (m *CreateArchiveTask) logStream() *coordinator.LogStream {
         return &coordinator.LogStream{
                 ID: m.ID,
         }
 }
 
 func init() {
         tumble.Register((*CreateArchiveTask)(nil))
 }