ste

package

Go to main page

Versions in this module

v10

v10.27.1

Nov 13, 2024

v10.27.0

Oct 29, 2024

v10.26.0

Jul 31, 2024

v10.25.1

Jun 12, 2024

v10.25.0

May 28, 2024

v10.25.0-Preview-1

Apr 2, 2024

v10.24.0

Mar 26, 2024

Changes in this version

+ var FilesServiceMaxSDDLSize = 8000

type JobPartPlanDstBlob

+ PutBlobSize int64

type TransferInfo

+ PutBlobSize int64

v10.23.0

Jan 23, 2024

Changes in this version

+ func NewSourceAuthPolicy(cred azcore.TokenCredential) policy.Policy

type AddJobPartArgs

+ SrcIsOAuth bool

type IJobPartMgr

+ SourceIsOAuth func() bool

+ type IJobPartPlanHeader interface

+ CommandString func() string

+ GetRelativeSrcDstStrings func(transferIndex uint32) (source string, destination string)

+ JobPartStatus func() common.JobStatus

+ JobStatus func() common.JobStatus

+ SetJobPartStatus func(newJobStatus common.JobStatus)

+ SetJobStatus func(newJobStatus common.JobStatus)

+ Transfer func(transferIndex uint32) *JobPartPlanTransfer

+ TransferSrcDstRelatives func(transferIndex uint32) (relSource string, relDest string)

+ TransferSrcDstStrings func(transferIndex uint32) (source string, destination string, isFolder bool)

+ TransferSrcPropertiesAndMetadata func(transferIndex uint32) (h common.ResourceHTTPHeaders, metadata common.Metadata, blobType blob.BlobType, ...)

v10.22.2

Jan 9, 2024

Changes in this version

type TransferInfo

+ SnapshotID string

+ VersionID string

v10.22.1

Dec 19, 2023

v10.22.0

Dec 5, 2023

Changes in this version

+ const BlockBlobDefaultData

+ func BlockIDIntToBase64(blockID int) string

+ func CreateNewContainer(t *testing.T, a *assert.Assertions, bsc *blobservice.Client) (cc *container.Client, name string)

+ func DeleteContainer(a *assert.Assertions, cc *container.Client)

+ func GenerateBlockIDsList(count int) []string

+ func GetAccountAndKey() (string, string)

+ func GetBlobServiceClient() *blobservice.Client

+ func GetContainerClient(t *testing.T, bsc *blobservice.Client) (container *container.Client, name string)

+ func NewVersionPolicy() policy.Policy

+ type AddJobPartArgs struct

+ CompletionChan chan struct{}

+ DstClient *common.ServiceClient

+ ExistingPlanMMF *JobPartPlanMMF

+ PartNum PartNumber

+ PlanFile JobPartPlanFileName

+ ScheduleTransfers bool

+ SourceTokenCred common.AuthTokenFunction

+ SrcClient *common.ServiceClient

+ type DatalakeClientStub interface

+ BlobURL func() string

+ DFSURL func() string

+ type FileClientStub interface

+ URL func() string

type IJobMgr

+ AddJobPart2 func(args *AddJobPartArgs) IJobPartMgr

type IJobPartMgr

+ DeleteDestinationFileIfNecessary func() bool

+ DstServiceClient func() *common.ServiceClient

+ From func() *common.Location

+ S2SSourceTokenCredential func(context.Context) (*string, error)

+ SourceTrailingDot func() *common.TrailingDotOption

+ SrcServiceClient func() *common.ServiceClient

+ TrailingDot func() *common.TrailingDotOption

type IJobPartTransferMgr

+ DeleteDestinationFileIfNecessary func() bool

+ DstServiceClient func() *common.ServiceClient

+ From func() *common.Location

+ SourceTrailingDot func() *common.TrailingDotOption

+ SrcServiceClient func() *common.ServiceClient

+ TrailingDot func() *common.TrailingDotOption

type ISourceInfoProvider

+ GetMD5 func(offset, count int64) ([]byte, error)

type JobPartPlanDstBlob

+ DeleteDestinationFileIfNecessary bool

+ type RetryCodes map[int]StorageErrorCodes

+ var RetryStatusCodes RetryCodes

+ func ParseRetryCodes(s string) (RetryCodes, error)

+ type StorageErrorCodes map[string]struct

+ func ParseStorageErrorCodes(s string) StorageErrorCodes

type TransferInfo

+ DstContainer string

+ DstFilePath string

+ SrcContainer string

+ SrcFilePath string

v10.22.0-Preview

Oct 23, 2023

v10.21.2

Nov 1, 2023

v10.21.1

Oct 25, 2023

v10.21.0

Sep 29, 2023

Changes in this version

+ const FileAttributeArchive

+ const FileAttributeHidden

+ const FileAttributeNoScrubData

+ const FileAttributeNone

