speed

Documentation

Index

• func Once(speed *Speed, proxy interfaces.Vendor, cfg *interfaces.SlaveRequestConfigsV2)
• func RefetchDownloadFiles(proxy interfaces.Vendor, file string) []string
• func SingleThread(downloadFiles []string, proxy interfaces.Vendor, timeoutSeconds int64, ...) context.CancelFunc
• type Speed
  • func (m *Speed) Run(proxy interfaces.Vendor, r *interfaces.SlaveRequest) error
  • func (m *Speed) Type() interfaces.SlaveRequestMacroType
• type WriteCounter
  • func (wc *WriteCounter) Take() uint64
  • func (wc *WriteCounter) Write(p []byte) (int, error)

Functions

func Once

func Once(speed *Speed, proxy interfaces.Vendor, cfg *interfaces.SlaveRequestConfigsV2)

func RefetchDownloadFiles

func RefetchDownloadFiles(proxy interfaces.Vendor, file string) []string

func SingleThread

func SingleThread(downloadFiles []string, proxy interfaces.Vendor, timeoutSeconds int64, wc *WriteCounter) context.CancelFunc

Types

type Speed

type Speed struct {
	AvgSpeed  uint64
	MaxSpeed  uint64
	TotalSize uint64
	Speeds    []uint64
}

func (*Speed) Run

func (m *Speed) Run(proxy interfaces.Vendor, r *interfaces.SlaveRequest) error

func (*Speed) Type

func (m *Speed) Type() interfaces.SlaveRequestMacroType

type WriteCounter

type WriteCounter struct {
	Total     uint64
	RateLimit int64
	Lock      sync.Mutex
}

func (*WriteCounter) Take

func (wc *WriteCounter) Take() uint64

func (*WriteCounter) Write

func (wc *WriteCounter) Write(p []byte) (int, error)