Use native Pub/Sub library primitives.

common/proto/logdog/svcconfig/config.proto

 // 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.
 
 syntax = "proto3";
 
 package svcconfig;
 
 import "transport.proto";
 import "storage.proto";
@@ skipping 53 matching lines @@
   // moved out of intermediate storage.
   //
   // This must be >= `archive_delay`, and should be fairly large (days) to allow
   // for the log stream to complete and for all available log entries to be
   // added to intermediate storage.
   google.protobuf.Duration archive_delay_max = 32;
 }
 
 // Collector is the set of configuration parameters for Collector instances.
 message Collector {
-  // Workers is the number of ingest workers to run.
-  int32 workers = 1;
-
-  // The number of transport worker goroutines to run.
-  int32 transport_workers = 2;
+  // The number of concurrent transport messages to process.
+  int32 transport_concurrent_messages = 1;
 
   // The maximum number of log stream states to cache locally. If <= 0, a
   // default will be used.
-  int32 state_cache_size = 3;
+  int32 state_cache_size = 2;
 
   // The maximum amount of time that cached stream state is valid. If <= 0, a
   // default will be used.
-  google.protobuf.Duration state_cache_expiration = 4;
+  google.protobuf.Duration state_cache_expiration = 3;
 }
 
 // Configuration for the Archivist microservice.
 message Archivist {
   // The number of tasks to run at a time. If blank, the archivist will choose a
   // default value.
   int32 tasks = 1;
 
   // The name of the Google Storage bucket and optional base path to archive
   // into. For example: gs://foo/bar
   //
   // The bucket name must be included (e.g., "gs://foo"). The remainder of the
   // base path is optional based on desired archive location.
   string gs_base = 10;
   // If not zero, the maximum number of stream indices between index entries.
   int32 stream_index_range = 11;
   // If not zero, the maximum number of prefix indices between index entries.
   int32 prefix_index_range = 12;
   // If not zero, the maximum number of log data bytes between index entries.
   int32 byte_range = 13;
 }
 
 // Configuration for the Janitor microservice.
 message Janitor {
   // The number of tasks to run at a time. If blank, the janitor will choose a
   // default value.
   int32 tasks = 1;
 }