accounting

Mar 10, 2024

Changes in this version

type TransferSnapshot

+ DstFs string

+ SrcFs string

Jan 8, 2024

Changes in this version

type StatsInfo

+ func (s *StatsInfo) BytesNoNetwork(bytes int64)

Sep 11, 2023

Changes in this version

type Account

+ func UnWrapAccounting(in io.Reader) (unwrapped io.Reader, acc *Account)

+ func (acc *Account) ServerSideMoveEnd(n int64)

+ func (acc *Account) ServerSideTransferEnd(n int64)

+ func (acc *Account) ServerSideTransferStart()

type StatsInfo

+ func (s *StatsInfo) AddServerSideCopy(n int64)

+ func (s *StatsInfo) AddServerSideMove(n int64)

Mar 14, 2023

Changes in this version

type StatsInfo

+ func (s *StatsInfo) DeleteFile(ctx context.Context, size int64) error

+ func (s *StatsInfo) GetDeletes() int64

Mar 31, 2021

Changes in this version

+ func Start(ctx context.Context)

Feb 2, 2021

Changes in this version

+ var ErrorMaxTransferLimitReachedGraceful = fserrors.NoRetryError(ErrorMaxTransferLimitReached)

+ var TokenBucket tokenBucket

+ func LimitTPS(ctx context.Context)

+ func StartLimitTPS(ctx context.Context)

type Account

+ func (acc *Account) DryRun(n int64)

type StatsInfo

+ func (s *StatsInfo) DeletedDirs(deletedDirs int64) int64

+ type TokenBucketSlot int

+ const TokenBucketSlotAccounting

+ const TokenBucketSlotTransportRx

+ const TokenBucketSlotTransportTx

+ const TokenBucketSlots

Oct 26, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Sep 13, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Sep 2, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Changes in this version

type Account

+ func (acc *Account) Abandon()

+ func (acc *Account) HasBuffer() bool

Aug 7, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Jun 24, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Jun 10, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

May 27, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Changes in this version

+ var ErrorMaxTransferLimitReachedFatal = fserrors.FatalError(ErrorMaxTransferLimitReached)

type Account

+ func (acc *Account) WriteTo(w io.Writer) (n int64, err error)

+ type RcloneCollector struct

+ func NewRcloneCollector() *RcloneCollector

+ func (c *RcloneCollector) Collect(ch chan<- prometheus.Metric)

+ func (c *RcloneCollector) Describe(ch chan<- *prometheus.Desc)

type StatsInfo

+ func (s *StatsInfo) GetBytesWithPending() int64

+ func (s *StatsInfo) Renames(renames int64) int64

+ func (s *StatsInfo) Speed() float64

Feb 1, 2020 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Changes in this version

+ var MaxCompletedTransfers = 100

type TransferSnapshot

+ Group string

Nov 19, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Nov 2, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Oct 26, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Changes in this version

type Account

+ func (acc *Account) ServerSideCopyEnd(n int64)

+ func (acc *Account) ServerSideCopyStart()

type StatsInfo

+ func (s *StatsInfo) PruneTransfers()

+ func (s *StatsInfo) RemoveTransfer(transfer *Transfer)

type Transfer

+ func (tr *Transfer) Reset()

Oct 5, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Sep 29, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Changes in this version

type Account

+ func (acc *Account) Done()

Sep 15, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Sep 8, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Aug 28, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Aug 26, 2019 GO-2022-0878

  GO-2022-0878: Use of Cryptographically Weak Pseudo-Random Number Generator in Rclone in github.com/rclone/rclone

Changes in this version

+ var ErrorMaxTransferLimitReached = fserrors.FatalError(errors.New("Max transfer limit reached as set by --max-transfer"))

+ func SetBwLimit(bandwidth fs.SizeSuffix)

+ func StartTokenBucket()

+ func StartTokenTicker()

+ func StatsGroupFromContext(ctx context.Context) (string, bool)

+ func WithStatsGroup(parent context.Context, group string) context.Context

+ type Account struct

+ 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 rc.Params)

+ 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 GlobalStats() *StatsInfo

+ func NewStats() *StatsInfo

+ func NewStatsGroup(group string) *StatsInfo

+ func Stats(ctx context.Context) *StatsInfo

+ func StatsGroup(group string) *StatsInfo

+ func (s *StatsInfo) AddTransfer(transfer *Transfer)

+ func (s *StatsInfo) Bytes(bytes int64)

+ 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) NewCheckingTransfer(obj fs.Object) *Transfer

+ func (s *StatsInfo) NewTransfer(obj fs.Object) *Transfer

+ func (s *StatsInfo) NewTransferRemoteSize(remote string, size int64) *Transfer

+ func (s *StatsInfo) RemoteStats() (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) Transferred() []TransferSnapshot

+ type Transfer struct

+ func (tr *Transfer) Account(in io.ReadCloser) *Account

+ func (tr *Transfer) Done(err error)

+ func (tr *Transfer) IsDone() bool

+ func (tr *Transfer) Snapshot() TransferSnapshot

+ func (tr *Transfer) TimeRange() (time.Time, time.Time)

+ type TransferSnapshot struct

+ Bytes int64

+ Checked bool

+ CompletedAt time.Time

+ Error error

+ Name string

+ Size int64

+ StartedAt time.Time

+ func (as TransferSnapshot) MarshalJSON() ([]byte, error)

+ type WrapFn func(io.Reader) io.Reader

+ func UnWrap(in io.Reader) (unwrapped io.Reader, wrap WrapFn)