+ const FileAttributeNotContentIndexed

+ const FileAttributeOffline

+ const FileAttributeReadonly

+ const FileAttributeSystem

+ const FileAttributeTemporary

+ func FileAttributesFromUint32(attributes uint32) (*file.NTFSFileAttributes, error)

+ func FileAttributesToUint32(attributes file.NTFSFileAttributes) uint32

+ func NewClientOptions(retry policy.RetryOptions, telemetry policy.TelemetryOptions, ...) azcore.ClientOptions

+ func NewTrailingDotPolicy(trailingDot *common.TrailingDotOption, from *common.Location) policy.Policy

+ type IBlobClient interface

+ GetAccountInfo func(ctx context.Context, o *blob.GetAccountInfoOptions) (blob.GetAccountInfoResponse, error)

+ URL func() string

type IJobPartMgr

+ ClientOptions func() azcore.ClientOptions

+ CredentialInfo func() common.CredentialInfo

+ CredentialOpOptions func() *common.CredentialOpOptions

+ Pipeline func() pipeline.Pipeline

+ S2SSourceClientOptions func() azcore.ClientOptions

+ S2SSourceCredentialInfo func() common.CredentialInfo

type IJobPartTransferMgr

+ ClientOptions func() azcore.ClientOptions

+ CredentialInfo func() common.CredentialInfo

+ CredentialOpOptions func() *common.CredentialOpOptions

+ GetS2SSourceTokenCredential func(ctx context.Context) (token *string, err error)

+ Pipeline func() pipeline.Pipeline

+ S2SSourceClientOptions func() azcore.ClientOptions

+ S2SSourceCredentialInfo func() common.CredentialInfo

+ type LogOptions struct

+ Log func(level common.LogLevel, message string)

+ RequestLogOptions RequestLogOptions

+ ShouldLog func(level common.LogLevel) bool

+ func (o LogOptions) ToPipelineLogOptions() pipeline.LogOptions

+ type URLHolderV1 interface

+ String func() string

+ URL func() url.URL

v10.21.0-Preview

Aug 15, 2023

v10.20.1

Aug 8, 2023

v10.20.0

Jul 26, 2023

v10.19.0

May 30, 2023

Changes in this version

+ var LogBlobConversionOnce = &sync.Once

+ func DeleteHNSResource(jptm IJobPartTransferMgr, p pipeline.Pipeline, pacer pacer)

+ func NewTrailingDotPolicyFactory(trailingDot common.TrailingDotOption) pipeline.Factory

type IJobPartMgr

+ SecondarySourceProviderPipeline func() pipeline.Pipeline

type IJobPartTransferMgr

+ SecondarySourceProviderPipeline func() pipeline.Pipeline

+ type JobPartPlanDstFile struct

+ TrailingDot common.TrailingDotOption

type JobPartPlanHeader

+ BlobFSRecursiveDelete bool

+ DstFileData JobPartPlanDstFile

+ func (jpph *JobPartPlanHeader) GetRelativeSrcDstStrings(transferIndex uint32) (source, destination string)

type TransferInfo

+ BlobFSRecursiveDelete bool

v10.18.1

Apr 20, 2023

v10.18.0

Mar 31, 2023

Changes in this version

type IJobPartTransferMgr

+ RestartedTransfer func() bool

+ TransferIndex func() (partNum, transferIndex uint32)

+ type ISymlinkBearingSourceInfoProvider interface

+ ReadLink func() (string, error)

type JobPartCreatedMsg

+ SymlinkTransfers uint32

+ type StatTAdapter unix.Stat_t — linux/amd64

+ func (s StatTAdapter) ATime() time.Time

+ func (s StatTAdapter) Attribute() uint64

+ func (s StatTAdapter) AttributeMask() uint64

+ func (s StatTAdapter) BTime() time.Time

+ func (s StatTAdapter) CTime() time.Time

+ func (s StatTAdapter) Device() uint64

+ func (s StatTAdapter) Extended() bool

+ func (s StatTAdapter) FileMode() uint32

+ func (s StatTAdapter) Group() uint32

+ func (s StatTAdapter) INode() uint64

+ func (s StatTAdapter) MTime() time.Time

+ func (s StatTAdapter) NLink() uint64

+ func (s StatTAdapter) Owner() uint32

+ func (s StatTAdapter) RDevice() uint64

+ func (s StatTAdapter) StatxMask() uint32

+ type StatxTAdapter unix.Statx_t — linux/amd64

+ func (s StatxTAdapter) ATime() time.Time

+ func (s StatxTAdapter) Attribute() uint64

+ func (s StatxTAdapter) AttributeMask() uint64

+ func (s StatxTAdapter) BTime() time.Time

+ func (s StatxTAdapter) CTime() time.Time

+ func (s StatxTAdapter) Device() uint64

+ func (s StatxTAdapter) Extended() bool

+ func (s StatxTAdapter) FileMode() uint32

+ func (s StatxTAdapter) Group() uint32

+ func (s StatxTAdapter) INode() uint64

+ func (s StatxTAdapter) MTime() time.Time

+ func (s StatxTAdapter) NLink() uint64

+ func (s StatxTAdapter) Owner() uint32

+ func (s StatxTAdapter) RDevice() uint64

+ func (s StatxTAdapter) StatxMask() uint32

type TransferInfo

+ func (i TransferInfo) IsFilePropertiesTransfer() bool

v10.17.0

Jan 23, 2023

Changes in this version

+ type HandleInfo struct — linux/amd64

+ func (hi HandleInfo) FileAttributes() azfile.FileAttributeFlags

+ func (hi HandleInfo) FileCreationTime() time.Time

+ func (hi HandleInfo) FileLastWriteTime() time.Time

v10.16.2

Nov 7, 2022

Changes in this version

type IJobPartTransferMgr

+ SuccessfulBytesTransferred func() int64

v10.16.1

Oct 5, 2022

Changes in this version

type IJobPartMgr

+ SourceCredential func() pipeline.Factory

type IJobPartTransferMgr

+ SourceCredential func() pipeline.Factory

v10.16.0

Jul 21, 2022

Changes in this version

+ func SetProperties(jptm IJobPartTransferMgr, p pipeline.Pipeline, pacer pacer)

type IJobMgr

+ DeferredCleanupJobMgr func()

type IJobPartMgr

+ PropertiesToTransfer func() common.SetPropertiesFlags

type IJobPartTransferMgr

+ PropertiesToTransfer func() common.SetPropertiesFlags

+ ResetSourceSize func()

+ type IUNIXPropertyBearingSourceInfoProvider interface

+ GetUNIXProperties func() (common.UnixStatAdapter, error)

+ HasUNIXProperties func() bool

type JobPartPlanDstBlob

+ SetPropertiesFlags common.SetPropertiesFlags

type JobPartPlanHeader

+ PreservePOSIXProperties bool

+ RehydratePriority common.RehydratePriorityType

type TransferInfo

+ PreservePOSIXProperties bool

+ RehydratePriority azblob.RehydratePriorityType

v10.15.0

May 10, 2022

Changes in this version

+ const ConcurrencyReasonNone

+ const ConcurrencyReasonTunerDisabled

+ const JobPartPlanFileNameFormat

+ var EnvironmentMimeMap map[string]string

+ func NewNullAutoPacer() *nullAutoPacer

+ func NewTokenBucketPacer(bytesPerSecond int64, expectedBytesPerCoarseRequest int64) *tokenBucketPacer

type IJobMgr

+ func NewJobMgr(concurrency ConcurrencySettings, jobID common.JobID, appCtx context.Context, ...) IJobMgr

+ AddSuccessfulBytesInActiveFiles func(n int64)

+ CancelPauseJobOrder func(desiredJobStatus common.JobStatus) common.CancelPauseResumeResponse

+ IsDaemon func() bool

+ IterateJobParts func(readonly bool, f func(k common.PartNumber, v IJobPartMgr))

+ Reset func(context.Context, string) IJobMgr

+ ScheduleChunk func(priority common.JobPriority, chunkFunc chunkFunc)

+ ScheduleTransfer func(priority common.JobPriority, jptm IJobPartTransferMgr)

+ SetInMemoryTransitJobState func(state InMemoryTransitJobState)

+ SuccessfulBytesInActiveFiles func() uint64

+ TransferDirection func() common.TransferDirection

type IJobPartTransferMgr

+ GetS2SSourceBlobTokenCredential func() azblob.TokenCredential

type InMemoryTransitJobState

+ CredentialInfo common.CredentialInfo

+ S2SSourceCredentialType common.CredentialType

+ type JobLogLCMWrapper struct

+ JobManager IJobMgr

+ func (j JobLogLCMWrapper) Progress(builder common.OutputBuilder)

+ type JobPartCreatedMsg struct

+ FileTransfers uint32

+ FolderTransfer uint32

+ IsFinalPart bool

+ TotalBytesEnumerated uint64

+ TotalTransfers uint32

type JobPartPlanHeader

+ func (jpph *JobPartPlanHeader) JobPartStatus() common.JobStatus

+ func (jpph *JobPartPlanHeader) SetJobPartStatus(newJobStatus common.JobStatus)

+ type NullConcurrencyTuner struct

+ FixedValue int

+ func (n *NullConcurrencyTuner) GetFinalState() (finalReason string, finalRecommendedConcurrency int)

+ func (n *NullConcurrencyTuner) GetRecommendedConcurrency(currentMbps int, highCpuUsage bool) (newConcurrency int, reason string)

+ func (n *NullConcurrencyTuner) RequestCallbackWhenStable(callback func()) (callbackAccepted bool)

