Versions in this module Expand all Collapse all v0 v0.6.20 Feb 26, 2019 Changes in this version + const BufferEvent + const CommitEvent + const DataWrittenEvent + const WriteDurationEvent + const WrittenPartEvent + type Committer struct v0.6.15 May 16, 2018 v0.6.14 Apr 20, 2018 v0.6.12 Mar 11, 2018 Changes in this version + const Blob + const BlobToPerf + const BlockBlob + const File + const HTTP + const NA + const PageBlob + const Perf + const PerfToBlock + const PerfToPage + const S3 + func ParseTransferSegment(def Definition) (TransferSegment, TransferSegment) type Transfer + func (t *Transfer) SetTransferTracker(tracker *internal.TransferTracker) + type TransferSegment string v0.5.25 Jan 30, 2018 v0.5.23 Jan 18, 2018 v0.5.22 Jan 17, 2018 Changes in this version + const BlobToBlock + const BlobToPage + const S3ToBlock + const S3ToPage v0.5.14 Dec 8, 2017 v0.5.13 Dec 2, 2017 v0.5.12 Nov 30, 2017 v0.5.10 Nov 13, 2017 Changes in this version + const BlobToFile + const DupeCheckLevelStr + const FileToBlock + const FileToPage + const HTTPToBlock + const HTTPToFile + const HTTPToPage + type Channels struct + Partitions chan pipeline.PartsPartition + Parts chan pipeline.Part + ReadParts chan pipeline.Part + Results chan pipeline.WorkerResult + type Definition string + func ParseTransferDefinition(str string) (Definition, error) + type DupeCheckLevel int + const Full + const None + const ZeroOnly + func ParseDupeCheckLevel(str string) (res DupeCheckLevel, err error) + func (d *DupeCheckLevel) ToString() string + type ProgressUpdate func(results pipeline.WorkerResult, committedCount int, bufferSize int) + type StatInfo struct + CumWriteDuration time.Duration + Duration time.Duration + NumberOfFiles int + TargetRetries int32 + TotalNumberOfBlocks int + TotalSize uint64 + type Stats struct + func NewStats(numberOfWorkers int, numberOfReaders int) *Stats + func (t *Stats) AddTransferInfo(info *StatInfo) + func (t *Stats) DisplaySummary() + type TimeStatsInfo struct + CumWriteDuration time.Duration + Duration time.Duration + StartTime time.Time + type Transfer struct + ControlChannels *Channels + NumOfReaders int + NumOfWorkers int + SourcePipeline *pipeline.SourcePipeline + SyncWaitGroups *WaitGroups + TargetPipeline *pipeline.TargetPipeline + ThreadTarget int + TimeStats *TimeStatsInfo + TotalNumOfBlocks int + TotalSize uint64 + func NewTransfer(source *pipeline.SourcePipeline, target *pipeline.TargetPipeline, readers int, ...) *Transfer + func (t *Transfer) GetStats() *StatInfo + func (t *Transfer) StartTransfer(dupeLevel DupeCheckLevel, progressBarDelegate ProgressUpdate) + func (t *Transfer) WaitForCompletion() (time.Duration, time.Duration) + type WaitGroups struct + Commits sync.WaitGroup + Readers sync.WaitGroup + Workers sync.WaitGroup + type Worker struct + Result chan pipeline.WorkerResult + Wg *sync.WaitGroup + WorkerID int + WorkerQueue chan pipeline.Part