common

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

+ const AutologinTypeAzCLI

+ const AutologinTypeDevice

+ const AutologinTypeMSI

+ const AutologinTypePsCred

+ const AutologinTypeSPN

+ const MaxPutBlobSize

type BlobTransferAttributes

+ PutBlobSizeInBytes int64

type LifecycleMgr

+ Warn func(string)

type Location

+ func (Location) AzureAccount() Location

v10.23.0

Jan 23, 2024

Changes in this version

+ const MegaByte

+ func DoWithOverrideReadOnlyOnAzureFiles(ctx context.Context, action func() (interface{}, error), ...) error

+ func ScopedCredential1(cred azcore.TokenCredential, scopes []string) func(context.Context) (*string, error)

+ func TryAddMetadata(metadata Metadata, key, value string)

+ func TryReadMetadata(metadata Metadata, key string) (*string, bool)

type CancelPauseResumeResponse

+ JobStatus JobStatus

+ type FileClientStub interface

+ URL func() string

type ScopedCredential

+ func NewScopedCredential(cred azcore.TokenCredential, credType CredentialType) *ScopedCredential

+ func (s *ScopedCredential) GetToken(ctx context.Context, _ policy.TokenRequestOptions) (azcore.AccessToken, error)

type ServiceClient

+ func NewServiceClient(bsc *blobservice.Client, fsc *fileservice.Client, dsc *datalake.Client) *ServiceClient

v10.22.2

Jan 9, 2024

v10.22.1

Dec 19, 2023

Changes in this version

+ func GetTokenStoreCredential(accessToken string, expiresOn time.Time) azcore.TokenCredential

v10.22.0

Dec 5, 2023

Changes in this version

+ const MaxRangeGetSize

+ func Cause(err error) error

+ func CreateDatalakeDirectoryClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *datalakedirectory.Client

+ func CreateFilesystemClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *filesystem.Client

+ func ForceLog(level LogLevel, msg string)

+ func GetBlobSharedKeyCredential() (*blob.SharedKeyCredential, error)

+ func GetDatalakeSharedKeyCredential() (*azdatalake.SharedKeyCredential, error)

+ func IffNotEmpty(wanted string) *string

+ func NewDatalakeReadLogFunc(logger ILogger, fullUrl string) func(int32, error, datalakefile.HTTPRange, bool)

+ func NewRecursivePolicy() policy.Policy

+ func NewRotatingWriter(filePath string, size uint64) (io.WriteCloser, error)

+ func ScopedCredential(cred azcore.TokenCredential, scopes []string) func(context.Context) (*string, error)

+ func SplitContainerNameFromPath(u string) (container string, filepath string, err error)

+ func WithRecursive(parent context.Context, recursive bool) context.Context

+ type AuthTokenFunction func(context.Context) (*string, error)

type AzError

+ func ErrInvalidClient(msg string) AzError

+ func (err AzError) InvalidServiceClient() AzError

type BlobTransferAttributes

+ DeleteDestinationFileIfNecessary bool

type CopyJobPartOrderRequest

+ DstDatalakeClient *datalake.Client

+ DstServiceClient *ServiceClient

+ SrcDatalakeClient *datalake.Client

+ SrcServiceClient *ServiceClient

type CredentialType

+ func (ct CredentialType) IsSharedKey() bool

+ type CtxRecursiveKey struct

+ type FileClientOptions struct

+ AllowSourceTrailingDot bool

+ AllowTrailingDot bool

type FromTo

+ func (ft FromTo) BothSupportTrailingDot() bool

type Location

+ func (l Location) SupportsTrailingDot() bool

type OAuthTokenInfo

+ AzCLICred bool

+ PSCred bool

+ func (credInfo *OAuthTokenInfo) GetAzCliCredential() (azcore.TokenCredential, error)

+ func (credInfo *OAuthTokenInfo) GetPSContextCredential() (azcore.TokenCredential, error)

+ type PSTokenProvider func(ctx context.Context, resource string, tenant string) ([]byte, error)