+ type PacerAdmin interface

+ GetTotalTraffic func() int64

+ type PipelineNetworkStats struct

+ func (s *PipelineNetworkStats) AverageE2EMilliseconds() int

+ func (s *PipelineNetworkStats) GetTotalRetries() int64

+ func (s *PipelineNetworkStats) IOPSServerBusyPercentage() float32

+ func (s *PipelineNetworkStats) IsStarted() bool

+ func (s *PipelineNetworkStats) NetworkErrorPercentage() float32

+ func (s *PipelineNetworkStats) OperationsPerSecond() int

+ func (s *PipelineNetworkStats) OtherServerBusyPercentage() float32

+ func (s *PipelineNetworkStats) ThroughputServerBusyPercentage() float32

+ func (s *PipelineNetworkStats) TotalServerBusyPercentage() float32

v10.14.1

Mar 14, 2022

v10.14.0

Feb 25, 2022

Changes in this version

type IJobPartTransferMgr

+ PermanentDeleteOption func() common.PermanentDeleteOption

type JobPartPlanFileName

+ func (jppfn *JobPartPlanFileName) Exists() bool

type JobPartPlanHeader

+ PermanentDeleteOption common.PermanentDeleteOption

type JobPartPlanTransfer

+ SrcBlobSnapshotIDLength int16

v10.13.0

Oct 20, 2021

v10.12.2

Sep 20, 2021

Changes in this version

type ConfiguredBool

+ func GetParallelStatFiles() *ConfiguredBool

type ConfiguredInt

+ func GetEnumerationPoolSize() *ConfiguredInt

v10.12.1

Sep 1, 2021

v10.12.0

Aug 31, 2021

Changes in this version

+ var DebugSkipFiles = make(map[string]bool)

+ type FolderCreationTracker common.FolderCreationTracker

+ func NewFolderCreationTracker(fpo common.FolderPropertyOption, plan *JobPartPlanHeader) FolderCreationTracker

+ type JPPTCompatibleFolderCreationTracker interface

+ RegisterPropertiesTransfer func(folder string, transferIndex uint32)

type JobPartPlanHeader

+ PreservePermissions common.PreservePermissionsOption

+ func (jpph *JobPartPlanHeader) TransferSrcDstRelatives(transferIndex uint32) (relSource, relDest string)

v10.11.0

Jun 15, 2021

v10.10.0

Apr 14, 2021

Changes in this version

+ const BlobTagsMaxByte

+ const CustomHeaderMaxBytes

+ const DataSchemaVersion

+ const DownloadMaxRetryDelay

+ const DownloadRetryDelay

+ const DownloadTryTimeout

+ const EMPTY_SAS_STRING

+ const MaxRetryPerDownloadBody

+ const MetadataMaxBytes

+ const PacerTimeToWaitInMs

+ const TagsHeaderMaxLength

+ const UploadMaxRetryDelay

+ const UploadMaxTries

+ const UploadRetryDelay

+ var ADLSFlushThreshold uint32 = 7500

+ var DefaultServiceApiVersion = common.GetLifecycleMgr().GetEnvironmentVariable(common.EEnvironmentVariable.DefaultServiceApiVersion())

+ var EAdviceType = AdviceType

+ var JobsAdmin interface

+ var ServiceAPIVersionOverride = serviceAPIVersionOverride

+ var UploadTryTimeout = time.Minute * 15

+ func BlobTierAllowed(destTier azblob.AccessTierType) bool

+ func CancelPauseJobOrder(jobID common.JobID, desiredJobStatus common.JobStatus) common.CancelPauseResumeResponse

+ func DeleteBlob(jptm IJobPartTransferMgr, p pipeline.Pipeline, pacer pacer)

+ func DeleteFile(jptm IJobPartTransferMgr, p pipeline.Pipeline, pacer pacer)

+ func ExecuteNewCopyJobPartOrder(order common.CopyJobPartOrderRequest) common.CopyJobPartOrderResponse

+ func GetJobFromTo(r common.GetJobFromToRequest) common.GetJobFromToResponse

+ func GetJobLCMWrapper(jobID common.JobID) common.LifecycleMgr

+ func GetJobSummary(jobID common.JobID) common.ListJobSummaryResponse

+ func ListJobTransfers(r common.ListJobTransfersRequest) common.ListJobTransfersResponse

+ func ListJobs(givenStatus common.JobStatus) common.ListJobsResponse

+ func MainSTE(concurrency ConcurrencySettings, targetRateInMegaBitsPerSec float64, ...) error

+ func NewAzcopyHTTPClient(maxIdleConns int) *http.Client

+ func NewBFSXferRetryPolicyFactory(o XferRetryOptions) pipeline.Factory

+ func NewBlobFSPipeline(c azbfs.Credential, o azbfs.PipelineOptions, r XferRetryOptions, p pacer, ...) pipeline.Pipeline

