LogDog: Update to archival V2.

appengine/logdog/coordinator/endpoints/services/loadStream_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 services
 
 import (
         "errors"
         "testing"
 
@@ skipping 23 matching lines @@
 
                 c = ct.UseConfig(c, &svcconfig.Coordinator{
                         ServiceAuthGroup: "test-services",
                 })
                 fs := authtest.FakeState{}
                 c = auth.WithState(c, &fs)
 
                 // Register a test stream.
                 desc := ct.TestLogStreamDescriptor(c, "foo/bar")
                 ls := ct.TestLogStream(c, desc)
-                if err := ls.Put(ds.Get(c)); err != nil {
+                if err := ds.Get(c).Put(ls); err != nil {
                         panic(err)
                 }
 
                 // Prepare a request to load the test stream.
                 req := logdog.LoadStreamRequest{
                         Path: string(ls.Path()),
                 }
 
                 Convey(`Returns Forbidden error if not a service.`, func() {
                         _, err := be.LoadStream(c, &logdog.LoadStreamRequest{})
@@ skipping 52 matching lines @@
                         Convey(`Will return Internal for random datastore failures.`, func() {
                                 c, fb := featureBreaker.FilterRDS(c, nil)
                                 fb.BreakFeatures(errors.New("test error"), "GetMulti")
 
                                 _, err := be.LoadStream(c, &req)
                                 So(err, ShouldBeRPCInternal)
                         })
                 })
         })
 }