common

package

Go to main page

Versions in this module

v10

v10.12.12

Mar 21, 2022

v10.12.11

Mar 9, 2022

v10.12.10

Mar 8, 2022

v10.12.9

Feb 8, 2022

v10.12.8

Feb 5, 2022

v10.12.7

Feb 5, 2022

Changes in this version

type ILoggerResetable

+ ChangeLogLevel func(pipeline.LogLevel)

v10.12.6

Feb 1, 2022

v10.12.5

Feb 1, 2022

Changes in this version

type ChunkStatusLoggerCloser

+ CloseLogger func()

type TransferDetail

+ ErrorMessage string

v10.12.4

Jan 4, 2022

v10.12.3

Oct 4, 2021

Changes in this version

+ const IMDSAPIVersionArcVM

+ const IMDSAPIVersionAzureVM

+ const MSIEndpointArcVM

+ const MSIEndpointAzureVM

+ const WSAECONNREFUSED

v10.12.2

Sep 22, 2021

v10.12.1

Sep 21, 2021

Changes in this version

+ const AZCOPY_PATH_SEPARATOR_CHAR

+ const AZCOPY_PATH_SEPARATOR_STRING

+ const ApplicationID

+ const AzcopyVersion

+ const BackupModeFlagName

+ const BenchmarkFinalDisclaimer

+ const BenchmarkLinuxExtraDisclaimer

+ const BenchmarkPreviewNotice

+ const BenchmarkUserAgent

+ const BlockSizeThreshold

+ const CPK_ERROR_SERVICE_CODE

+ const DEFAULT_FILE_PERM

+ const DefaultActiveDirectoryEndpoint

+ const DefaultAzureFileChunkSize

+ const DefaultBlockBlobBlockSize

+ const DefaultPageBlobChunkSize

+ const DefaultTenantID

+ const Dev_Null

+ const EXTENDED_PATH_PREFIX

+ const EXTENDED_UNC_PATH_PREFIX

+ const EncryptionAlgorithmAES256

+ const EnvVarOAuthTokenInfo

+ const ErrorCodeEnvVarOAuthTokenInfoNotSet

+ const FILE_ATTRIBUTE_WRITE_THROUGH — windows/amd64

+ const FileCountDefault

+ const FileCountParam

+ const GCPImportUserAgent

+ const IMDSAPIVersion

+ const IncludeAfterFlagName

+ const IncludeBeforeFlagName

+ const MSIEndpoint

+ const MaxAppendBlobBlockSize

+ const MaxBlockBlobBlockSize

+ const MaxNumberOfBlocksPerBlob

+ const MinParallelChunkCountThreshold

+ const OS_PATH_SEPARATOR

+ const PreserveOwnerDefault

+ const PreserveOwnerFlagName

+ const Resource

+ const S3ImportUserAgent

+ const SigAzure

+ const SigXAmzForAws

+ const SizePerFileParam

+ const TokenRefreshSourceTokenStore

+ const TryEquals

+ const UserAgent

+ var AzcopyJobPlanFolder string

+ var BenchmarkLmt = time.Date(1900, 1, 1, 0, 0, 0, 0, time.UTC)

+ var ChunkWriterAlreadyFailed = errors.New("chunk Writer already failed")

+ var DefaultHashValidationOption = EHashValidationOption.FailIfDifferent()

+ var DefaultInvalidMetadataHandleOption = EInvalidMetadataHandleOption.ExcludeIfInvalid()

+ var DefaultTokenExpiryWithinThreshold = time.Minute * 10

+ var EBenchMarkMode = BenchMarkMode(0)

+ var EBlobType = BlobType(0)

+ var EBlockBlobTier = BlockBlobTier(0)

+ var ECompressionType = CompressionType(0)

+ var ECredentialType = CredentialType(0)

+ var EDeleteDestination = DeleteDestination(0)

+ var EDeleteSnapshotsOption = DeleteSnapshotsOption(0)

+ var EEntityType = EntityType(0)

+ var EEnvironmentVariable = EnvironmentVariable

+ var EExitCode = ExitCode(0)

+ var EFolderPropertiesOption = FolderPropertyOption(0)

+ var EFromTo = FromTo(0)

+ var EHashValidationOption = HashValidationOption(0)

+ var EInvalidMetadataHandleOption = InvalidMetadataHandleOption(0)

+ var EJobPriority = JobPriority(0)

+ var EJobStatus = JobStatus(0)

+ var ELocation = Location(0)

+ var ELogLevel = LogLevel(pipeline.LogNone)

+ var EOutputFormat = OutputFormat(0)

+ var EOverwriteOption = OverwriteOption(0)

+ var EPageBlobTier = PageBlobTier(0)

+ var EPerfConstraint = PerfConstraint(0)

+ var EPreservePermissionsOption = PreservePermissionsOption(0)

+ var EPromptType = PromptType("")

+ var EResponseOption = ResponseOption

+ var ERpcCmd = RpcCmd("")

+ var ETransferDirection = TransferDirection(0)

+ var ETransferStatus = TransferStatus(0)

+ var EWaitReason = WaitReason

+ var GlobalTestOAuthInjection = TestOAuthInjection

+ var NewCredCacheInternalIntegration = NewCredCache — darwin/amd64

+ var ProxyLookupTimeoutError = errors.New("proxy lookup timed out")

+ var RootDriveRegex = regexp.MustCompile(`(?i)(^[A-Z]:\/?$)`)

+ var RootShareRegex = regexp.MustCompile(`(^\/\/[^\/]*\/?$)`)

+ var VisibleEnvironmentVariables = []EnvironmentVariable

+ func AtomicMorphInt32(target *int32, morpher AtomicMorpherInt32) interface

+ func AtomicMorphInt64(target *int64, morpher AtomicMorpherInt64) interface

+ func AtomicMorphUint32(target *uint32, morpher AtomicMorpherUint32) interface

+ func AtomicMorphUint64(target *uint64, morpher AtomicMorpherUint64) interface

+ func ConsolidatePathSeparators(path string) string

+ func CreateBlobCredential(ctx context.Context, credInfo CredentialInfo, options CredentialOpOptions) azblob.Credential

+ func CreateBlobFSCredential(ctx context.Context, credInfo CredentialInfo, options CredentialOpOptions) azbfs.Credential

+ func CreateDirectoryIfNotExist(directory string, tracker FolderCreationTracker) error

+ func CreateFileOfSizeWithWriteThroughOption(destinationPath string, fileSize int64, writeThrough bool, ...) (*os.File, error) — darwin/amd64, linux/amd64, windows/amd64

+ func CreateGCPClient(ctx context.Context) (*gcpUtils.Client, error)

+ func CreateParentDirectoryIfNotExist(destinationPath string, tracker FolderCreationTracker) error

+ func CreateS3Client(ctx context.Context, credInfo CredentialInfo, option CredentialOpOptions) (*minio.Client, error)

+ func CreateS3Credential(ctx context.Context, credInfo CredentialInfo, options CredentialOpOptions) (*credentials.Credentials, error)

+ func DeterminePathSeparator(path string) string

+ func DocumentationForDependencyOnChangeDetection()

+ func EnvVarOAuthTokenInfoExists() bool

+ func GenerateFullPath(rootPath, childPath string) string

+ func GenerateFullPathWithQuery(rootPath, childPath, extraQuery string) string

+ func GetBlocksRoundedUp(size uint64, blockSize uint64) uint16

+ func GetClientProvidedKey(options CpkOptions) azblob.ClientProvidedKeyOptions

+ func GetFileInformation(path string) (windows.ByHandleFileInformation, error) — windows/amd64

+ func GetJsonStringFromTemplate(template interface{}) string

+ func IffError(test bool, trueVal, falseVal error) error

+ func IffString(test bool, trueVal, falseVal string) string

+ func IffStringNotNil(wanted *string, instead string) string

+ func IffUint8(test bool, trueVal, falseVal uint8) byte

+ func Iffint16(test bool, trueVal, falseVal int16) int16

+ func Iffint32(test bool, trueVal, falseVal int32) int32

+ func Iffint64(test bool, trueVal, falseVal int64) int64

+ func Iffint8(test bool, trueVal, falseVal int8) int8

+ func Iffloat64(test bool, trueVal, falseVal float64) float64

+ func Iffuint16(test bool, trueVal, falseVal uint16) uint16

+ func Iffuint32(test bool, trueVal, falseVal uint32) uint32

+ func Iffuint64(test bool, trueVal, falseVal uint64) uint64

+ func IsErrorEnvVarOAuthTokenInfoNotSet(err error) bool

+ func IsForceLoggingDisabled() bool

+ func IsGCPURL(u url.URL) bool

+ func IsS3URL(u url.URL) bool

+ func IsShortPath(s string) bool

+ func NewAzCopyLogSanitizer() pipeline.LogSanitizer

+ func NewDecompressingWriter(destination io.WriteCloser, ct CompressionType) io.WriteCloser

+ func NewNullHasher() hash.Hash

+ func NewRandomDataGenerator(length int64) *randomDataGenerator

+ func NewReadLogFunc(logger ILogger, fullUrl *url.URL) func(int, error, int64, int64, bool)

+ func OSOpenFile(name string, flag int, perm os.FileMode) (*os.File, error)

+ func OSStat(name string) (os.FileInfo, error)

+ func OpenWithWriteThroughSetting(path string, mode int, perm uint32, writeThrough bool) (fd windows.Handle, err error) — windows/amd64

+ func PanicIfErr(err error)

+ func RedactSecretQueryParam(rawQuery, queryKeyNeedRedact string) (bool, string)

+ func SetBackupMode(enable bool, fromTo FromTo) error — darwin/amd64, linux/amd64, windows/amd64

+ func ToClientProvidedKeyOptions(cpkInfo CpkInfo, cpkScopeInfo CpkScopeInfo) azblob.ClientProvidedKeyOptions

+ func ToExtendedPath(short string) string

+ func ToShortPath(long string) string

+ type AtomicMorpherInt32 func(startVal int32) (val int32, morphResult interface{})

+ type AtomicMorpherInt64 func(startVal int64) (val int64, morphResult interface{})

+ type AtomicMorpherUint32 func(startVal uint32) (val uint32, morphResult interface{})

+ type AtomicMorpherUint64 func(startVal uint64) (val uint64, morphResult interface{})

+ type AzError struct

+ var EAzError AzError

+ func NewAzError(base AzError, additionalInfo string) AzError

+ func (err AzError) Error() string

+ func (err AzError) ErrorCode() uint64

+ func (err AzError) InvalidBlobName() AzError

+ func (err AzError) LoginCredMissing() AzError

+ func (lhs AzError) Equals(rhs AzError) bool

+ type BenchMarkMode uint8

+ func (BenchMarkMode) Download() BenchMarkMode

+ func (BenchMarkMode) Upload() BenchMarkMode

+ func (bm *BenchMarkMode) Parse(s string) error

+ func (bm BenchMarkMode) String() string

+ type BlobTags map[string]string

+ func ToCommonBlobTagsMap(blobTagsString string) BlobTags

+ func (bt BlobTags) ToAzBlobTagsMap() azblob.BlobTagsMap

+ func (bt BlobTags) ToString() string

+ type BlobTransferAttributes struct

+ BlobTagsString string

+ BlobType BlobType

+ BlockBlobTier BlockBlobTier

+ BlockSizeInBytes int64

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentType string

+ DeleteSnapshotsOption DeleteSnapshotsOption

+ MD5ValidationOption HashValidationOption

+ Metadata string

+ NoGuessMimeType bool

+ PageBlobTier PageBlobTier

+ PreserveLastModifiedTime bool

+ PutMd5 bool

+ type BlobType uint8

+ func FromAzBlobType(bt azblob.BlobType) BlobType

+ func (BlobType) AppendBlob() BlobType

+ func (BlobType) BlockBlob() BlobType

+ func (BlobType) Detect() BlobType

+ func (BlobType) PageBlob() BlobType

+ func (bt *BlobType) Parse(s string) error

+ func (bt *BlobType) ToAzBlobType() azblob.BlobType

+ func (bt BlobType) String() string

+ type BlockBlobTier uint8

+ func (BlockBlobTier) Archive() BlockBlobTier

+ func (BlockBlobTier) Cool() BlockBlobTier

+ func (BlockBlobTier) Hot() BlockBlobTier

+ func (BlockBlobTier) None() BlockBlobTier

+ func (bbt *BlockBlobTier) Parse(s string) error

+ func (bbt *BlockBlobTier) UnmarshalJSON(b []byte) error

+ func (bbt BlockBlobTier) MarshalJSON() ([]byte, error)

+ func (bbt BlockBlobTier) String() string

+ func (bbt BlockBlobTier) ToAccessTierType() azblob.AccessTierType

+ type ByteSlice []byte

+ type ByteSliceExtension struct

+ func (bs ByteSliceExtension) RemoveBOM() []byte

+ type ByteSlicePooler interface

+ Prune func()

+ RentSlice func(desiredLength int64) []byte

+ ReturnSlice func(slice []byte)

+ func NewMultiSizeSlicePool(maxSliceLength int64) ByteSlicePooler

+ type CPUMonitor interface

+ CPUContentionExists func() bool

+ func NewCalibratedCpuUsageMonitor() CPUMonitor

+ func NewNullCpuMonitor() CPUMonitor

+ type CacheLimiter interface

+ Limit func() int64

+ Remove func(count int64)

+ TryAdd func(count int64, useRelaxedLimit bool) (added bool)

+ WaitUntilAdd func(ctx context.Context, count int64, useRelaxedLimit Predicate) error