+ func NewBlobPipeline(c azblob.Credential, o azblob.PipelineOptions, r XferRetryOptions, p pacer, ...) pipeline.Pipeline

+ func NewBlobXferRetryPolicyFactory(o XferRetryOptions) pipeline.Factory

+ func NewFilePipeline(c azfile.Credential, o azfile.PipelineOptions, r azfile.RetryOptions, p pacer, ...) pipeline.Pipeline

+ func NewRequestLogPolicyFactory(o RequestLogOptions) pipeline.Factory

+ func NewVersionPolicyFactory() pipeline.Factory

+ func ResumeJobOrder(req common.ResumeJobRequest) common.CancelPauseResumeResponse

+ func ToFixed(num float64, precision int) float64

+ func ValidateTier(jptm IJobPartTransferMgr, blobTier azblob.AccessTierType, ...) (isValid bool)

+ type AdviceType struct

+ func (AdviceType) AccountIOPS() AdviceType

+ func (AdviceType) AccountThroughput() AdviceType

+ func (AdviceType) ConcurrencyHighCpu() AdviceType

+ func (AdviceType) ConcurrencyHitUpperLimit() AdviceType

+ func (AdviceType) ConcurrencyNotEnoughTime() AdviceType

+ func (AdviceType) ConcurrencyNotTuned() AdviceType

+ func (AdviceType) FileShareOrNetwork() AdviceType

+ func (AdviceType) MbpsCapped() AdviceType

+ func (AdviceType) NetworkErrors() AdviceType

+ func (AdviceType) NetworkIsBottleneck() AdviceType

+ func (AdviceType) NetworkNotBottleneck() AdviceType

+ func (AdviceType) ServerBusy() AdviceType

+ func (AdviceType) SmallFilesOrNetwork() AdviceType

+ func (AdviceType) VMSize() AdviceType

+ type AzureFileParentDirCreator struct

+ func (d AzureFileParentDirCreator) CreateDirToRoot(ctx context.Context, dirURL azfile.DirectoryURL, p pipeline.Pipeline, ...) error

+ func (d AzureFileParentDirCreator) CreateParentDirToRoot(ctx context.Context, fileURL azfile.FileURL, p pipeline.Pipeline, ...) error

+ type ConcurrencySettings struct

+ CheckCpuWhenTuning *ConfiguredBool

+ EnumerationPoolSize *ConfiguredInt

+ InitialMainPoolSize int

+ MaxIdleConnections int

+ MaxMainPoolSize *ConfiguredInt

+ MaxOpenDownloadFiles int

+ ParallelStatFiles *ConfiguredBool

+ TransferInitiationPoolSize *ConfiguredInt

+ func NewConcurrencySettings(maxFileAndSocketHandles int, requestAutoTuneGRs bool) ConcurrencySettings

+ func (c ConcurrencySettings) AutoTuneMainPool() bool

+ type ConcurrencyTuner interface

+ GetFinalState func() (finalReason string, finalRecommendedConcurrency int)

+ RequestCallbackWhenStable func(callback func()) (callbackAccepted bool)

+ func NewAutoConcurrencyTuner(initial, max int, isBenchmarking bool) ConcurrencyTuner

+ type ConfiguredBool struct

+ DefaultSourceDesc string

+ EnvVarName string

+ IsUserSpecified bool

+ Value bool

+ func (b *ConfiguredBool) GetDescription() string

+ type ConfiguredInt struct

+ DefaultSourceDesc string

+ EnvVarName string

+ IsUserSpecified bool

+ Value int

+ func (i *ConfiguredInt) GetDescription() string

+ type CoordinatorChannels struct

+ type ErrorEx struct

+ func (errex ErrorEx) ErrorCodeAndString() (string, int, string)

+ func (errex ErrorEx) MSRequestID() string

+ type HandleInfo struct — windows/amd64

+ func (hi HandleInfo) FileAttributes() azfile.FileAttributeFlags

+ func (hi HandleInfo) FileCreationTime() time.Time

+ func (hi HandleInfo) FileLastWriteTime() time.Time

+ type IBlobSourceInfoProvider interface

+ BlobTier func() azblob.AccessTierType

+ BlobType func() azblob.BlobType

+ type ICustomLocalOpener interface

+ Open func(path string) (*os.File, error)

+ type IJobMgr interface

+ ActiveConnections func() int64

+ AddJobPart func(partNum PartNumber, planFile JobPartPlanFileName, ...) IJobPartMgr

+ AllTransfersScheduled func() bool

+ Cancel func()

+ ChunkStatusLogger func() common.ChunkStatusLogger

+ ConfirmAllTransfersScheduled func()

+ Context func() context.Context

+ GetPerfInfo func() (displayStrings []string, constraint common.PerfConstraint)

+ HttpClient func() *http.Client