+ type PowershellContextCredential struct

+ func NewPowershellContextCredential(options *PowershellContextCredentialOptions) (*PowershellContextCredential, error)

+ func (c *PowershellContextCredential) GetToken(ctx context.Context, opts policy.TokenRequestOptions) (azcore.AccessToken, error)

+ type PowershellContextCredentialOptions struct

+ TenantID string

type ResumeJobRequest

+ DstServiceClient *ServiceClient

+ SrcServiceClient *ServiceClient

+ type ServiceClient struct

+ func GetServiceClientForLocation(loc Location, resourceURL string, credType CredentialType, ...) (*ServiceClient, error)

+ func (s *ServiceClient) BlobServiceClient() (*blobservice.Client, error)

+ func (s *ServiceClient) DatalakeServiceClient() (*datalake.Client, error)

+ func (s *ServiceClient) FileServiceClient() (*fileservice.Client, error)

type UserOAuthTokenManager

+ func (uotm *UserOAuthTokenManager) AzCliLogin(tenantID string) error

+ func (uotm *UserOAuthTokenManager) PSContextToken(tenantID string) error

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 ManagedDiskScope

+ const StorageScope

+ func CreateAppendBlobClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *appendblob.Client

+ func CreateBlobClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *blob.Client

+ func CreateBlobServiceClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *blobservice.Client

+ func CreateBlockBlobClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *blockblob.Client

+ func CreateContainerClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *container.Client

+ func CreateFileServiceClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *fileservice.Client

+ func CreatePageBlobClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *pageblob.Client

+ func CreateShareClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *share.Client

+ func CreateShareDirectoryClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *sharedirectory.Client

+ func CreateShareFileClient(u string, credInfo CredentialInfo, credOpOptions *CredentialOpOptions, ...) *sharefile.Client

+ func GetSourceBlobCredential(credInfo CredentialInfo, options CredentialOpOptions) (azcore.TokenCredential, error)

+ func Iff(test bool, trueVal, falseVal T) T

+ func IffNotNil(wanted *T, instead T) T

+ func NewBlobReadLogFunc(logger ILogger, fullUrl string) func(int32, error, blob.HTTPRange, bool)

+ func NewFileReadLogFunc(logger ILogger, fullUrl string) func(int32, error, sharefile.HTTPRange, bool)

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

type BlobType

+ func FromBlobType(bt blob.BlobType) BlobType

+ func (bt *BlobType) ToBlobType() blob.BlobType

type CpkOptions

+ func (options CpkOptions) GetCPKInfo() *blob.CPKInfo

+ func (options CpkOptions) GetCPKScopeInfo() *blob.CPKScopeInfo

type CredentialInfo

+ S2SSourceTokenCredential azcore.TokenCredential

+ type DeviceCodeCredential struct

+ func (dcc *DeviceCodeCredential) GetToken(ctx context.Context, options policy.TokenRequestOptions) (azcore.AccessToken, error)

+ func (dcc *DeviceCodeCredential) RefreshTokenWithUserCredential(ctx context.Context, resource string) (*adal.Token, error)

type Location

+ func (l Location) SupportsHnsACLs() bool

type LogLevel

+ const LogDebug

+ const LogError

+ const LogFatal

+ const LogInfo

+ const LogNone

+ const LogPanic

+ const LogWarning

+ type LogSanitizer interface

+ SanitizeLogMessage func(raw string) string

type OAuthTokenInfo

+ func (credInfo *OAuthTokenInfo) GetClientCertificateCredential() (azcore.TokenCredential, error)

+ func (credInfo *OAuthTokenInfo) GetClientSecretCredential() (azcore.TokenCredential, error)

+ func (credInfo *OAuthTokenInfo) GetDeviceCodeCredential() (azcore.TokenCredential, error)

+ func (credInfo *OAuthTokenInfo) GetManagedIdentityCredential() (azcore.TokenCredential, error)