+ func NewCacheLimiter(limit int64) CacheLimiter

+ type CancelPauseResumeResponse struct

+ CancelledPauseResumed bool

+ ErrorMsg string

+ type ChunkID struct

+ Name string

+ func NewChunkID(name string, offsetInFile int64, length int64) ChunkID

+ func NewPseudoChunkIDForWholeFile(name string) ChunkID

+ func (id ChunkID) IsPseudoChunk() bool

+ func (id ChunkID) Length() int64

+ func (id ChunkID) OffsetInFile() int64

+ func (id ChunkID) SetCompletionNotificationSent()

+ type ChunkReaderSourceFactory func() (CloseableReaderAt, error)

+ type ChunkStatusLogger interface

+ IsWaitingOnFinalBodyReads func() bool

+ LogChunkStatus func(id ChunkID, reason WaitReason)

+ type ChunkStatusLoggerCloser interface

+ FlushLog func()

+ GetCounts func(td TransferDirection) []chunkStatusCount

+ GetPrimaryPerfConstraint func(td TransferDirection, rc RetryCounter) PerfConstraint

+ func NewChunkStatusLogger(jobID JobID, cpuMon CPUMonitor, logFileFolder string, enableOutput bool) ChunkStatusLoggerCloser

+ type ChunkedFileWriter interface

+ EnqueueChunk func(ctx context.Context, id ChunkID, chunkSize int64, chunkContents io.Reader, ...) error

+ Flush func(ctx context.Context) (md5HashOfFileAsWritten []byte, err error)

+ MaxRetryPerDownloadBody func() int

+ WaitToScheduleChunk func(ctx context.Context, id ChunkID, chunkSize int64) error

+ func NewChunkedFileWriter(ctx context.Context, slicePool ByteSlicePooler, cacheLimiter CacheLimiter, ...) ChunkedFileWriter

+ type CloseableReaderAt interface

+ type CompressionType uint8

+ func GetCompressionType(contentEncoding string) (CompressionType, error)

+ func (CompressionType) GZip() CompressionType

+ func (CompressionType) None() CompressionType

+ func (CompressionType) Unsupported() CompressionType

+ func (CompressionType) ZLib() CompressionType

+ func (ct CompressionType) String() string

+ type CopyJobPartOrderErrorType string

+ var ECopyJobPartOrderErrorType CopyJobPartOrderErrorType

+ func (CopyJobPartOrderErrorType) NoTransfersScheduledErr() CopyJobPartOrderErrorType

+ type CopyJobPartOrderRequest struct

+ AutoDecompress bool

+ BlobAttributes BlobTransferAttributes

+ CommandString string

+ CpkOptions CpkOptions

+ CredentialInfo CredentialInfo

+ DestLengthValidation bool

+ DestinationRoot ResourceString

+ ExcludeBlobType []azblob.BlobType

+ ForceIfReadOnly bool

+ ForceWrite OverwriteOption

+ Fpo FolderPropertyOption

+ FromTo FromTo

+ IsFinalPart bool

+ JobID JobID

+ LogLevel LogLevel

+ PartNum PartNumber

+ PreserveSMBInfo bool

+ PreserveSMBPermissions PreservePermissionsOption

+ Priority JobPriority

+ S2SGetPropertiesInBackend bool

+ S2SInvalidMetadataHandleOption InvalidMetadataHandleOption

+ S2SPreserveBlobTags bool

+ S2SSourceChangeValidation bool

+ SourceRoot ResourceString

+ Transfers Transfers

+ Version Version

+ type CopyJobPartOrderResponse struct

+ ErrorMsg CopyJobPartOrderErrorType

+ JobStarted bool

+ type CopyTransfer struct

+ BlobTags BlobTags

+ BlobTier azblob.AccessTierType

+ BlobType azblob.BlobType

+ BlobVersionID string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentMD5 []byte

+ ContentType string

+ Destination string

+ EntityType EntityType

+ LastModifiedTime time.Time

+ Metadata Metadata

+ Source string

+ SourceSize int64

+ type CountPerSecond interface

+ Add func(delta uint64) uint64

+ LatestRate func() float64

+ Reset func()

+ func NewCountPerSecond() CountPerSecond

+ type CpkInfo struct

+ EncryptionAlgorithm *string

+ EncryptionKey *string

+ EncryptionKeySha256 *string

+ func GetCpkInfo(cpkInfo bool) CpkInfo

+ func (csi CpkInfo) Marshal() (string, error)

+ type CpkOptions struct

+ CpkInfo bool

+ CpkScopeInfo string

+ IsSourceEncrypted bool

+ type CpkScopeInfo struct

+ EncryptionScope *string

+ func GetCpkScopeInfo(cpkScopeInfo string) CpkScopeInfo

+ func (csi CpkScopeInfo) Marshal() (string, error)

+ type CredCache struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewCredCache(options CredCacheOptions) *CredCache

+ func (c *CredCache) HasCachedToken() (bool, error)

+ func (c *CredCache) LoadToken() (*OAuthTokenInfo, error)

+ func (c *CredCache) RemoveCachedToken() error

+ func (c *CredCache) SaveToken(token OAuthTokenInfo) error

+ type CredCacheInternalIntegration struct — linux/amd64, windows/amd64

+ func NewCredCacheInternalIntegration(options CredCacheOptions) *CredCacheInternalIntegration

+ func (c *CredCacheInternalIntegration) HasCachedToken() (bool, error)

+ func (c *CredCacheInternalIntegration) LoadToken() (*OAuthTokenInfo, error)

+ func (c *CredCacheInternalIntegration) RemoveCachedToken() error

+ func (c *CredCacheInternalIntegration) SaveToken(token OAuthTokenInfo) error

+ type CredCacheOptions struct

+ AccountName string

+ DPAPIFilePath string

+ KeyName string

+ ServiceName string

+ type CredentialInfo struct

+ CredentialType CredentialType

+ GCPCredentialInfo GCPCredentialInfo

+ OAuthTokenInfo OAuthTokenInfo

+ S3CredentialInfo S3CredentialInfo

+ type CredentialOpOptions struct

+ CallerID string

+ Cancel context.CancelFunc

+ LogError func(string)

+ LogInfo func(string)

+ Panic func(error)

+ type CredentialType uint8

+ func (CredentialType) Anonymous() CredentialType

+ func (CredentialType) GoogleAppCredentials() CredentialType

+ func (CredentialType) OAuthToken() CredentialType

+ func (CredentialType) S3AccessKey() CredentialType

+ func (CredentialType) S3PublicBucket() CredentialType

+ func (CredentialType) SharedKey() CredentialType

+ func (CredentialType) Unknown() CredentialType

+ func (ct *CredentialType) Parse(s string) error

+ func (ct CredentialType) String() string

+ type DeleteDestination uint32

+ func (DeleteDestination) False() DeleteDestination

+ func (DeleteDestination) Prompt() DeleteDestination

