manager

Documentation

Index

• Variables
• func Wait(ctx context.Context, manager goccm.ConcurrencyManager) bool
• 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 goccm.ConcurrencyManager) bool

Types

type Manager

type Manager struct {
	FilesManager            goccm.ConcurrencyManager
	FilePartsManager        goccm.ConcurrencyManager
	DirectoryListingManager goccm.ConcurrencyManager
}

func Build

func Build(maxConcurrentConnections, maxConcurrentDirectoryLists int) *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()