cmd

Oct 29, 2024

Changes in this version

+ const LocalFileObjectType

+ type DryrunTransfer struct

+ BlobType common.BlobType

+ Destination string

+ EntityType common.EntityType

+ FromTo common.FromTo

+ Source string

+ func (d *DryrunTransfer) UnmarshalJSON(bytes []byte) error

+ func (d DryrunTransfer) MarshalJSON() ([]byte, error)

Jun 12, 2024

Changes in this version

+ const ArchiveStatus

+ const BlobAccessTier

+ const BlobType

+ const ContentEncoding

+ const ContentMD5

+ const ContentType

+ const LastModifiedTime

+ const LastModifiedTimeFormat

+ const LeaseDuration

+ const LeaseState

+ const LeaseStatus

+ const VersionId

May 28, 2024

Changes in this version

+ var LocalToFileShareWarnMsg = "AzCopy sync is supported but not fully recommended for Azure Files. AzCopy sync doesn't support differential copies at scale, and some file fidelity might be lost."

+ func ValidateArgumentLocation(src string, userSpecifiedLocation string) (common.Location, error)

+ type AzCopyListObject struct

+ ArchiveStatus blob.ArchiveStatus

+ BlobAccessTier blob.AccessTier

+ BlobType blob.BlobType

+ ContentEncoding string

+ ContentLength string

+ ContentMD5 []byte

+ ContentType string

+ LastModifiedTime *time.Time

+ LeaseDuration lease.DurationType

+ LeaseState lease.StateType

+ LeaseStatus lease.StatusType

+ Path string

+ StringEncoding string

+ VersionId string

+ func (l AzCopyListObject) String() string

+ type AzCopyListSummary struct

+ FileCount string

+ StringEncoding string

+ TotalFileSize string

+ func (l AzCopyListSummary) String() string

Mar 26, 2024

Changes in this version

+ var WindowsAttributeStrings = map[WindowsAttribute]string — windows/amd64

+ var WindowsAttributesByName = map[string]WindowsAttribute — windows/amd64

type LocationLevel

+ func (LocationLevel) Account() LocationLevel

+ type WindowsAttribute uint32 — windows/amd64

+ const WindowsAttributeArchiveReady

+ const WindowsAttributeCompressedFile

+ const WindowsAttributeEncryptedFile

+ const WindowsAttributeHidden

+ const WindowsAttributeNonIndexedFile

+ const WindowsAttributeNormalFile

+ const WindowsAttributeOfflineFile

+ const WindowsAttributeReadOnly

+ const WindowsAttributeSystemFile

+ const WindowsAttributeTemporaryFile

Dec 5, 2023

Changes in this version

+ func PrintOlderVersion(newest Version, local Version)

type Version

+ func ValidateCachedVersion(filePath string) (*Version, error)

+ func (v Version) CacheRemoteVersion(remoteVer Version, filePath string) error

+ func (v Version) EqualTo(v2 Version) bool

Sep 29, 2023

Changes in this version

+ const ISO8601

Mar 31, 2023

Changes in this version

+ func NewFolderPropertyOption(fromTo common.FromTo, recursive, stripTopDir bool, filters []ObjectFilter, ...) (common.FolderPropertyOption, string)

type CookedCopyCmdArgs

+ SymlinkHandling common.SymlinkHandlingType

Jan 23, 2023

Changes in this version

+ var ErrorHashAsyncCalculation = errors.New("hash is calculating asynchronously")

+ var ErrorHashNoLongerValid = errors.New("attached hash no longer valid")

+ var ErrorHashNotCompatible = errors.New("hash types do not match")

+ var ErrorNoHashPresent = errors.New("no hash present on file")

type CookedCopyCmdArgs

+ IsSourceDir bool

Jul 21, 2022

Changes in this version

+ const MAX_SYMLINKS_TO_FOLLOW

+ var AzcopyAppPathFolder string

+ type ErrorFileInfo struct

+ ErrorMsg error

+ FileInfo os.FileInfo

+ FilePath string

Sep 20, 2021

Changes in this version

+ var EnumerationParallelStatFiles = false

+ var EnumerationParallelism = 1

+ func GetCredentialInfoForLocation(ctx context.Context, location common.Location, resource, resourceSAS string, ...) (credInfo common.CredentialInfo, isPublic bool, err error)