+ func (DeleteDestination) True() DeleteDestination

+ func (dd *DeleteDestination) Parse(s string) error

+ func (dd DeleteDestination) String() string

+ type DeleteSnapshotsOption uint8

+ func (DeleteSnapshotsOption) Include() DeleteSnapshotsOption

+ func (DeleteSnapshotsOption) None() DeleteSnapshotsOption

+ func (DeleteSnapshotsOption) Only() DeleteSnapshotsOption

+ func (d *DeleteSnapshotsOption) Parse(s string) error

+ func (d DeleteSnapshotsOption) String() string

+ func (d DeleteSnapshotsOption) ToDeleteSnapshotsOptionType() azblob.DeleteSnapshotsOptionType

+ type EntityType uint8

+ func (EntityType) File() EntityType

+ func (EntityType) Folder() EntityType

+ func (e EntityType) String() string

+ type EnvironmentVariable struct

+ DefaultValue string

+ Description string

+ Hidden bool

+ Name string

+ func (EnvironmentVariable) AADEndpoint() EnvironmentVariable

+ func (EnvironmentVariable) AWSAccessKeyID() EnvironmentVariable

+ func (EnvironmentVariable) AWSSecretAccessKey() EnvironmentVariable

+ func (EnvironmentVariable) AccountKey() EnvironmentVariable

+ func (EnvironmentVariable) AccountName() EnvironmentVariable

+ func (EnvironmentVariable) ApplicationID() EnvironmentVariable

+ func (EnvironmentVariable) AutoLoginType() EnvironmentVariable

+ func (EnvironmentVariable) AutoTuneToCpu() EnvironmentVariable

+ func (EnvironmentVariable) AwsSessionToken() EnvironmentVariable

+ func (EnvironmentVariable) BufferGB() EnvironmentVariable

+ func (EnvironmentVariable) CPKEncryptionKey() EnvironmentVariable

+ func (EnvironmentVariable) CPKEncryptionKeySHA256() EnvironmentVariable

+ func (EnvironmentVariable) CacheProxyLookup() EnvironmentVariable

+ func (EnvironmentVariable) CertificatePassword() EnvironmentVariable

+ func (EnvironmentVariable) CertificatePath() EnvironmentVariable

+ func (EnvironmentVariable) ClientSecret() EnvironmentVariable

+ func (EnvironmentVariable) ConcurrencyValue() EnvironmentVariable

+ func (EnvironmentVariable) CredentialType() EnvironmentVariable

+ func (EnvironmentVariable) DefaultServiceApiVersion() EnvironmentVariable

+ func (EnvironmentVariable) DisableHierarchicalScanning() EnvironmentVariable

+ func (EnvironmentVariable) DisableSyslog() EnvironmentVariable

+ func (EnvironmentVariable) EnumerationPoolSize() EnvironmentVariable

+ func (EnvironmentVariable) GoogleAppCredentials() EnvironmentVariable

+ func (EnvironmentVariable) GoogleCloudProject() EnvironmentVariable

+ func (EnvironmentVariable) JobPlanLocation() EnvironmentVariable

+ func (EnvironmentVariable) LogLocation() EnvironmentVariable

+ func (EnvironmentVariable) ManagedIdentityClientID() EnvironmentVariable

+ func (EnvironmentVariable) ManagedIdentityObjectID() EnvironmentVariable

+ func (EnvironmentVariable) ManagedIdentityResourceString() EnvironmentVariable

+ func (EnvironmentVariable) MimeMapping() EnvironmentVariable

+ func (EnvironmentVariable) OAuthTokenInfo() EnvironmentVariable

+ func (EnvironmentVariable) OptimizeSparsePageBlobTransfers() EnvironmentVariable

+ func (EnvironmentVariable) PacePageBlobs() EnvironmentVariable

+ func (EnvironmentVariable) ParallelStatFiles() EnvironmentVariable

+ func (EnvironmentVariable) ProfileCPU() EnvironmentVariable

+ func (EnvironmentVariable) ProfileMemory() EnvironmentVariable

+ func (EnvironmentVariable) RequestTryTimeout() EnvironmentVariable

+ func (EnvironmentVariable) ShowPerfStates() EnvironmentVariable

+ func (EnvironmentVariable) TenantID() EnvironmentVariable

+ func (EnvironmentVariable) TransferInitiationPoolSize() EnvironmentVariable

+ func (EnvironmentVariable) UserAgentPrefix() EnvironmentVariable

+ func (EnvironmentVariable) UserDir() EnvironmentVariable

+ type ExclusiveStringMap struct

+ func NewExclusiveStringMap(fromTo FromTo, goos string) *ExclusiveStringMap

+ func (e *ExclusiveStringMap) Add(key string) error

+ func (e *ExclusiveStringMap) Remove(key string)

+ type ExitCode uint32

+ func (ExitCode) Error() ExitCode

+ func (ExitCode) NoExit() ExitCode

+ func (ExitCode) Success() ExitCode

+ type FileURLPartsExtension struct

+ func (parts FileURLPartsExtension) GetServiceURL() url.URL

+ func (parts FileURLPartsExtension) GetShareURL() url.URL

+ type FolderCreationTracker interface

+ RecordCreation func(folder string)

+ ShouldSetProperties func(folder string, overwrite OverwriteOption, prompter Prompter) bool

+ StopTracking func(folder string)

+ type FolderDeletionFunc func(context.Context, ILogger) bool

+ type FolderDeletionManager interface

+ RecordChildDeleted func(childFile *url.URL)

+ RecordChildExists func(childFileOrFolder *url.URL)

+ RequestDeletion func(folder *url.URL, deletionFunc FolderDeletionFunc)

+ func NewFolderDeletionManager(ctx context.Context, fpo FolderPropertyOption, logger ILogger) FolderDeletionManager

+ type FolderPropertyOption uint8

+ func (FolderPropertyOption) AllFolders() FolderPropertyOption

+ func (FolderPropertyOption) AllFoldersExceptRoot() FolderPropertyOption

+ func (FolderPropertyOption) NoFolders() FolderPropertyOption

+ func (FolderPropertyOption) Unspecified() FolderPropertyOption

+ type FromTo uint16

+ func (FromTo) BenchmarkBlob() FromTo

+ func (FromTo) BenchmarkBlobFS() FromTo

+ func (FromTo) BenchmarkFile() FromTo

+ func (FromTo) BlobBlob() FromTo

+ func (FromTo) BlobFSLocal() FromTo

+ func (FromTo) BlobFSTrash() FromTo

+ func (FromTo) BlobFile() FromTo

+ func (FromTo) BlobLocal() FromTo

+ func (FromTo) BlobPipe() FromTo

+ func (FromTo) BlobTrash() FromTo

+ func (FromTo) FileBlob() FromTo

+ func (FromTo) FileFile() FromTo

+ func (FromTo) FileLocal() FromTo

