LogDog: Implement prefix registration in Butler.

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"
@@ skipping 12 matching lines @@
 // 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
 
         // 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
 
         // MaxBundleSize is the maximum bundle size in bytes that may be generated.
         //
         // If this value is zero, no size constraint will be applied to generated
         // bundles.
         MaxBundleSize int
@@ skipping 140 matching lines @@
                 }
         }()
 
         for {
                 bb = &builder{
                         size: b.c.MaxBundleSize,
                         template: logpb.ButlerLogBundle{
                                 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()
 
                         // Attempt to create more bundles.
                         sendNow := b.bundleRoundLocked(bb, state)
 
@@ skipping 287 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
 }