+ IncludeExclude func() (map[string]int, map[string]int)

+ JobID func() common.JobID

+ JobPartMgr func(partNum PartNumber) (IJobPartMgr, bool)

+ ListJobSummary func() common.ListJobSummaryResponse

+ OccupyAConnection func()

+ PipelineLogInfo func() pipeline.LogOptions

+ PipelineNetworkStats func() *pipelineNetworkStats

+ ReleaseAConnection func()

+ ReportJobPartDone func(jobPartProgressInfo)

+ ResetAllTransfersScheduled func()

+ ResumeTransfers func(appCtx context.Context)

+ ResurrectSummary func(js common.ListJobSummaryResponse)

+ SendJobPartCreatedMsg func(msg jobPartCreatedMsg)

+ SendXferDoneMsg func(msg xferDoneMsg)

+ SetIncludeExclude func(map[string]int, map[string]int)

+ TryGetPerformanceAdvice func(bytesInJob uint64, filesInJob uint32, fromTo common.FromTo) []common.PerformanceAdvice

+ type IJobPartMgr interface

+ AutoDecompress func() bool

+ BlobTiers func() (blockBlobTier common.BlockBlobTier, pageBlobTier common.PageBlobTier)

+ BlobTypeOverride func() common.BlobType

+ CacheLimiter func() common.CacheLimiter

+ ChunkStatusLogger func() common.ChunkStatusLogger

+ Close func()

+ CpkInfo func() common.CpkInfo

+ CpkScopeInfo func() common.CpkScopeInfo

+ ExclusiveDestinationMap func() *common.ExclusiveStringMap

+ FileCountLimiter func() common.CacheLimiter

+ FolderDeletionManager func() common.FolderDeletionManager

+ GetForceIfReadOnly func() bool

+ GetOverwriteOption func() common.OverwriteOption

+ IsSourceEncrypted func() bool

+ OccupyAConnection func()

+ Plan func() *JobPartPlanHeader

+ ReleaseAConnection func()

+ ReportTransferDone func(status common.TransferStatus) uint32

+ RescheduleTransfer func(jptm IJobPartTransferMgr)

+ SAS func() (string, string)

+ ScheduleChunks func(chunkFunc chunkFunc)

+ ScheduleTransfers func(jobCtx context.Context)

+ SecurityInfoPersistenceManager func() *securityInfoPersistenceManager

+ SendXferDoneMsg func(msg xferDoneMsg)

+ ShouldPutMd5 func() bool

+ SlicePool func() common.ByteSlicePooler

+ SourceProviderPipeline func() pipeline.Pipeline

+ StartJobXfer func(jptm IJobPartTransferMgr)

+ type IJobPartTransferMgr interface

+ BlobTiers func() (blockBlobTier common.BlockBlobTier, pageBlobTier common.PageBlobTier)

+ BlobTypeOverride func() common.BlobType

+ CacheLimiter func() common.CacheLimiter

+ Cancel func()

+ ChunkStatusLogger func() common.ChunkStatusLogger

+ Context func() context.Context

+ CpkInfo func() common.CpkInfo

+ CpkScopeInfo func() common.CpkScopeInfo

+ DeleteSnapshotsOption func() common.DeleteSnapshotsOption

+ EnsureDestinationUnlocked func()

+ FailActiveDownload func(where string, err error)

+ FailActiveDownloadWithStatus func(where string, err error, failureStatus common.TransferStatus)

+ FailActiveS2SCopy func(where string, err error)

+ FailActiveS2SCopyWithStatus func(where string, err error, failureStatus common.TransferStatus)

+ FailActiveSend func(where string, err error)

+ FailActiveSendWithStatus func(where string, err error, failureStatus common.TransferStatus)

+ FailActiveUpload func(where string, err error)

+ FailActiveUploadWithStatus func(where string, err error, failureStatus common.TransferStatus)

+ FolderDeletionManager func() common.FolderDeletionManager

+ FromTo func() common.FromTo

+ GetDestinationRoot func() string

+ GetFolderCreationTracker func() common.FolderCreationTracker

+ GetForceIfReadOnly func() bool

+ GetOverwriteOption func() common.OverwriteOption

+ GetOverwritePrompter func() *overwritePrompter

+ GetSourceCompressionType func() (common.CompressionType, error)

+ HoldsDestinationLock func() bool

+ Info func() TransferInfo

+ IsDeadBeforeStart func() bool

+ IsDeadInflight func() bool

+ IsLive func() bool

+ IsSourceEncrypted func() bool

+ JobHasLowFileCount func() bool

+ LastModifiedTime func() time.Time

+ LogAtLevelForCurrentTransfer func(level pipeline.LogLevel, msg string)

+ LogChunkStatus func(id common.ChunkID, reason common.WaitReason)

+ LogDownloadError func(source, destination, errorMsg string, status int)

