Versions in this module Expand all Collapse all v1 v1.48.1 Aug 21, 2019 Changes in this version + var ErrorMaxTransferLimitReached = fserrors.FatalError(errors.New("Max transfer limit reached as set by --max-transfer")) + var Stats = NewStats() + func SetBwLimit(bandwidth fs.SizeSuffix) + func StartTokenBucket() + func StartTokenTicker() + type Account struct + func NewAccount(in io.ReadCloser, obj fs.Object) *Account + func NewAccountSizeName(in io.ReadCloser, size int64, name string) *Account + func (acc *Account) AccountRead(n int) (err error) + func (acc *Account) Close() error + func (acc *Account) GetAsyncReader() *asyncreader.AsyncReader + func (acc *Account) GetReader() io.ReadCloser + func (acc *Account) OldStream() io.Reader + func (acc *Account) Read(p []byte) (n int, err error) + func (acc *Account) RemoteStats() (out map[string]interface{}) + func (acc *Account) SetStream(in io.Reader) + func (acc *Account) StopBuffering() + func (acc *Account) String() string + func (acc *Account) UpdateReader(in io.ReadCloser) + func (acc *Account) WithBuffer() *Account + func (acc *Account) WrapStream(in io.Reader) io.Reader + type Accounter interface + OldStream func() io.Reader + SetStream func(io.Reader) + WrapStream func(io.Reader) io.Reader + type StatsInfo struct + func NewStats() *StatsInfo + func (s *StatsInfo) Bytes(bytes int64) + func (s *StatsInfo) Checking(remote string) + func (s *StatsInfo) Deletes(deletes int64) int64 + func (s *StatsInfo) DoneChecking(remote string) + func (s *StatsInfo) DoneTransferring(remote string, ok bool) + func (s *StatsInfo) Error(err error) + func (s *StatsInfo) Errored() bool + func (s *StatsInfo) Errors(errors int64) + func (s *StatsInfo) FatalError() + func (s *StatsInfo) GetBytes() int64 + func (s *StatsInfo) GetChecks() int64 + func (s *StatsInfo) GetErrors() int64 + func (s *StatsInfo) GetLastError() error + func (s *StatsInfo) GetTransfers() int64 + func (s *StatsInfo) HadFatalError() bool + func (s *StatsInfo) HadRetryError() bool + func (s *StatsInfo) Log() + func (s *StatsInfo) RemoteStats(in rc.Params) (out rc.Params, err error) + func (s *StatsInfo) ResetCounters() + func (s *StatsInfo) ResetErrors() + func (s *StatsInfo) RetryAfter() time.Time + func (s *StatsInfo) RetryError() + func (s *StatsInfo) SetCheckQueue(n int, size int64) + func (s *StatsInfo) SetRenameQueue(n int, size int64) + func (s *StatsInfo) SetTransferQueue(n int, size int64) + func (s *StatsInfo) String() string + func (s *StatsInfo) Transferring(remote string) + type WrapFn func(io.Reader) io.Reader + func UnWrap(in io.Reader) (unwrapped io.Reader, wrap WrapFn)
Go to main page