| OLD | NEW | 
|---|
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be | 
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. | 
| 4 | 4 | 
| 5 syntax = "proto3"; | 5 syntax = "proto3"; | 
| 6 | 6 | 
| 7 package svcconfig; | 7 package svcconfig; | 
| 8 | 8 | 
| 9 import "transport.proto"; | 9 import "transport.proto"; | 
| 10 import "storage.proto"; | 10 import "storage.proto"; | 
| (...skipping 21 matching lines...) Expand all  Loading... | 
| 32   string project = 1; | 32   string project = 1; | 
| 33 | 33 | 
| 34   // The name of the authentication group for administrators. | 34   // The name of the authentication group for administrators. | 
| 35   string admin_auth_group = 10; | 35   string admin_auth_group = 10; | 
| 36   // The name of the authentication group for backend services. | 36   // The name of the authentication group for backend services. | 
| 37   string service_auth_group = 11; | 37   string service_auth_group = 11; | 
| 38 | 38 | 
| 39   // A list of origin URLs that are allowed to perform CORS RPC calls. | 39   // A list of origin URLs that are allowed to perform CORS RPC calls. | 
| 40   repeated string rpc_allow_origins = 20; | 40   repeated string rpc_allow_origins = 20; | 
| 41 | 41 | 
|  | 42   // The name of the task queue for project-specific archival scans. | 
|  | 43   string archive_scan_project_queue_name = 30; | 
|  | 44 | 
| 42   // The full path of the archival Pub/Sub topic. | 45   // The full path of the archival Pub/Sub topic. | 
| 43   // | 46   // | 
| 44   // The Coordinator must have permission to publish to this topic. | 47   // The Coordinator must have permission to publish to this topic. | 
| 45   string archive_topic = 30; | 48   string archive_topic = 31; | 
| 46 | 49 | 
| 47   // The amount of time after an archive request has been dispatched before it | 50   // The amount of time after an archive request has been dispatched before it | 
| 48   // should be executed. | 51   // should be executed. | 
| 49   // | 52   // | 
| 50   // Since terminal messages can arrive out of order, the archival request may | 53   // Since terminal messages can arrive out of order, the archival request may | 
| 51   // be kicked off before all of the log stream data has been loaded into | 54   // be kicked off before all of the log stream data has been loaded into | 
| 52   // intermediate storage. If this happens, the Archivist will retry archival | 55   // intermediate storage. If this happens, the Archivist will retry archival | 
| 53   // later autometically. | 56   // later autometically. | 
| 54   // | 57   // | 
| 55   // This parameter is an optimization to stop the archivist from wasting its | 58   // This parameter is an optimization to stop the archivist from wasting its | 
| 56   // time until the log stream has a reasonable expectation of being available. | 59   // time until the log stream has a reasonable expectation of being available. | 
| 57   google.protobuf.Duration archive_settle_delay = 31; | 60   google.protobuf.Duration archive_settle_delay = 32; | 
| 58 | 61 | 
| 59   // The amount of time before a log stream is candidate for archival regardless | 62   // The amount of time before a log stream is candidate for archival regardless | 
| 60   // of whether or not it's been terminated or complete. | 63   // of whether or not it's been terminated or complete. | 
| 61   // | 64   // | 
| 62   // This is a failsafe designed to ensure that log streams with missing records | 65   // This is a failsafe designed to ensure that log streams with missing records | 
| 63   // or no terminal record (e.g., Butler crashed) are eventually archived. | 66   // or no terminal record (e.g., Butler crashed) are eventually archived. | 
| 64   // | 67   // | 
| 65   // This should be fairly large (days) to avoid prematurely archiving | 68   // This should be fairly large (days) to avoid prematurely archiving | 
| 66   // long-running streams, but should be considerably smaller than the | 69   // long-running streams, but should be considerably smaller than the | 
| 67   // intermediate storage data retention period. | 70   // intermediate storage data retention period. | 
| 68   google.protobuf.Duration archive_delay_max = 32; | 71   google.protobuf.Duration archive_delay_max = 33; | 
| 69 } | 72 } | 
| 70 | 73 | 
| 71 // Collector is the set of configuration parameters for Collector instances. | 74 // Collector is the set of configuration parameters for Collector instances. | 
| 72 message Collector { | 75 message Collector { | 
| 73   // The maximum number of concurrent transport messages to process. If <= 0, | 76   // The maximum number of concurrent transport messages to process. If <= 0, | 
| 74   // a default will be chosen based on the transport. | 77   // a default will be chosen based on the transport. | 
| 75   int32 max_concurrent_messages = 1; | 78   int32 max_concurrent_messages = 1; | 
| 76 | 79 | 
| 77   // The maximum number of concurrent workers to process each ingested message. | 80   // The maximum number of concurrent workers to process each ingested message. | 
| 78   // If <= 0, collector.DefaultMaxMessageWorkers will be used. | 81   // If <= 0, collector.DefaultMaxMessageWorkers will be used. | 
| (...skipping 29 matching lines...) Expand all  Loading... | 
| 108   // The name of the staging storage bucket. Uses same notation as "gs_base". | 111   // The name of the staging storage bucket. Uses same notation as "gs_base". | 
| 109   string gs_staging_base = 4; | 112   string gs_staging_base = 4; | 
| 110 | 113 | 
| 111   // If not zero, the maximum number of stream indices between index entries. | 114   // If not zero, the maximum number of stream indices between index entries. | 
| 112   int32 stream_index_range = 10; | 115   int32 stream_index_range = 10; | 
| 113   // If not zero, the maximum number of prefix indices between index entries. | 116   // If not zero, the maximum number of prefix indices between index entries. | 
| 114   int32 prefix_index_range = 11; | 117   int32 prefix_index_range = 11; | 
| 115   // If not zero, the maximum number of log data bytes between index entries. | 118   // If not zero, the maximum number of log data bytes between index entries. | 
| 116   int32 byte_range = 12; | 119   int32 byte_range = 12; | 
| 117 } | 120 } | 
| OLD | NEW | 
|---|