+ func (FromTo) FilePipe() FromTo

+ func (FromTo) FileTrash() FromTo

+ func (FromTo) GCPBlob() FromTo

+ func (FromTo) LocalBlob() FromTo

+ func (FromTo) LocalBlobFS() FromTo

+ func (FromTo) LocalFile() FromTo

+ func (FromTo) PipeBlob() FromTo

+ func (FromTo) PipeFile() FromTo

+ func (FromTo) S3Blob() FromTo

+ func (FromTo) Unknown() FromTo

+ func (ft *FromTo) AreBothFolderAware() bool

+ func (ft *FromTo) From() Location

+ func (ft *FromTo) FromAndTo(s string) (srcLocation, dstLocation Location, err error)

+ func (ft *FromTo) IsDownload() bool

+ func (ft *FromTo) IsS2S() bool

+ func (ft *FromTo) IsUpload() bool

+ func (ft *FromTo) Parse(s string) error

+ func (ft *FromTo) To() Location

+ func (ft FromTo) String() string

+ type GCPClientFactory struct

+ func NewGCPClientFactory() GCPClientFactory

+ func (f *GCPClientFactory) GetGCPClient(ctx context.Context, credInfo CredentialInfo, option CredentialOpOptions) (*gcpUtils.Client, error)

+ type GCPCredentialInfo struct

+ type GCPObjectInfoExtension struct

+ ObjectInfo gcpUtils.ObjectAttrs

+ func (gie *GCPObjectInfoExtension) CacheControl() string

+ func (gie *GCPObjectInfoExtension) ContentDisposition() string

+ func (gie *GCPObjectInfoExtension) ContentEncoding() string

+ func (gie *GCPObjectInfoExtension) ContentLanguage() string

+ func (gie *GCPObjectInfoExtension) ContentMD5() []byte

+ func (gie *GCPObjectInfoExtension) ContentType() string

+ func (gie *GCPObjectInfoExtension) NewCommonMetadata() Metadata

+ type GCPURLParts struct

+ BucketName string

+ Host string

+ ObjectKey string

+ Scheme string

+ UnparsedParams string

+ func NewGCPURLParts(u url.URL) (GCPURLParts, error)

+ func (gUrl *GCPURLParts) IsBucketSyntactically() bool

+ func (gUrl *GCPURLParts) IsDirectorySyntactically() bool

+ func (gUrl *GCPURLParts) IsObjectSyntactically() bool

+ func (gUrl *GCPURLParts) IsServiceSyntactically() bool

+ func (gUrl *GCPURLParts) String() string

+ func (gUrl *GCPURLParts) URL() url.URL

+ type GenericResourceURLParts struct

+ func NewGenericResourceURLParts(resourceURL url.URL, location Location) GenericResourceURLParts

+ func (g *GenericResourceURLParts) SetObjectName(objectName string)

+ func (g GenericResourceURLParts) GetContainerName() string

+ func (g GenericResourceURLParts) GetObjectName() string

+ func (g GenericResourceURLParts) String() string

+ func (g GenericResourceURLParts) URL() url.URL

+ type GetJobFromToRequest struct

+ JobID JobID

+ type GetJobFromToResponse struct

+ Destination string

+ ErrorMsg string

+ FromTo FromTo

+ Source string

+ type HTTPResponseExtension struct

+ func (r HTTPResponseExtension) IsSuccessStatusCode(successStatusCodes ...int) bool

+ type HashValidationOption uint8

+ func (HashValidationOption) FailIfDifferent() HashValidationOption

+ func (HashValidationOption) FailIfDifferentOrMissing() HashValidationOption

+ func (HashValidationOption) LogOnly() HashValidationOption

+ func (HashValidationOption) NoCheck() HashValidationOption

+ func (hvo *HashValidationOption) Parse(s string) error

+ func (hvo *HashValidationOption) UnmarshalJSON(b []byte) error

+ func (hvo HashValidationOption) MarshalJSON() ([]byte, error)

+ func (hvo HashValidationOption) String() string

+ type ILogger interface

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

+ Panic func(err error)

+ ShouldLog func(level pipeline.LogLevel) bool

+ type ILoggerCloser interface

+ CloseLog func()

+ func NewAppLogger(minimumLevelToLog pipeline.LogLevel, logFileFolder string) ILoggerCloser

+ type ILoggerResetable interface

+ MinimumLogLevel func() pipeline.LogLevel

+ OpenLog func()

+ var AzcopyCurrentJobLogger ILoggerResetable

+ func NewJobLogger(jobID JobID, minimumLevelToLog LogLevel, logFileFolder string, ...) ILoggerResetable

+ type IdentityInfo struct

+ ClientID string

+ MSIResID string

+ ObjectID string

+ func (identityInfo *IdentityInfo) Validate() error

+ type InitMsgJsonTemplate struct

+ IsCleanupJob bool

+ JobID string

+ LogFileLocation string

+ type InvalidMetadataHandleOption uint8

+ func (InvalidMetadataHandleOption) ExcludeIfInvalid() InvalidMetadataHandleOption

+ func (InvalidMetadataHandleOption) FailIfInvalid() InvalidMetadataHandleOption

+ func (InvalidMetadataHandleOption) RenameIfInvalid() InvalidMetadataHandleOption

+ func (i *InvalidMetadataHandleOption) Parse(s string) error

+ func (i *InvalidMetadataHandleOption) UnmarshalJSON(b []byte) error

+ func (i InvalidMetadataHandleOption) MarshalJSON() ([]byte, error)

+ func (i InvalidMetadataHandleOption) String() string

+ type JobID UUID

+ func NewJobID() JobID

+ func ParseJobID(jobID string) (JobID, error)

+ func (j *JobID) UnmarshalJSON(b []byte) error

+ func (j JobID) IsEmpty() bool

+ func (j JobID) MarshalJSON() ([]byte, error)

+ func (j JobID) String() string

+ type JobIDDetails struct

+ CommandString string

+ JobId JobID

+ JobStatus JobStatus

+ StartTime int64

+ type JobPriority uint8

+ func (JobPriority) Low() JobPriority

+ func (JobPriority) Normal() JobPriority

+ func (jp JobPriority) String() string

+ type JobStatus uint32

+ func (JobStatus) All() JobStatus

+ func (JobStatus) Cancelled() JobStatus

+ func (JobStatus) Cancelling() JobStatus

+ func (JobStatus) Completed() JobStatus

+ func (JobStatus) CompletedWithErrors() JobStatus

+ func (JobStatus) CompletedWithErrorsAndSkipped() JobStatus

+ func (JobStatus) CompletedWithSkipped() JobStatus

+ func (JobStatus) Failed() JobStatus

+ func (JobStatus) InProgress() JobStatus

+ func (JobStatus) Paused() JobStatus

+ func (j *JobStatus) AtomicLoad() JobStatus

+ func (j *JobStatus) AtomicStore(newJobStatus JobStatus)

+ func (j *JobStatus) EnhanceJobStatusInfo(skippedTransfers, failedTransfers, successfulTransfers bool) JobStatus

+ func (j *JobStatus) IsJobDone() bool

+ func (j *JobStatus) Parse(s string) error

+ func (j *JobStatus) UnmarshalJSON(b []byte) error

+ func (j JobStatus) MarshalJSON() ([]byte, error)

+ func (js JobStatus) String() string

+ type JsonOutputTemplate struct

+ MessageContent string

+ MessageType string

+ PromptDetails PromptDetails

+ TimeStamp time.Time

+ type LifecycleMgr interface

+ AddUserAgentPrefix func(string) string

+ AllowReinitiateProgressReporting func()

+ ClearEnvironmentVariable func(EnvironmentVariable)

+ Dryrun func(OutputBuilder)

+ E2EAwaitAllowOpenFiles func()

+ E2EAwaitContinue func()

+ E2EEnableAwaitAllowOpenFiles func(enable bool)

+ EnableCancelFromStdIn func()

+ EnableInputWatcher func()

+ Error func(string)

+ Exit func(OutputBuilder, ExitCode)

+ GetEnvironmentVariable func(EnvironmentVariable) string

+ Info func(string)

+ Init func(OutputBuilder)

+ InitiateProgressReporting func(WorkController)

+ IsForceLoggingDisabled func() bool

+ Progress func(OutputBuilder)

+ Prompt func(message string, details PromptDetails) ResponseOption

+ RegisterCloseFunc func(func())

+ SetForceLogging func()

+ SetOutputFormat func(OutputFormat)

+ SurrenderControl func()

+ func GetLifecycleMgr() LifecycleMgr

+ type ListContainerResponse struct

+ Blobs []string

+ type ListJobSummaryResponse struct

+ ActiveConnections int64

+ AverageE2EMilliseconds int

+ AverageIOPS int

+ BytesOverWire uint64

+ CompleteJobOrdered bool

+ ErrorMsg string

+ FailedTransfers []TransferDetail

+ FileTransfers uint32

+ FolderPropertyTransfers uint32

+ IsCleanupJob bool

+ JobID JobID

+ JobStatus JobStatus

+ NetworkErrorPercentage float32

+ PercentComplete float32

+ PerfConstraint PerfConstraint

+ PerfStrings []string

+ PerformanceAdvice []PerformanceAdvice

+ ServerBusyPercentage float32

+ SkippedTransfers []TransferDetail

+ Timestamp time.Time

+ TotalBytesEnumerated uint64

+ TotalBytesExpected uint64

+ TotalBytesTransferred uint64

+ TotalTransfers uint32

+ TransfersCompleted uint32

+ TransfersFailed uint32

+ TransfersSkipped uint32

+ type ListJobTransfersRequest struct

+ JobID JobID

+ OfStatus TransferStatus

+ type ListJobTransfersResponse struct

+ Details []TransferDetail

+ ErrorMsg string

+ JobID JobID

+ type ListJobsResponse struct

+ ErrorMessage string

+ JobIDDetails []JobIDDetails

+ type ListOfFiles struct

+ Files []string

+ type ListRequest struct

+ JobID JobID

+ OfStatus string

+ Output OutputFormat

+ type ListSyncJobSummaryResponse struct

+ DeleteTotalTransfers uint32

+ DeleteTransfersCompleted uint32

+ type Location uint8

+ func (Location) AllStandardLocations() []Location

+ func (Location) Benchmark() Location

+ func (Location) Blob() Location

+ func (Location) BlobFS() Location

+ func (Location) File() Location

+ func (Location) GCP() Location

+ func (Location) Local() Location

+ func (Location) Pipe() Location

+ func (Location) S3() Location

+ func (Location) Unknown() Location

+ func (l Location) IsFolderAware() bool

+ func (l Location) IsLocal() bool

+ func (l Location) IsRemote() bool

+ func (l Location) String() string

+ type LogLevel uint8

+ func (LogLevel) Debug() LogLevel

+ func (LogLevel) Error() LogLevel

+ func (LogLevel) Fatal() LogLevel

+ func (LogLevel) Info() LogLevel

+ func (LogLevel) None() LogLevel

+ func (LogLevel) Panic() LogLevel

+ func (LogLevel) Warning() LogLevel

+ func (ll *LogLevel) Parse(s string) error

+ func (ll LogLevel) String() string

+ func (ll LogLevel) ToPipelineLogLevel() pipeline.LogLevel

+ type MMF struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewMMF(file *os.File, writable bool, offset int64, length int64) (*MMF, error)

+ func (m *MMF) Slice() []byte

+ func (m *MMF) Unmap()

+ func (m *MMF) UnuseMMF()

+ func (m *MMF) UseMMF() bool

+ type Metadata map[string]string

+ func FromAzBlobMetadataToCommonMetadata(m azblob.Metadata) Metadata

+ func FromAzFileMetadataToCommonMetadata(m azfile.Metadata) Metadata

+ func UnMarshalToCommonMetadata(metadataString string) (Metadata, error)

+ func (m Metadata) ConcatenatedKeys() string

+ func (m Metadata) ExcludeInvalidKey() (retainedMetadata Metadata, excludedMetadata Metadata, invalidKeyExists bool)

+ func (m Metadata) Marshal() (string, error)

+ func (m Metadata) ResolveInvalidKey() (resolvedMetadata Metadata, err error)

+ func (m Metadata) ToAzBlobMetadata() azblob.Metadata

+ func (m Metadata) ToAzFileMetadata() azfile.Metadata

+ type NoCopy struct

+ func (nc *NoCopy) Check()

+ type OAuthTokenInfo struct

+ ActiveDirectoryEndpoint string

+ ApplicationID string

+ ClientID string

+ Identity bool

+ IdentityInfo IdentityInfo

+ SPNInfo SPNInfo

+ ServicePrincipalName bool

+ Tenant string

+ TokenRefreshSource string

+ func (credInfo *OAuthTokenInfo) GetNewTokenFromCert(ctx context.Context) (*adal.Token, error)

+ func (credInfo *OAuthTokenInfo) GetNewTokenFromMSI(ctx context.Context) (*adal.Token, error)

+ func (credInfo *OAuthTokenInfo) GetNewTokenFromSecret(ctx context.Context) (*adal.Token, error)

+ func (credInfo *OAuthTokenInfo) GetNewTokenFromTokenStore(ctx context.Context) (*adal.Token, error)

+ func (credInfo *OAuthTokenInfo) Refresh(ctx context.Context) (*adal.Token, error)

+ func (credInfo *OAuthTokenInfo) RefreshTokenWithUserCredential(ctx context.Context) (*adal.Token, error)

+ func (credInfo OAuthTokenInfo) IsEmpty() bool

+ type ObjectInfoExtension struct

+ ObjectInfo minio.ObjectInfo

+ func (oie *ObjectInfoExtension) CacheControl() string

+ func (oie *ObjectInfoExtension) ContentDisposition() string

+ func (oie *ObjectInfoExtension) ContentEncoding() string

+ func (oie *ObjectInfoExtension) ContentLanguage() string

+ func (oie *ObjectInfoExtension) ContentMD5() []byte

+ func (oie *ObjectInfoExtension) ContentType() string

+ func (oie *ObjectInfoExtension) NewCommonMetadata() Metadata

+ type OutputBuilder func(OutputFormat) string

+ func GetStandardInitOutputBuilder(jobID string, logFileLocation string, isCleanupJob bool, cleanupMessage string) OutputBuilder

+ type OutputFormat uint32

+ func (OutputFormat) Json() OutputFormat

+ func (OutputFormat) None() OutputFormat

+ func (OutputFormat) Text() OutputFormat

+ func (of *OutputFormat) Parse(s string) error

+ func (of OutputFormat) String() string

+ type OverwriteOption uint8

+ func (OverwriteOption) False() OverwriteOption

+ func (OverwriteOption) IfSourceNewer() OverwriteOption

+ func (OverwriteOption) Prompt() OverwriteOption

+ func (OverwriteOption) True() OverwriteOption

+ func (o *OverwriteOption) Parse(s string) error

+ func (o OverwriteOption) String() string

+ type PageBlobTier uint8

+ func (PageBlobTier) None() PageBlobTier

+ func (PageBlobTier) P10() PageBlobTier

+ func (PageBlobTier) P15() PageBlobTier

+ func (PageBlobTier) P20() PageBlobTier

+ func (PageBlobTier) P30() PageBlobTier

+ func (PageBlobTier) P4() PageBlobTier

+ func (PageBlobTier) P40() PageBlobTier

+ func (PageBlobTier) P50() PageBlobTier

+ func (PageBlobTier) P6() PageBlobTier

+ func (pbt *PageBlobTier) Parse(s string) error

+ func (pbt *PageBlobTier) UnmarshalJSON(b []byte) error

+ func (pbt PageBlobTier) MarshalJSON() ([]byte, error)

+ func (pbt PageBlobTier) String() string

+ func (pbt PageBlobTier) ToAccessTierType() azblob.AccessTierType

+ type PartNumber uint32

+ type PerfConstraint int32

+ func (PerfConstraint) CPU() PerfConstraint

+ func (PerfConstraint) Disk() PerfConstraint

+ func (PerfConstraint) PageBlobService() PerfConstraint

+ func (PerfConstraint) Service() PerfConstraint

+ func (PerfConstraint) Unknown() PerfConstraint

+ func (pc *PerfConstraint) Parse(s string) error

+ func (pc PerfConstraint) String() string

+ type PerformanceAdvice struct

+ Code string

+ PriorityAdvice bool

+ Reason string

+ Title string

+ type Predicate func() bool

+ type PreservePermissionsOption uint8

+ func NewPreservePermissionsOption(preserve, includeOwnership bool, fromTo FromTo) PreservePermissionsOption

+ func (PreservePermissionsOption) ACLsOnly() PreservePermissionsOption

+ func (PreservePermissionsOption) None() PreservePermissionsOption

+ func (PreservePermissionsOption) OwnershipAndACLs() PreservePermissionsOption

+ func (p PreservePermissionsOption) IsTruthy() bool

+ type PrologueState struct

+ LeadingBytes []byte

+ func (ps PrologueState) GetInferredContentType(jptm cutdownJptm) string

+ type PromptDetails struct

+ PromptTarget string

+ PromptType PromptType

+ ResponseOptions []ResponseOption

+ type PromptType string

+ func (PromptType) Cancel() PromptType

+ func (PromptType) DeleteDestination() PromptType

+ func (PromptType) Overwrite() PromptType

+ type Prompter interface

+ ShouldOverwrite func(objectPath string, objectType EntityType) bool

+ type ProxyLookupFunc func(req *http.Request) (*url.URL, error)

+ var GlobalProxyLookup ProxyLookupFunc

+ type ResourceHTTPHeaders struct

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentMD5 []byte

+ ContentType string

+ func (h ResourceHTTPHeaders) ToAzBlobHTTPHeaders() azblob.BlobHTTPHeaders

+ func (h ResourceHTTPHeaders) ToAzFileHTTPHeaders() azfile.FileHTTPHeaders

+ func (h ResourceHTTPHeaders) ToBlobFSHTTPHeaders() azbfs.BlobFSHTTPHeaders

+ type ResourceString struct

+ ExtraQuery string

+ SAS string

+ Value string

+ func (r ResourceString) Clone() ResourceString

+ func (r ResourceString) CloneWithConsolidatedSeparators() ResourceString

+ func (r ResourceString) CloneWithValue(newValue string) ResourceString

+ func (r ResourceString) FullURL() (*url.URL, error)

+ func (r ResourceString) ValueLocal() string

+ type ResponseOption struct

+ ResponseString string

+ ResponseType string

+ UserFriendlyResponseType string

+ func (ResponseOption) Default() ResponseOption

+ func (ResponseOption) No() ResponseOption

+ func (ResponseOption) NoForAll() ResponseOption

+ func (ResponseOption) Yes() ResponseOption

+ func (ResponseOption) YesForAll() ResponseOption

+ func (o *ResponseOption) Parse(s string) error

+ type ResumeJobRequest struct

+ CredentialInfo CredentialInfo

+ DestinationSAS string

+ ExcludeTransfer map[string]int

+ IncludeTransfer map[string]int

+ JobID JobID

+ SourceSAS string

+ type RetryCounter interface

+ GetTotalRetries func() int64

+ type RpcCmd string

+ func (RpcCmd) CancelJob() RpcCmd

+ func (RpcCmd) CopyJobPartOrder() RpcCmd

+ func (RpcCmd) GetJobFromTo() RpcCmd

+ func (RpcCmd) GetJobLCMWrapper() RpcCmd

+ func (RpcCmd) ListJobSummary() RpcCmd

+ func (RpcCmd) ListJobTransfers() RpcCmd

+ func (RpcCmd) ListJobs() RpcCmd

+ func (RpcCmd) ListSyncJobSummary() RpcCmd

+ func (RpcCmd) None() RpcCmd

+ func (RpcCmd) PauseJob() RpcCmd

+ func (RpcCmd) ResumeJob() RpcCmd

+ func (c *RpcCmd) Parse(s string) error

+ func (c RpcCmd) Pattern() string

+ func (c RpcCmd) String() string

+ type S3ClientFactory struct

+ func NewS3ClientFactory() S3ClientFactory

+ func (f *S3ClientFactory) GetS3Client(ctx context.Context, credInfo CredentialInfo, option CredentialOpOptions) (*minio.Client, error)

+ type S3CredentialInfo struct