+ LogError func(resource, context string, err error)

+ LogS2SCopyError func(source, destination, errorMsg string, status int)

+ LogSendError func(source, destination, errorMsg string, status int)

+ LogTransferInfo func(level pipeline.LogLevel, source, destination, msg string)

+ LogTransferStart func(source, destination, description string)

+ LogUploadError func(source, destination, errorMsg string, status int)

+ MD5ValidationOption func() common.HashValidationOption

+ OccupyAConnection func()

+ PreserveLastModifiedTime func() (time.Time, bool)

+ ReleaseAConnection func()

+ ReportChunkDone func(id common.ChunkID) (lastChunk bool, chunksDone uint32)

+ ReportTransferDone func() uint32

+ RescheduleTransfer func()

+ ResourceDstData func(dataFileToXfer []byte) (headers common.ResourceHTTPHeaders, metadata common.Metadata, ...)

+ ScheduleChunks func(chunkFunc chunkFunc)

+ SecurityInfoPersistenceManager func() *securityInfoPersistenceManager

+ SetActionAfterLastChunk func(f func())

+ SetDestinationIsModified func()

+ SetErrorCode func(errorCode int32)

+ SetNumberOfChunks func(numChunks uint32)

+ SetStatus func(status common.TransferStatus)

+ ShouldDecompress func() bool

+ ShouldInferContentType func() bool

+ ShouldPutMd5 func() bool

+ SlicePool func() common.ByteSlicePooler

+ SourceProviderPipeline func() pipeline.Pipeline

+ StartJobXfer func()

+ TransferStatusIgnoringCancellation func() common.TransferStatus

+ WaitUntilLockDestination func(ctx context.Context) error

+ WasCanceled func() bool

+ type ILocalSourceInfoProvider interface

+ OpenSourceFile func() (common.CloseableReaderAt, error)

+ type IRemoteSourceInfoProvider interface

+ PreSignedSourceURL func() (*url.URL, error)

+ RawSource func() string

+ SourceSize func() int64

+ type ISMBPropertyBearingSourceInfoProvider interface

+ GetSDDL func() (string, error)

+ GetSMBProperties func() (TypedSMBPropertyHolder, error)

+ type ISourceInfoProvider interface

+ EntityType func() common.EntityType

+ GetFreshFileLastModifiedTime func() (time.Time, error)

+ IsLocal func() bool

+ Properties func() (*SrcProperties, error)

+ type InMemoryTransitJobState struct

+ type JobPartPlanDstBlob struct

+ BlobTags [BlobTagsMaxByte]byte

+ BlobTagsLength uint16

+ BlobType common.BlobType

+ BlockBlobTier common.BlockBlobTier

+ BlockSize int64

+ CacheControl [CustomHeaderMaxBytes]byte

+ CacheControlLength uint16

+ ContentDisposition [CustomHeaderMaxBytes]byte

+ ContentDispositionLength uint16

+ ContentEncoding [CustomHeaderMaxBytes]byte

+ ContentEncodingLength uint16

+ ContentLanguage [CustomHeaderMaxBytes]byte

+ ContentLanguageLength uint16

+ ContentType [CustomHeaderMaxBytes]byte

+ ContentTypeLength uint16

+ CpkInfo bool

+ CpkScopeInfo [CustomHeaderMaxBytes]byte

+ CpkScopeInfoLength uint16

+ IsSourceEncrypted bool

+ Metadata [MetadataMaxBytes]byte

+ MetadataLength uint16

+ NoGuessMimeType bool

+ PageBlobTier common.PageBlobTier

+ PutMd5 bool

+ type JobPartPlanDstLocal struct

+ MD5VerificationOption common.HashValidationOption

+ PreserveLastModifiedTime bool

+ type JobPartPlanFileName string

+ func (jpfn JobPartPlanFileName) Create(order common.CopyJobPartOrderRequest)

+ func (jpfn JobPartPlanFileName) Delete() error

+ func (jpfn JobPartPlanFileName) Map() *JobPartPlanMMF

+ func (jpfn JobPartPlanFileName) Parse() (jobID common.JobID, partNumber common.PartNumber, err error)

+ func (jppfn *JobPartPlanFileName) GetJobPartPlanPath() string

+ type JobPartPlanHeader struct

+ AutoDecompress bool

+ CommandStringLength uint32

+ DeleteSnapshotsOption common.DeleteSnapshotsOption

+ DestExtraQuery [1000]byte

+ DestExtraQueryLength uint16

+ DestLengthValidation bool

+ DestinationRoot [1000]byte

+ DestinationRootLength uint16

+ DstBlobData JobPartPlanDstBlob

+ DstLocalData JobPartPlanDstLocal

+ ForceIfReadOnly bool

+ ForceWrite common.OverwriteOption

+ Fpo common.FolderPropertyOption

+ FromTo common.FromTo

