Create unbuffered Tumble entry point for LogDog.

logdog/appengine/coordinator/endpoints/services/registerStream_test.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 services
 
 import (
         "errors"
         "fmt"
         "testing"
@@ skipping 282 matching lines @@
 
                                         Convey(`Will not register if the descriptor doesn't validate.`, func() {
                                                 tls.Desc.ContentType = ""
                                                 So(tls.Desc.Validate(true), ShouldNotBeNil)
                                                 req.Desc = tls.DescBytes()
 
                                                 _, err := svr.RegisterStream(c, &req)
                                                 So(err, ShouldBeRPCInvalidArgument, "Invalid log stream descriptor")
                                         })
                                 })
-
-                                Convey(`The registerStreamMutation`, func() {
-                                        svcs := coordinator.GetServices(c)
-                                        cfg, err := svcs.Config(c)
-                                        if err != nil {
-                                                panic(err)
-                                        }
-                                        pcfg, err := svcs.ProjectConfig(c, "proj-foo")
-                                        if err != nil {
-                                                panic(err)
-                                        }
-
-                                        rsm := registerStreamMutation{
-                                                RegisterStreamRequest: &req,
-
-                                                cfg:  cfg,
-                                                pcfg: pcfg,
-
-                                                desc: tls.Desc,
-                                                pfx:  tls.Prefix,
-                                                ls:   tls.Stream,
-                                                lst:  tls.State,
-                                        }
-
-                                        Convey(`Can RollForward.`, func() {
-                                                _, err := rsm.RollForward(c)
-                                                So(err, ShouldBeNil)
-                                        })
-
-                                        Convey(`Returns internal server error if the stream Put() fails (tumble).`, func() {
-                                                c, fb := featureBreaker.FilterRDS(c, nil)
-                                                fb.BreakFeatures(errors.New("test error"), "PutMulti")
-
-                                                _, err := rsm.RollForward(c)
-                                                So(err, ShouldBeRPCInternal)
-                                        })
-                                })
                         })
                 })
         })
 }
 
 func BenchmarkRegisterStream(b *testing.B) {
         c, env := ct.Install()
 
         // Set our archival delays. The project delay is smaller than the service
         // delay, so it should be used.
@@ skipping 34 matching lines @@
                         Desc:          tls.DescBytes(),
                         TerminalIndex: -1,
                 }
 
                 _, err := svr.RegisterStream(c, &req)
                 if err != nil {
                         b.Fatalf("failed to get OK response (%s)", err)
                 }
         }
 }