manager

package
v3.3.130 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 4, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Index

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.
	AdaptiveUploadV2ConcurrentFiles = 300
	// AdaptiveUploadV2ConcurrentFileParts is the V2 upload HTTP part concurrency cap.
	// The adaptive manager treats this as a maximum, not a fixed target.
	AdaptiveUploadV2ConcurrentFileParts = 1024
)

Functions

This section is empty.

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 Build

func Build(maxConcurrentConnections, maxConcurrentDirectoryLists int, downloadFilesAsSingleStream ...bool) *Manager

func Default

func Default() *Manager

func New

func New(files, fileParts, directoryListing int) *Manager

func SharedDefault added in v3.3.130

func SharedDefault() *Manager

func Sync

func Sync() *Manager

func (*Manager) CreateMatchingClient added in v3.0.3

func (m *Manager) CreateMatchingClient(client *http.Client) *http.Client

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL