LogDog: Add prefix registration endpoint.

appengine/logdog/coordinator/logStreamState_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 coordinator
 
 import (
         "bytes"
         "testing"
         "time"
 
         "github.com/luci/gae/impl/memory"
         ds "github.com/luci/gae/service/datastore"
         "github.com/luci/luci-go/common/clock/testclock"
         "github.com/luci/luci-go/common/logdog/types"
         "golang.org/x/net/context"
 
         . "github.com/luci/luci-go/common/testing/assertions"
         . "github.com/smartystreets/goconvey/convey"
 )
 
 func TestLogStreamState(t *testing.T) {
         t.Parallel()
 
         Convey(`A testing log stream state`, t, func() {
                 c, tc := testclock.UseTime(context.Background(), testclock.TestTimeLocal)
                 c = memory.Use(c)
 
-                if err := WithProjectNamespaceNoAuth(&c, "proj-foo"); err != nil {
+                if err := WithProjectNamespace(&c, "proj-foo", NamespaceAccessNoAuth); err != nil {
                         panic(err)
                 }
                 di := ds.Get(c)
                 di.Testable().Consistent(true)
 
                 now := ds.RoundTime(tc.Now().UTC())
                 ls := LogStream{ID: LogStreamID("testing/+/log/stream")}
                 lst := ls.State(di)
 
                 lst.Schema = CurrentSchemaVersion
@@ skipping 75 matching lines @@
                                         lst.ArchivedTime = now
                                         So(di.Put(lst), ShouldBeNil)
 
                                         So(runQuery(q.Eq("_Terminated", true)), ShouldBeTrue)
                                         So(runQuery(q.Eq("_ArchivalState", ArchivedComplete)), ShouldBeTrue)
                                 })
                         })
                 })
         })
 }