@@ -12,52 +12,31 @@ import (
1212)
1313
1414// UseCollectionBulkWrite returns whether to use collection-level bulk write.
15- // This is an internal option, not exposed via HTTP API.
16- //
17- // Configuration sources (in order of precedence):
18- // - CLI flag: --use-collection-bulk-write (hidden)
19- // - Env var: PCSM_USE_COLLECTION_BULK_WRITE
20- // - Default: false
15+ // Internal option, not exposed via HTTP API.
2116func UseCollectionBulkWrite () bool {
2217 return viper .GetBool ("use-collection-bulk-write" )
2318}
2419
2520// CloneNumParallelCollections returns the number of collections to clone in parallel.
26- // Configurable via CLI flag only (no env var support per decision #2).
27- //
28- // Configuration sources (in order of precedence):
29- // - CLI flag: --clone-num-parallel-collections
30- // - Default: 0 (auto)
21+ // Returns 0 for auto-detection.
3122func CloneNumParallelCollections () int {
3223 return viper .GetInt ("clone-num-parallel-collections" )
3324}
3425
3526// CloneNumReadWorkers returns the number of read workers.
36- // Configurable via CLI flag only (no env var support per decision #2).
37- //
38- // Configuration sources (in order of precedence):
39- // - CLI flag: --clone-num-read-workers
40- // - Default: 0 (auto)
27+ // Returns 0 for auto-detection.
4128func CloneNumReadWorkers () int {
4229 return viper .GetInt ("clone-num-read-workers" )
4330}
4431
4532// CloneNumInsertWorkers returns the number of insert workers.
46- // Configurable via CLI flag only (no env var support per decision #2).
47- //
48- // Configuration sources (in order of precedence):
49- // - CLI flag: --clone-num-insert-workers
50- // - Default: 0 (auto)
33+ // Returns 0 for auto-detection.
5134func CloneNumInsertWorkers () int {
5235 return viper .GetInt ("clone-num-insert-workers" )
5336}
5437
5538// CloneSegmentSizeBytes returns the segment size in bytes.
56- // Configurable via CLI flag only (no env var support per decision #2).
57- //
58- // Configuration sources (in order of precedence):
59- // - CLI flag: --clone-segment-size
60- // - Default: AutoCloneSegmentSize (0 = auto)
39+ // Returns 0 (AutoCloneSegmentSize) for auto-detection.
6140func CloneSegmentSizeBytes () int64 {
6241 sizeStr := viper .GetString ("clone-segment-size" )
6342 if sizeStr == "" {
@@ -73,11 +52,7 @@ func CloneSegmentSizeBytes() int64 {
7352}
7453
7554// CloneReadBatchSizeBytes returns the read batch size in bytes.
76- // Configurable via CLI flag only (no env var support per decision #2).
77- //
78- // Configuration sources (in order of precedence):
79- // - CLI flag: --clone-read-batch-size
80- // - Default: 0 (uses MaxWriteBatchSizeBytes)
55+ // Returns 0 to use MaxWriteBatchSizeBytes default.
8156func CloneReadBatchSizeBytes () int32 {
8257 sizeStr := viper .GetString ("clone-read-batch-size" )
8358 if sizeStr == "" {
@@ -112,11 +87,6 @@ func UseTargetClientCompressors() []string {
11287}
11388
11489// MongoDBOperationTimeout returns the timeout for MongoDB client operations.
115- //
116- // Configuration sources (in order of precedence):
117- // - CLI flag: --mongodb-cli-operation-timeout
118- // - Env var: PCSM_MONGODB_CLI_OPERATION_TIMEOUT
119- // - Default: 5m
12090func MongoDBOperationTimeout () time.Duration {
12191 timeoutStr := viper .GetString ("mongodb-cli-operation-timeout" )
12292 if timeoutStr != "" {
0 commit comments