+ func (credInfo *OAuthTokenInfo) GetTokenCredential() (azcore.TokenCredential, error)

+ func (credInfo *OAuthTokenInfo) GetTokenStoreCredential() (azcore.TokenCredential, error)

type ResourceHTTPHeaders

+ func (h ResourceHTTPHeaders) ToBlobHTTPHeaders() blob.HTTPHeaders

+ func (h ResourceHTTPHeaders) ToFileHTTPHeaders() sharefile.HTTPHeaders

type ResourceString

+ func (r ResourceString) String() (string, error)

+ type TokenStoreCredential struct

+ func (tsc *TokenStoreCredential) GetToken(_ context.Context, _ policy.TokenRequestOptions) (azcore.AccessToken, error)

v10.21.0-Preview

Aug 15, 2023

v10.20.1

Aug 8, 2023

v10.20.0

Jul 26, 2023

Changes in this version

type AzError

+ func (err AzError) InvalidBlobOrWindowsName() AzError

v10.19.0

May 30, 2023

Changes in this version

+ var EHashStorageMode = HashStorageMode(0)

+ var ETrailingDotOption = TrailingDotOption(0)

+ var LocalHashDir = ""

+ var LocalHashStorageMode = EHashStorageMode.Default()

+ var NewHashDataAdapter = func(hashPath, dataPath string, mode HashStorageMode) (HashDataAdapter, error)

+ func LogHashStorageFailure()

+ type AlternateDataStreamHashDataAdapter struct — windows/amd64

+ func (a *AlternateDataStreamHashDataAdapter) GetHashData(relativePath string) (*SyncHashData, error)

+ func (a *AlternateDataStreamHashDataAdapter) GetMode() HashStorageMode

+ func (a *AlternateDataStreamHashDataAdapter) SetHashData(relativePath string, data *SyncHashData) error

type CacheLimiter

+ StrictLimit func() int64

type CopyJobPartOrderRequest

+ BlobFSRecursiveDelete bool

+ FileAttributes FileTransferAttributes

+ type FileTransferAttributes struct

+ TrailingDot TrailingDotOption

type FromTo

+ func (FromTo) BlobBlobFS() FromTo

+ func (FromTo) BlobFSBlob() FromTo

+ func (FromTo) BlobFSBlobFS() FromTo

+ func (FromTo) BlobFSFile() FromTo

+ func (FromTo) FileBlobFS() FromTo

+ func (ft FromTo) IsDelete() bool

+ func (ft FromTo) IsSetProperties() bool

+ type HashDataAdapter interface

+ GetHashData func(relativePath string) (*SyncHashData, error)

+ GetMode func() HashStorageMode

+ SetHashData func(relativePath string, data *SyncHashData) error

+ type HashStorageMode uint8

+ func (HashStorageMode) AlternateDataStreams() HashStorageMode

+ func (HashStorageMode) HiddenFiles() HashStorageMode

+ func (HashStorageMode) XAttr() HashStorageMode

+ func (e *HashStorageMode) Default() HashStorageMode

+ func (mode *HashStorageMode) Parse(s string) error

+ func (mode HashStorageMode) IsOSAgnostic() bool

+ func (mode HashStorageMode) String() string

+ type HiddenFileDataAdapter struct

+ func (a *HiddenFileDataAdapter) GetHashData(relativePath string) (*SyncHashData, error)

+ func (a *HiddenFileDataAdapter) GetMode() HashStorageMode

+ func (a *HiddenFileDataAdapter) HideFile(fullPath string) error

+ func (a *HiddenFileDataAdapter) SetHashData(relativePath string, data *SyncHashData) error

type Location

+ func (l Location) CanForwardOAuthTokens() bool

+ type TrailingDotOption uint8

+ func (TrailingDotOption) Disable() TrailingDotOption

+ func (TrailingDotOption) Enable() TrailingDotOption

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

+ func (d TrailingDotOption) String() string

+ type XAttrHashDataAdapter struct — darwin/amd64, linux/amd64

+ func (a *XAttrHashDataAdapter) GetHashData(relativePath string) (*SyncHashData, error)

+ func (a *XAttrHashDataAdapter) GetMode() HashStorageMode

+ func (a *XAttrHashDataAdapter) SetHashData(relativePath string, data *SyncHashData) error

v10.18.1

Apr 20, 2023

v10.18.0

Mar 31, 2023

Changes in this version

+ const AZCOPY_BLOCKNAME_LENGTH

+ const PreserveSymlinkFlagName

+ var ESymlinkHandlingType = eSymlinkHandlingType(0)

+ func GenerateBlockBlobBlockID(blockNamePrefix string, index int32) string

+ func VerifyIsURLResolvable(url_string string) error

type BlockBlobTier

+ func (BlockBlobTier) Cold() BlockBlobTier

type CopyJobPartOrderRequest

+ SymlinkHandlingType SymlinkHandlingType

type CpkInfo

+ func (csi CpkInfo) Empty() bool

type EntityType

+ func (EntityType) FileProperties() EntityType

+ func (EntityType) Symlink() EntityType

type EnvironmentVariable

+ func (EnvironmentVariable) DisableBlobTransferResume() EnvironmentVariable

type ListJobSummaryResponse

+ SymlinkTransfers uint32

+ type SymlinkHandlingType uint8

+ func (sht *SymlinkHandlingType) Determine(Follow, Preserve bool) error

+ func (sht SymlinkHandlingType) Follow() bool

+ func (sht SymlinkHandlingType) None() bool

+ func (sht SymlinkHandlingType) Preserve() bool

type TransferStatus

+ func (TransferStatus) Restarted() TransferStatus

type Transfers

+ SymlinkTransferCount uint32

v10.17.0

Jan 23, 2023

Changes in this version

+ const AzCopyHashDataStream

+ const BLOB_NOT_FOUND

+ const CIFS_XATTR_ATTRIB — linux/amd64

+ const CIFS_XATTR_CIFS_ACL — linux/amd64

+ const CIFS_XATTR_CIFS_NTSD — linux/amd64

+ const CIFS_XATTR_CIFS_NTSD_FULL — linux/amd64

+ const CIFS_XATTR_CREATETIME — linux/amd64

+ const FILE_NOT_FOUND

+ const TICKS_FROM_WINDOWS_EPOCH_TO_UNIX_EPOCH — linux/amd64

+ func GetProxyFunc() func(*http.Request) (*url.URL, error)

+ func PutHashData(fullpath string, data SyncHashData) error

+ func UnixNanoToWindowsTicks(nsec int64) int64 — linux/amd64

+ func WindowsTicksToUnixNano(ticks int64) int64 — linux/amd64

+ type ByHandleFileInformation struct — linux/amd64

+ CreationTime Filetime

+ FileAttributes uint32

+ FileIndexHigh uint32

+ FileIndexLow uint32

+ FileSizeHigh uint32

+ FileSizeLow uint32

+ LastAccessTime Filetime

+ LastWriteTime Filetime

+ NumberOfLinks uint32

+ VolumeSerialNumber uint32

+ func GetFileInformation(path string) (ByHandleFileInformation, error)

type CredentialInfo

+ SourceBlobToken azblob.Credential

+ type Filetime struct — linux/amd64

+ HighDateTime uint32

+ LowDateTime uint32

+ func NsecToFiletime(nsec int64) Filetime

+ func StatxTimestampToFiletime(ts unix.StatxTimestamp) Filetime

+ func (ft *Filetime) Nanoseconds() int64

type FolderCreationTracker

+ CreateFolder func(folder string, doCreation func() error) error

type ListJobSummaryResponse

+ FoldersCompleted uint32

+ FoldersFailed uint32

+ FoldersSkipped uint32

type OverwriteOption

+ func (OverwriteOption) PosixProperties() OverwriteOption

+ type SyncHashData struct

+ Data string

+ LMT time.Time

+ Mode SyncHashType

+ func TryGetHashData(fullpath string) (SyncHashData, error)

+ type SyncHashType uint8

+ var ESyncHashType SyncHashType = 0

+ func (SyncHashType) MD5() SyncHashType

+ func (SyncHashType) None() SyncHashType

+ func (ht *SyncHashType) Parse(s string) error

+ func (ht SyncHashType) String() string

type TransferStatus

+ func (t TransferStatus) StatusLocked() bool

v10.16.2

Nov 7, 2022

v10.16.1

Oct 5, 2022

v10.16.0

Jul 21, 2022

Changes in this version

+ const LINUXAttributeMaskMeta

+ const LINUXAttributeMeta

+ const LINUXBTimeMeta

+ const LINUXStatxMaskMeta

+ const MDResource

+ const MetadataAndBlobTagsClearFlag

+ const POSIXATimeMeta

+ const POSIXBlockDeviceMeta

+ const POSIXCTimeMeta

+ const POSIXCharDeviceMeta

+ const POSIXDevMeta

+ const POSIXFIFOMeta

+ const POSIXFolderMeta

+ const POSIXGroupMeta

+ const POSIXINodeMeta

+ const POSIXModTimeMeta

+ const POSIXModeMeta

+ const POSIXNlinkMeta

+ const POSIXOwnerMeta

+ const POSIXRDevMeta

+ const POSIXSocketMeta

+ const POSIXSymlinkMeta

+ const STATX_ALL

+ const STATX_ATIME

+ const STATX_ATTR_APPEND

+ const STATX_ATTR_AUTOMOUNT

+ const STATX_ATTR_COMPRESSED

+ const STATX_ATTR_DAX

+ const STATX_ATTR_ENCRYPTED

+ const STATX_ATTR_IMMUTABLE

+ const STATX_ATTR_MOUNT_ROOT

+ const STATX_ATTR_NODUMP

+ const STATX_ATTR_VERITY

+ const STATX_BASIC_STATS

+ const STATX_BLOCKS

+ const STATX_BTIME

+ const STATX_CTIME

+ const STATX_GID

+ const STATX_INO

+ const STATX_MNT_ID

+ const STATX_MODE

+ const STATX_MTIME

+ const STATX_NLINK

+ const STATX_SIZE

+ const STATX_TYPE

+ const STATX_UID

+ const S_ALLPERM

+ const S_IFBLK

+ const S_IFCHR

+ const S_IFDIR

+ const S_IFIFO

+ const S_IFLNK

+ const S_IFSOCK

+ const S_IRGRP

+ const S_IROTH

+ const S_IRUSR

+ const S_IWGRP

+ const S_IWOTH

+ const S_IWUSR

+ const S_IXGRP

+ const S_IXOTH

+ const S_IXUSR

+ var AllLinuxProperties = []string

+ var EOutputVerbosity = OutputVerbosity(0)

+ var ERehydratePriorityType = RehydratePriorityType(0)

+ var ESetPropertiesFlags = SetPropertiesFlags(0)

+ func AddStatToBlobMetadata(s UnixStatAdapter, metadata azblob.Metadata)

+ func ClearStatFromBlobMetadata(metadata azblob.Metadata)

+ func StatXReturned(mask uint32, want uint32) bool

type BlobTransferAttributes

+ RehydratePriority RehydratePriorityType

type ChunkStatusLoggerCloser

+ CloseLogger func()

type CopyJobPartOrderRequest

+ PreservePOSIXProperties bool

+ SetPropertiesFlags SetPropertiesFlags

type CredentialType

+ func (CredentialType) MDOAuthToken() CredentialType

+ func (ct CredentialType) IsAzureOAuth() bool

type FromTo

+ func (FromTo) BlobFSNone() FromTo

+ func (FromTo) BlobNone() FromTo

+ func (FromTo) FileNone() FromTo

+ func (ft *FromTo) IsPropertyOnlyTransfer() bool

type LifecycleMgr

+ SetOutputVerbosity func(mode OutputVerbosity)

type Location

+ func (Location) None() Location

type Metadata

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

+ func (m Metadata) Clone() Metadata

+ type OutputVerbosity uint8

+ func (OutputVerbosity) Default() OutputVerbosity

+ func (OutputVerbosity) Essential() OutputVerbosity

+ func (OutputVerbosity) Quiet() OutputVerbosity

+ func (qm *OutputVerbosity) Parse(s string) error

+ func (qm OutputVerbosity) String() string

+ type RehydratePriorityType uint8

+ func (RehydratePriorityType) High() RehydratePriorityType

+ func (RehydratePriorityType) None() RehydratePriorityType

+ func (RehydratePriorityType) Standard() RehydratePriorityType

+ func (rpt *RehydratePriorityType) Parse(s string) error

+ func (rpt RehydratePriorityType) String() string

+ func (rpt RehydratePriorityType) ToRehydratePriorityType() azblob.RehydratePriorityType

+ type SetPropertiesFlags uint32

+ func (SetPropertiesFlags) None() SetPropertiesFlags

+ func (SetPropertiesFlags) SetBlobTags() SetPropertiesFlags

+ func (SetPropertiesFlags) SetMetadata() SetPropertiesFlags

+ func (SetPropertiesFlags) SetTier() SetPropertiesFlags

+ func (op *SetPropertiesFlags) ShouldTransferBlobTags() bool

+ func (op *SetPropertiesFlags) ShouldTransferMetaData() bool

+ func (op *SetPropertiesFlags) ShouldTransferTier() bool

+ type UnixStatAdapter interface

+ ATime func() time.Time

+ Attribute func() uint64

+ AttributeMask func() uint64

+ BTime func() time.Time

+ CTime func() time.Time

+ Device func() uint64

+ Extended func() bool

+ FileMode func() uint32

+ Group func() uint32

+ INode func() uint64

+ MTime func() time.Time

+ NLink func() uint64

+ Owner func() uint32

+ RDevice func() uint64

+ StatxMask func() uint32

+ func ReadStatFromMetadata(metadata azblob.Metadata, contentLength int64) (UnixStatAdapter, error)

+ type UnixStatContainer struct

+ func (u UnixStatContainer) ATime() time.Time

+ func (u UnixStatContainer) Attribute() uint64

+ func (u UnixStatContainer) AttributeMask() uint64

+ func (u UnixStatContainer) BTime() time.Time

+ func (u UnixStatContainer) CTime() time.Time

+ func (u UnixStatContainer) Device() uint64

+ func (u UnixStatContainer) Extended() bool

+ func (u UnixStatContainer) FileMode() uint32

+ func (u UnixStatContainer) Group() uint32

+ func (u UnixStatContainer) INode() uint64

+ func (u UnixStatContainer) MTime() time.Time

+ func (u UnixStatContainer) NLink() uint64

+ func (u UnixStatContainer) Owner() uint32

+ func (u UnixStatContainer) RDevice() uint64

+ func (u UnixStatContainer) StatxMask() uint32

v10.15.0

May 10, 2022

Changes in this version

+ var AzcopyJobPlanFolder string

type CopyJobPartOrderRequest

+ S2SSourceCredentialType CredentialType

type CredentialInfo

+ func (c CredentialInfo) WithType(credentialType CredentialType) CredentialInfo

type EnvironmentVariable

+ func (EnvironmentVariable) DownloadToTempPath() EnvironmentVariable

type ILoggerResetable

+ var AzcopyCurrentJobLogger ILoggerResetable

+ func NewSysLogger(jobID JobID, minimumLevelToLog LogLevel, logSuffix string) ILoggerResetable

+ type LCMMsg struct

+ Req *LCMMsgReq

+ Resp *LCMMsgResp

+ func NewLCMMsg() *LCMMsg

+ func (m *LCMMsg) Reply()

+ func (m *LCMMsg) SetRequest(req *LCMMsgReq)

+ func (m *LCMMsg) SetResponse(resp *LCMMsgResp)

+ type LCMMsgReq struct

+ MsgType string

+ TimeStamp time.Time

+ Value string

+ type LCMMsgResp struct

+ Err error

+ MsgType string

+ TimeStamp time.Time

+ Value fmt.Stringer

+ type LCMMsgType uint16

+ var ELCMMsgType LCMMsgType

+ func (LCMMsgType) CancelJob() LCMMsgType

+ func (LCMMsgType) E2EInterrupts() LCMMsgType

+ func (LCMMsgType) Invalid() LCMMsgType

+ func (LCMMsgType) PerformanceAdjustment() LCMMsgType

+ func (m *LCMMsgType) Parse(s string) error

+ func (m *LCMMsgType) String() string

type LifecycleMgr

+ DownloadToTempPath func() bool

+ MsgHandlerChannel func() <-chan *LCMMsg

+ ReportAllJobPartsDone func()

+ type PerfAdjustmentReq struct

+ Throughput int64

+ type PerfAdjustmentResp struct

+ AdjustedThroughPut int64

+ Err string

+ NextAdjustmentAfter time.Time

+ Status bool

+ func (p PerfAdjustmentResp) Json() string

+ func (p PerfAdjustmentResp) String() string

+ type S3HTTPTraceLogger struct

+ func NewS3HTTPTraceLogger(logger ILogger, level pipeline.LogLevel) S3HTTPTraceLogger

+ func (e S3HTTPTraceLogger) Write(msg []byte) (n int, err error)

v10.14.1

Mar 14, 2022

v10.14.0

Feb 25, 2022

Changes in this version

+ var EPermanentDeleteOption = PermanentDeleteOption(3)

type BlobTransferAttributes

+ PermanentDeleteOption PermanentDeleteOption

type CopyTransfer

+ BlobSnapshotID string

+ type PermanentDeleteOption uint8

+ func (PermanentDeleteOption) None() PermanentDeleteOption

+ func (PermanentDeleteOption) Snapshots() PermanentDeleteOption

+ func (PermanentDeleteOption) SnapshotsAndVersions() PermanentDeleteOption

+ func (PermanentDeleteOption) Versions() PermanentDeleteOption

+ func (p *PermanentDeleteOption) Parse(s string) error

+ func (p PermanentDeleteOption) String() string

+ func (p PermanentDeleteOption) ToPermanentDeleteOptionType() azblob.BlobDeleteType

v10.13.0

Oct 20, 2021

Changes in this version

+ const IMDSAPIVersionArcVM

+ const IMDSAPIVersionAzureVM

+ const MSIEndpointArcVM

+ const MSIEndpointAzureVM

+ const WSAECONNREFUSED

+ func IsSourcePublicBlob(sourceURI string, ctx context.Context) bool

v10.12.2

Sep 20, 2021

Changes in this version

type BlobType

+ func FromAzBlobType(bt azblob.BlobType) BlobType

v10.12.1

Sep 1, 2021

v10.12.0

Aug 31, 2021

Changes in this version

type AzError

+ func (err AzError) InvalidBlobName() AzError

type CredentialType

+ func (CredentialType) S3PublicBucket() CredentialType

type LifecycleMgr

+ Dryrun func(OutputBuilder)

+ type Prompter interface

+ ShouldOverwrite func(objectPath string, objectType EntityType) bool

type TransferStatus

+ func (TransferStatus) FolderCreated() TransferStatus

v10.11.0

Jun 15, 2021

Changes in this version

type EnvironmentVariable

+ func (EnvironmentVariable) MimeMapping() EnvironmentVariable

v10.10.0

Apr 14, 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 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) 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 (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) 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) 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)

+ func NewFolderCreationTracker(fpo FolderPropertyOption) FolderCreationTracker

+ 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()

+ 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)

+ 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 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) 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/Azure/azure-storage-azcopy

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