+ Endpoint string

+ Region string

+ type S3URLParts struct

+ BucketName string

+ Endpoint string

+ Host string

+ ObjectKey string

+ Region string

+ Scheme string

+ UnparsedParams string

+ Version string

+ func NewS3URLParts(u url.URL) (S3URLParts, error)

+ func (p *S3URLParts) IsBucketSyntactically() bool

+ func (p *S3URLParts) IsDirectorySyntactically() bool

+ func (p *S3URLParts) IsObjectSyntactically() bool

+ func (p *S3URLParts) IsServiceSyntactically() bool

+ func (p *S3URLParts) String() string

+ func (p *S3URLParts) URL() url.URL

+ type SPNInfo struct

+ CertPath string

+ Secret string

+ type SingleChunkReader interface

+ BlockingPrefetch func(fileReader io.ReaderAt, isRetry bool) error

+ GetPrologueState func() PrologueState

+ HasPrefetchedEntirelyZeros func() bool

+ Length func() int64

+ WriteBufferTo func(h hash.Hash)

+ func NewSingleChunkReader(ctx context.Context, sourceFactory ChunkReaderSourceFactory, chunkId ChunkID, ...) SingleChunkReader

+ type Status uint32

+ type TestOAuthInjection struct

+ DoTokenRefreshInjection bool

+ TokenRefreshDuration time.Duration

+ type TransferDetail struct

+ Dst string

+ ErrorCode int32

+ IsFolderProperties bool

+ Src string

+ TransferSize uint64

+ TransferStatus TransferStatus

+ type TransferDirection int32

+ func (TransferDirection) Download() TransferDirection

+ func (TransferDirection) S2SCopy() TransferDirection

+ func (TransferDirection) UnKnown() TransferDirection

+ func (TransferDirection) Upload() TransferDirection

+ func (td *TransferDirection) AtomicLoad() TransferDirection

+ func (td *TransferDirection) AtomicStore(newTransferDirection TransferDirection)

+ func (td *TransferDirection) Parse(s string) error

+ func (td TransferDirection) String() string

+ type TransferStatus int32

+ func (TransferStatus) All() TransferStatus

+ func (TransferStatus) BlobTierFailure() TransferStatus

+ func (TransferStatus) Cancelled() TransferStatus

+ func (TransferStatus) Failed() TransferStatus

+ func (TransferStatus) FolderCreated() TransferStatus

+ func (TransferStatus) NotStarted() TransferStatus

+ func (TransferStatus) SkippedBlobHasSnapshots() TransferStatus

+ func (TransferStatus) SkippedEntityAlreadyExists() TransferStatus

+ func (TransferStatus) Started() TransferStatus

+ func (TransferStatus) Success() TransferStatus

+ func (TransferStatus) TierAvailabilityCheckFailure() TransferStatus

+ func (ts *TransferStatus) AtomicLoad() TransferStatus

+ func (ts *TransferStatus) AtomicStore(newTransferStatus TransferStatus)

+ func (ts *TransferStatus) Parse(s string) error

+ func (ts *TransferStatus) UnmarshalJSON(b []byte) error

+ func (ts TransferStatus) MarshalJSON() ([]byte, error)

+ func (ts TransferStatus) ShouldTransfer() bool

+ func (ts TransferStatus) String() string

+ type Transfers struct

+ FileTransferCount uint32

+ FolderTransferCount uint32

+ List []CopyTransfer

+ TotalSizeInBytes uint64

+ type URLExtension struct

+ func (u URLExtension) RedactSecretQueryParamForLogging() string

+ func (u URLExtension) URLWithPlusDecodedInPath() url.URL

+ type URLStringExtension string

+ func (s URLStringExtension) RedactSecretQueryParamForLogging() string

+ type UUID struct

+ D1 uint32

+ D2 uint16

+ D3 uint16

+ D4 [8]uint8

+ func NewUUID() (u UUID)

+ func ParseUUID(uuidStr string) (UUID, error)

+ func (u *UUID) UnmarshalJSON(b []byte) error

+ func (u UUID) MarshalJSON() ([]byte, error)

+ func (u UUID) String() string

+ type UserOAuthTokenManager struct

+ func NewUserOAuthTokenManagerInstance(credCacheOptions CredCacheOptions) *UserOAuthTokenManager

+ func (uotm *UserOAuthTokenManager) CertLogin(tenantID, activeDirectoryEndpoint, certPath, certPass, applicationID string, ...) (*OAuthTokenInfo, error)

+ func (uotm *UserOAuthTokenManager) GetTokenInfo(ctx context.Context) (*OAuthTokenInfo, error)

+ func (uotm *UserOAuthTokenManager) HasCachedToken() (bool, error)

+ func (uotm *UserOAuthTokenManager) MSILogin(ctx context.Context, identityInfo IdentityInfo, persist bool) (*OAuthTokenInfo, error)

+ func (uotm *UserOAuthTokenManager) RemoveCachedToken() error

+ func (uotm *UserOAuthTokenManager) SecretLogin(tenantID, activeDirectoryEndpoint, secret, applicationID string, persist bool) (*OAuthTokenInfo, error)

+ func (uotm *UserOAuthTokenManager) UserLogin(tenantID, activeDirectoryEndpoint string, persist bool) (*OAuthTokenInfo, error)

+ type Version uint32

+ type WaitReason struct

+ Name string

+ func (WaitReason) Body() WaitReason

+ func (WaitReason) BodyReReadDueToMem() WaitReason

+ func (WaitReason) BodyReReadDueToSpeed() WaitReason

+ func (WaitReason) Cancelled() WaitReason

+ func (WaitReason) ChunkDone() WaitReason

+ func (WaitReason) CreateLocalFile() WaitReason

+ func (WaitReason) DiskIO() WaitReason

+ func (WaitReason) Epilogue() WaitReason

+ func (WaitReason) FilePacer() WaitReason

+ func (WaitReason) HeaderResponse() WaitReason

+ func (WaitReason) LockDestination() WaitReason

+ func (WaitReason) ModifiedTimeRefresh() WaitReason

+ func (WaitReason) Nothing() WaitReason

+ func (WaitReason) OpenLocalSource() WaitReason

+ func (WaitReason) PriorChunk() WaitReason

+ func (WaitReason) QueueToWrite() WaitReason

+ func (WaitReason) RAMToSchedule() WaitReason

+ func (WaitReason) S2SCopyOnWire() WaitReason

+ func (WaitReason) Sorting() WaitReason

+ func (WaitReason) WorkerGR() WaitReason

+ func (WaitReason) XferStart() WaitReason

+ func (wr WaitReason) String() string

+ type WorkController interface

+ Cancel func(mgr LifecycleMgr)

+ ReportProgressOrExit func(mgr LifecycleMgr) (totalKnownCount uint32)

Other modules containing this package

github.com/nitin-deamon/azure-storage-azcopy

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