manager

Documentation

Index

• Variables
• func Wait(ctx context.Context, manager ConcurrencyManager) bool
• type ConcurrencyManager
  • func (c ConcurrencyManager) Max() int
  • func (ConcurrencyManager) New(maxGoRoutines int, downloadFilesAsSingleStream ...bool) ConcurrencyManager
• type Manager
  • func Build(maxConcurrentConnections, maxConcurrentDirectoryLists int, ...) *Manager
  • func Default() *Manager
  • func New(files, fileParts, directoryListing int) *Manager
  • func Sync() *Manager
• type WaitGroup
  • func WithWaitGroup(manager goccm.ConcurrencyManager) *WaitGroup
  • func (w *WaitGroup) Add()
  • func (w *WaitGroup) Count() int
  • func (w *WaitGroup) Done()
  • func (w *WaitGroup) Wait()

Variables

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()