LogDog: Add prefix registration endpoint.

client/internal/logdog/butler/bundler/bundler.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 bundler
 
 import (
         "container/heap"
         "fmt"
         "sync"
         "time"
 
         "github.com/luci/luci-go/client/logdog/butlerlib/streamproto"
         "github.com/luci/luci-go/common/cancelcond"
         "github.com/luci/luci-go/common/clock"
         "github.com/luci/luci-go/common/config"
         "github.com/luci/luci-go/common/logdog/types"
         "github.com/luci/luci-go/common/proto/google"
         "github.com/luci/luci-go/common/proto/logdog/logpb"
         "golang.org/x/net/context"
 )
 
 // Config is the Bundler configuration.
 type Config struct {
         // Clock is the clock instance that will be used for Bundler and stream
         // timing.
         Clock clock.Clock
 
-        // Source is the bundle source string to use. This can be empty if there is no
-        // source information to include.
-        Source string
-
         // Project is the project to use.
         Project config.ProjectName
         // Prefix is the common prefix for this set of streams.
         Prefix types.StreamName
         // Secret is the prefix secret for this set of streams.
         Secret []byte
 
         // MaxBufferedBytes is the maximum number of bytes to buffer in memory per
         // stream.
         MaxBufferedBytes int64
@@ skipping 143 matching lines @@
         defer func() {
                 if bb != nil && bb.hasContent() {
                         b.bundleC <- bb.bundle()
                 }
         }()
 
         for {
                 bb = &builder{
                         size: b.c.MaxBundleSize,
                         template: logpb.ButlerLogBundle{
-                                Source:    b.c.Source,
                                 Timestamp: google.NewTimestamp(b.getClock().Now()),
                                 Project:   string(b.c.Project),
                                 Prefix:    string(b.c.Prefix),
                                 Secret:    b.c.Secret,
                         },
                 }
                 var oldestContentTime time.Time
 
                 for {
                         state := b.getStreamStateLocked()
@@ skipping 291 matching lines @@
 
 func (s *streamState) Push(x interface{}) {
         s.streams = append(s.streams, x.(bundlerStream))
 }
 
 func (s *streamState) Pop() interface{} {
         last := s.streams[len(s.streams)-1]
         s.streams = s.streams[:len(s.streams)-1]
         return last
 }