manager

package
v2.0.171-beta Latest Latest
Warning

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

Go to latest
Published: Mar 10, 2023 License: MIT Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ConcurrentFiles         = 50
	ConcurrentFileParts     = 75
	ConcurrentDirectoryList = 100
)

Functions

func Wait

func Wait(ctx context.Context, manager ConcurrencyManager) bool

Types

type ConcurrencyManager

type ConcurrencyManager struct {
	goccm.ConcurrencyManager

	DownloadFilesAsSingleStream bool
	// contains filtered or unexported fields
}

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 Sync

func Sync() *Manager

type WaitGroup

type WaitGroup struct {
	// contains filtered or unexported fields
}

func WithWaitGroup

func WithWaitGroup(manager goccm.ConcurrencyManager) *WaitGroup

func (*WaitGroup) Add

func (w *WaitGroup) Add()

func (*WaitGroup) Count

func (w *WaitGroup) Count() int

func (*WaitGroup) Done

func (w *WaitGroup) Done()

func (*WaitGroup) Wait

func (w *WaitGroup) Wait()

Jump to

Keyboard shortcuts

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