LogDog: Add log rendering view.

appengine/logdog/coordinator/backend/storageCleanup_test.go

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 package backend
 
 import (
         "errors"
         "fmt"
         "net/http"
@@ skipping 35 matching lines @@
 func TestHandleStorageCleanup(t *testing.T) {
         t.Parallel()
 
         Convey(`A testing setup`, t, func() {
                 c := gaetesting.TestingContext()
                 c, tc := testclock.UseTime(c, testclock.TestTimeUTC)
 
                 st := testPurgeStorage{}
                 b := Backend{
                         s: coordinator.Service{
-                                StorageFunc: func(context.Context) (storage.Storage, error) {
+                                IntermediateStorageFunc: func(context.Context) (storage.Storage, error) {
                                         return &st, nil
                                 },
                         },
                 }
 
                 tb := testBase{Context: c}
                 r := httprouter.New()
                 b.InstallHandlers(r, tb.base)
 
                 s := httptest.NewServer(r)
@@ skipping 14 matching lines @@
 
                 Convey(`Will succeed, deleting the task, if invalid stream path.`, func() {
                         resp, err := http.PostForm(fmt.Sprintf("%s/archive/cleanup", s.URL), mkValues(map[string]string{
                                 "path": "!!!INVALID PATH!!!",
                         }))
                         So(err, ShouldBeNil)
                         So(resp.StatusCode, ShouldEqual, http.StatusOK)
                 })
 
                 Convey(`Will error if a storage instance could not be obtained.`, func() {
-                        b.s.StorageFunc = func(context.Context) (storage.Storage, error) {
+                        b.s.IntermediateStorageFunc = func(context.Context) (storage.Storage, error) {
                                 return nil, errors.New("test error")
                         }
 
                         resp, err := http.PostForm(fmt.Sprintf("%s/archive/cleanup", s.URL), mkValues(map[string]string{
                                 "path": "testing/+/foo",
                         }))
                         So(err, ShouldBeNil)
                         So(resp.StatusCode, ShouldEqual, http.StatusInternalServerError)
 
                         So(ds.Get(c).Get(ls), ShouldBeNil)
@@ skipping 22 matching lines @@
                         }))
                         So(err, ShouldBeNil)
                         So(resp.StatusCode, ShouldEqual, http.StatusInternalServerError)
                         So(st.closed, ShouldBeTrue)
 
                         So(ds.Get(c).Get(ls), ShouldBeNil)
                         So(ls.State, ShouldEqual, coordinator.LSArchived)
                 })
         })
 }