+ func InferArgumentLocation(arg string) common.Location

+ func InitPipeline(ctx context.Context, location common.Location, ...) (p pipeline.Pipeline, err error)

+ func ValidateFromTo(src, dst string, userSpecifiedFromTo string) (common.FromTo, error)

+ type AccountTraverser interface

type BlobFSAccountTraverser

+ func (t *BlobFSAccountTraverser) IsDirectory(isSource bool) bool

+ func (t *BlobFSAccountTraverser) Traverse(preprocessor objectMorpher, processor objectProcessor, filters []ObjectFilter) error

+ type CookedCopyCmdArgs struct

+ CheckLength bool

+ CpkOptions common.CpkOptions

+ Destination common.ResourceString

+ ExcludeFileAttributes []string

+ ExcludePathPatterns []string

+ ExcludePatterns []string

+ FollowSymlinks bool

+ ForceIfReadOnly bool

+ ForceWrite common.OverwriteOption

+ FromTo common.FromTo

+ IncludeAfter *time.Time

+ IncludeBefore *time.Time

+ IncludeDirectoryStubs bool

+ IncludeFileAttributes []string

+ IncludePatterns []string

+ ListOfFilesChannel chan string

+ ListOfVersionIDs chan string

+ LogVerbosity common.LogLevel

+ Recursive bool

+ S2sPreserveBlobTags bool

+ Source common.ResourceString

+ StripTopDir bool

+ func (cca *CookedCopyCmdArgs) Cancel(lcm common.LifecycleMgr)

+ func (cca *CookedCopyCmdArgs) InitModularFilters() []ObjectFilter

+ func (cca *CookedCopyCmdArgs) MakeEscapedRelativePath(source bool, dstIsDir bool, object StoredObject) (relativePath string)

+ func (cca *CookedCopyCmdArgs) ReportProgressOrExit(lcm common.LifecycleMgr) (totalKnownCount uint32)

+ type CopyEnumerator struct

+ Filters []ObjectFilter

+ Finalize func() error

+ ObjectDispatcher objectProcessor

+ Traverser ResourceTraverser

+ func NewCopyEnumerator(traverser ResourceTraverser, filters []ObjectFilter, ...) *CopyEnumerator

+ type FilterSet []ObjectFilter

+ func (fs FilterSet) GetEnumerationPreFilter(recursive bool) string

+ type IncludeAfterDateFilter struct

+ Threshold time.Time

+ func (_ IncludeAfterDateFilter) FormatAsUTC(t time.Time) string

+ func (_ IncludeAfterDateFilter) ParseISO8601(s string, chooseEarliest bool) (time.Time, error)

+ func (f *IncludeAfterDateFilter) AppliesOnlyToFiles() bool

+ func (f *IncludeAfterDateFilter) DoesPass(storedObject StoredObject) bool

+ func (f *IncludeAfterDateFilter) DoesSupportThisOS() (msg string, supported bool)

+ type IncludeBeforeDateFilter struct

+ Threshold time.Time

+ func (_ IncludeBeforeDateFilter) FormatAsUTC(t time.Time) string

+ func (_ IncludeBeforeDateFilter) ParseISO8601(s string, chooseEarliest bool) (time.Time, error)

+ func (f *IncludeBeforeDateFilter) AppliesOnlyToFiles() bool

+ func (f *IncludeBeforeDateFilter) DoesPass(storedObject StoredObject) bool

+ func (f *IncludeBeforeDateFilter) DoesSupportThisOS() (msg string, supported bool)

+ type IncludeFilter struct

+ func (f *IncludeFilter) AppliesOnlyToFiles() bool

+ func (f *IncludeFilter) DoesPass(storedObject StoredObject) bool

+ func (f *IncludeFilter) DoesSupportThisOS() (msg string, supported bool)

type LocationLevel

+ func DetermineLocationLevel(location string, locationType common.Location, source bool) (LocationLevel, error)

+ type ObjectFilter interface

+ AppliesOnlyToFiles func() bool

+ DoesPass func(storedObject StoredObject) bool

+ DoesSupportThisOS func() (msg string, supported bool)

+ type ResourceTraverser interface

+ IsDirectory func(isSource bool) bool

+ Traverse func(preprocessor objectMorpher, processor objectProcessor, filters []ObjectFilter) error

+ func InitResourceTraverser(resource common.ResourceString, location common.Location, ctx *context.Context, ...) (ResourceTraverser, error)

+ type StoredObject struct

+ ContainerName string

+ DstContainerName string

+ Metadata common.Metadata

+ func (s *StoredObject) ToNewCopyTransfer(steWillAutoDecompress bool, Source string, Destination string, ...) (transfer common.CopyTransfer, shouldSendToSte bool)

Aug 31, 2021

Changes in this version

+ const PreservePermissionsFlag

+ func IsDestinationCaseInsensitive(fromTo common.FromTo) bool

+ func WrapFolder(fullpath string, stat os.FileInfo) (os.FileInfo, error)

Jun 15, 2021

Changes in this version

+ func WarnStdoutAndScanningLog(toLog string)

Apr 14, 2021

Changes in this version

+ const NumOfFilesPerDispatchJobPart

+ var FinalPartCreatedMessage = "Final job part has been created"

+ var IPv4Regex = regexp.MustCompile(`\d+\.\d+\.\d+\.\d+`)

+ var NothingScheduledError = errors.New("no transfers were scheduled because no files matched the specified criteria")

+ var NothingToRemoveError = errors.New("nothing found to remove")

+ var Rpc = func(cmd common.RpcCmd, request interface{}, response interface{})

+ func Execute(azsAppPathFolder, logPathFolder string, jobPlanFolder string, ...)

+ func GetAccountRoot(resource common.ResourceString, location common.Location) (string, error)

+ func GetContainerName(path string, location common.Location) (string, error)

+ func GetCredTypeFromEnvVar() common.CredentialType

+ func GetOAuthTokenManagerInstance() (*common.UserOAuthTokenManager, error)

+ func GetResourceRoot(resource string, location common.Location) (resourceBase string, err error)

+ func GetUserOAuthTokenManagerInstance() *common.UserOAuthTokenManager

+ func HandleListJobsCommand(jobStatus common.JobStatus) error

+ func HandlePauseCommand(jobIdString string)

+ func HandleShowCommand(listRequest common.ListRequest) error

+ func ParseSizeString(s string, name string) (int64, error)

+ func PrintExistingJobIds(listJobResponse common.ListJobsResponse) error

+ func PrintJobProgressSummary(summary common.ListJobSummaryResponse)

+ func PrintJobTransfers(listTransfersResponse common.ListJobTransfersResponse)

+ func SplitResourceString(raw string, loc common.Location) (common.ResourceString, error)

+ func UnfurlSymlinks(symlinkPath string) (result string, err error)

+ func WalkWithSymlinks(fullPath string, walkFunc filepath.WalkFunc, followSymlinks bool) (err error)

+ func WarnStdoutAndJobLog(toLog string)

+ type BlobFSAccountTraverser struct

+ type BucketToContainerNameResolver interface

+ ResolveName func(bucketName string) (string, error)

+ type GCPBucketNameToAzureResourcesResolver struct

+ func NewGCPBucketNameToAzureResourcesResolver(gcpBucketNames []string) *GCPBucketNameToAzureResourcesResolver

+ func (resolver *GCPBucketNameToAzureResourcesResolver) ResolveName(bucketName string) (string, error)

+ type HTTPClient struct

+ func NewHttpClient(url string) *HTTPClient

+ type ListReq struct

+ JobID common.JobID

+ OfStatus string

+ type ListResponse struct

+ ErrorMsg string

+ type LocationLevel uint8

+ var ELocationLevel LocationLevel = 0

+ func (LocationLevel) Container() LocationLevel

+ func (LocationLevel) Object() LocationLevel

+ func (LocationLevel) Service() LocationLevel

+ type S3BucketNameToAzureResourcesResolver struct

+ func NewS3BucketNameToAzureResourcesResolver(s3BucketNames []string) *S3BucketNameToAzureResourcesResolver

+ func (s3Resolver *S3BucketNameToAzureResourcesResolver) ResolveName(bucketName string) (string, error)

+ type Version struct

+ func NewVersion(raw string) (*Version, error)

+ func (v Version) NewerThan(v2 Version) bool

+ func (v Version) OlderThan(v2 Version) bool