Documentation
¶
Index ¶
- Variables
- func EffectiveAdaptiveDownloadV2ConcurrentFileParts() int
- func EffectiveAdaptiveUploadV2ConcurrentFileParts(defaultMax int) int
- func SetAdaptiveDownloadV2ConcurrentFileParts(maxConcurrentFileParts int)
- func SetAdaptiveUploadV2ConcurrentFileParts(maxConcurrentFileParts int)
- type ConcurrencyManager
- type Manager
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ConcurrentFiles is the default number of files a transfer job may process at once. ConcurrentFiles = 50 // ConcurrentFileParts is the default job-wide cap for concurrent upload/download part work. ConcurrentFileParts = 50 // ConcurrentDirectoryList is the default number of local directory listing operations that may run at once. ConcurrentDirectoryList = 100 // AdaptiveUploadV2ConcurrentFiles is the V2 upload job-level file concurrency cap. // Adaptive upload V2 still controls HTTP part concurrency dynamically; this value prevents // large multi-file jobs from being serialized while the per-destination controller learns. // The default is documented in docs/adaptive-upload-v2-file-concurrency-cap.md. AdaptiveUploadV2ConcurrentFiles = 128 // AdaptiveUploadV2ConcurrentFileParts is the V2 upload HTTP part concurrency cap. // The adaptive manager treats this as a maximum, not a fixed target. AdaptiveUploadV2ConcurrentFileParts = 1024 // AdaptiveDownloadV2ConcurrentFiles is the V2 download job-level file concurrency cap. AdaptiveDownloadV2ConcurrentFiles = 128 // AdaptiveDownloadV2ConcurrentFileParts is the V2 download HTTP range concurrency cap. // The adaptive manager treats this as a maximum, not a fixed target. AdaptiveDownloadV2ConcurrentFileParts = 1024 )
Functions ¶
func EffectiveAdaptiveDownloadV2ConcurrentFileParts ¶ added in v3.3.141
func EffectiveAdaptiveDownloadV2ConcurrentFileParts() int
EffectiveAdaptiveDownloadV2ConcurrentFileParts returns the adaptive download V2 max with the process-wide override applied, when one is configured.
func EffectiveAdaptiveUploadV2ConcurrentFileParts ¶ added in v3.3.141
EffectiveAdaptiveUploadV2ConcurrentFileParts returns defaultMax capped by the process-wide adaptive upload V2 override, when one is configured.
func SetAdaptiveDownloadV2ConcurrentFileParts ¶ added in v3.3.141
func SetAdaptiveDownloadV2ConcurrentFileParts(maxConcurrentFileParts int)
SetAdaptiveDownloadV2ConcurrentFileParts sets the process-wide maximum for adaptive download V2 HTTP range concurrency. Values less than 1 reset the SDK to its default.
func SetAdaptiveUploadV2ConcurrentFileParts ¶ added in v3.3.141
func SetAdaptiveUploadV2ConcurrentFileParts(maxConcurrentFileParts int)
SetAdaptiveUploadV2ConcurrentFileParts sets the process-wide maximum for adaptive upload V2 HTTP part concurrency. Values less than 1 reset the SDK to its target-specific defaults.
Types ¶
type ConcurrencyManager ¶
type ConcurrencyManager struct {
*lib.ConstrainedWorkGroup
DownloadFilesAsSingleStream bool
}
func (ConcurrencyManager) Max ¶
func (c ConcurrencyManager) Max() int
func (ConcurrencyManager) New ¶
func (ConcurrencyManager) New(maxGoRoutines int, downloadFilesAsSingleStream ...bool) ConcurrencyManager
type Manager ¶
type Manager struct {
FilesManager ConcurrencyManager
FilePartsManager ConcurrencyManager
DirectoryListingManager ConcurrencyManager
}
func SharedDefault ¶ added in v3.3.130
func SharedDefault() *Manager
Click to show internal directories.
Click to hide internal directories.