+ IsFinalPart bool

+ JobID common.JobID

+ LogLevel common.LogLevel

+ NumTransfers uint32

+ PartNum common.PartNumber

+ PreserveSMBInfo bool

+ PreserveSMBPermissions common.PreservePermissionsOption

+ Priority common.JobPriority

+ S2SGetPropertiesInBackend bool

+ S2SInvalidMetadataHandleOption common.InvalidMetadataHandleOption

+ S2SSourceChangeValidation bool

+ SourceExtraQuery [1000]byte

+ SourceExtraQueryLength uint16

+ SourceRoot [1000]byte

+ SourceRootLength uint16

+ StartTime int64

+ TTLAfterCompletion uint32

+ Version common.Version

+ func (jpph *JobPartPlanHeader) CommandString() string

+ func (jpph *JobPartPlanHeader) JobStatus() common.JobStatus

+ func (jpph *JobPartPlanHeader) SetJobStatus(newJobStatus common.JobStatus)

+ func (jpph *JobPartPlanHeader) Transfer(transferIndex uint32) *JobPartPlanTransfer

+ func (jpph *JobPartPlanHeader) TransferSrcDstStrings(transferIndex uint32) (source, destination string, isFolder bool)

+ func (jpph *JobPartPlanHeader) TransferSrcPropertiesAndMetadata(transferIndex uint32) (h common.ResourceHTTPHeaders, metadata common.Metadata, ...)

+ type JobPartPlanMMF common.MMF

+ func (mmf *JobPartPlanMMF) Plan() *JobPartPlanHeader

+ func (mmf *JobPartPlanMMF) Unmap()

+ type JobPartPlanTransfer struct

+ CompletionTime uint64

+ DstLength int16

+ EntityType common.EntityType

+ ModifiedTime int64

+ SourceSize int64

+ SrcBlobTagsLength int16

+ SrcBlobTierLength int16

+ SrcBlobTypeLength int16

+ SrcBlobVersionIDLength int16

+ SrcCacheControlLength int16

+ SrcContentDispositionLength int16

+ SrcContentEncodingLength int16

+ SrcContentLanguageLength int16

+ SrcContentMD5Length int16

+ SrcContentTypeLength int16

+ SrcLength int16

+ SrcMetadataLength int16

+ SrcOffset int64

+ func (jppt *JobPartPlanTransfer) ErrorCode() int32

+ func (jppt *JobPartPlanTransfer) SetErrorCode(errorCode int32, overwrite bool)

+ func (jppt *JobPartPlanTransfer) SetTransferStatus(status common.TransferStatus, overWrite bool)

+ func (jppt *JobPartPlanTransfer) TransferStatus() common.TransferStatus

+ type PartNumber = common.PartNumber

+ type PerformanceAdvisor struct

+ func NewPerformanceAdvisor(stats *pipelineNetworkStats, commandLineMbpsCap float64, mbps int64, ...) *PerformanceAdvisor

+ func (p *PerformanceAdvisor) GetAdvice() []common.PerformanceAdvice

+ type RequestLogOptions struct

+ LogWarningIfTryOverThreshold time.Duration

+ SyslogDisabled bool

+ type SrcProperties struct

+ SrcBlobTags common.BlobTags

+ SrcHTTPHeaders common.ResourceHTTPHeaders

+ SrcMetadata common.Metadata

+ type TransferInfo struct

+ BlockSize int64

+ DestLengthValidation bool

+ Destination string

+ EntityType common.EntityType

+ JobID common.JobID

+ NumChunks uint16

+ PreserveSMBInfo bool

+ PreserveSMBPermissions common.PreservePermissionsOption

+ S2SGetPropertiesInBackend bool

+ S2SInvalidMetadataHandleOption common.InvalidMetadataHandleOption

+ S2SSourceChangeValidation bool

+ S2SSrcBlobTier azblob.AccessTierType

+ Source string

+ SourceSize int64

+ SrcBlobType azblob.BlobType

+ func (i TransferInfo) IsFolderPropertiesTransfer() bool

+ func (i TransferInfo) ShouldTransferLastWriteTime() bool

+ type TypedSMBPropertyHolder interface

+ FileAttributes func() azfile.FileAttributeFlags

+ FileCreationTime func() time.Time

+ FileLastWriteTime func() time.Time

+ type URLHolder interface

+ String func() string

+ URL func() url.URL

+ type XferChannels struct

+ type XferRetryOptions struct

+ MaxRetryDelay time.Duration

+ MaxTries int32

+ Policy XferRetryPolicy

+ RetryDelay time.Duration

+ RetryReadsFromSecondaryHost string

+ TryTimeout time.Duration

+ type XferRetryPolicy int32

+ const RetryPolicyExponential

+ const RetryPolicyFixed

Other modules containing this package

github.com/Azure/azure-storage-azcopy

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL