ste

package

Go to main page

Versions in this module

v10

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