azure

Jan 8, 2025

Changes in this version

type MockAzureClient

+ UploadContentType string

Jul 8, 2022

Changes in this version

type Client

+ DeleteAllVersions func(file vfs.File) error

type DefaultClient

+ func (a *DefaultClient) DeleteAllVersions(file vfs.File) error

type MockAzureClient

+ func (a *MockAzureClient) DeleteAllVersions(file vfs.File) error

Oct 6, 2021

Changes in this version

+ const Name

+ const Scheme

+ func IsValidURI(u *url.URL) bool

+ func ParsePath(p string) (host, pth string, err error)

+ type BlobProperties struct

+ LastModified *time.Time

+ Metadata map[string]string

+ Size uint64

+ func NewBlobProperties(azureProps *azblob.BlobGetPropertiesResponse) *BlobProperties

+ type Client interface

+ Copy func(srcFile vfs.File, tgtFile vfs.File) error

+ Delete func(file vfs.File) error

+ Download func(file vfs.File) (io.ReadCloser, error)

+ List func(l vfs.Location) ([]string, error)

+ Properties func(locationURI, filePath string) (*BlobProperties, error)

+ SetMetadata func(file vfs.File, metadata map[string]string) error

+ Upload func(file vfs.File, content io.ReadSeeker) error

+ type DefaultClient struct

+ func NewClient(options *Options) (*DefaultClient, error)

+ func (a *DefaultClient) Copy(srcFile, tgtFile vfs.File) error

+ func (a *DefaultClient) Delete(file vfs.File) error

+ func (a *DefaultClient) Download(file vfs.File) (io.ReadCloser, error)

+ func (a *DefaultClient) List(l vfs.Location) ([]string, error)

+ func (a *DefaultClient) Properties(containerURI, filePath string) (*BlobProperties, error)

+ func (a *DefaultClient) SetMetadata(file vfs.File, metadata map[string]string) error

+ func (a *DefaultClient) Upload(file vfs.File, content io.ReadSeeker) error

+ type DefaultTokenCredentialFactory struct

+ func (f *DefaultTokenCredentialFactory) New(tenantID, clientID, clientSecret, azureEnvName string) (azblob.TokenCredential, error)

+ type File struct

+ func (f *File) Close() error

+ func (f *File) CopyToFile(file vfs.File) error

+ func (f *File) CopyToLocation(location vfs.Location) (vfs.File, error)

+ func (f *File) Delete() error

+ func (f *File) Exists() (bool, error)

+ func (f *File) LastModified() (*time.Time, error)

+ func (f *File) Location() vfs.Location

+ func (f *File) MoveToFile(file vfs.File) error

+ func (f *File) MoveToLocation(location vfs.Location) (vfs.File, error)

+ func (f *File) Name() string

+ func (f *File) Path() string

+ func (f *File) Read(p []byte) (n int, err error)

+ func (f *File) Seek(offset int64, whence int) (int64, error)

+ func (f *File) Size() (uint64, error)

+ func (f *File) String() string

+ func (f *File) Touch() error

+ func (f *File) URI() string

+ func (f *File) Write(p []byte) (int, error)

+ type FileSystem struct

+ func NewFileSystem() *FileSystem

+ func (fs *FileSystem) Client() (Client, error)

+ func (fs *FileSystem) Host() string

+ func (fs *FileSystem) Name() string

+ func (fs *FileSystem) NewFile(volume, absFilePath string) (vfs.File, error)

+ func (fs *FileSystem) NewLocation(volume, absLocPath string) (vfs.Location, error)

+ func (fs *FileSystem) Retry() vfs.Retry

+ func (fs *FileSystem) Scheme() string

+ func (fs *FileSystem) WithClient(client Client) *FileSystem

+ func (fs *FileSystem) WithOptions(opts vfs.Options) *FileSystem

+ type Location struct

+ func (l *Location) ChangeDir(relLocPath string) error

+ func (l *Location) ContainerURL() string

+ func (l *Location) DeleteFile(relFilePath string) error

+ func (l *Location) Exists() (bool, error)

+ func (l *Location) FileSystem() vfs.FileSystem

+ func (l *Location) List() ([]string, error)

+ func (l *Location) ListByPrefix(prefix string) ([]string, error)

+ func (l *Location) ListByRegex(regex *regexp.Regexp) ([]string, error)

+ func (l *Location) NewFile(relFilePath string) (vfs.File, error)

+ func (l *Location) NewLocation(relLocPath string) (vfs.Location, error)

+ func (l *Location) Path() string

+ func (l *Location) String() string

+ func (l *Location) URI() string

+ func (l *Location) Volume() string

+ type MockAzureClient struct

+ ExpectedError error

+ ExpectedResult interface{}

+ PropertiesError error

+ PropertiesResult *BlobProperties

+ func (a *MockAzureClient) Copy(srcFile, tgtFile vfs.File) error

+ func (a *MockAzureClient) Delete(file vfs.File) error

+ func (a *MockAzureClient) Download(file vfs.File) (io.ReadCloser, error)

+ func (a *MockAzureClient) List(l vfs.Location) ([]string, error)

+ func (a *MockAzureClient) Properties(locationURI, filePath string) (*BlobProperties, error)

+ func (a *MockAzureClient) SetMetadata(file vfs.File, metadata map[string]string) error

+ func (a *MockAzureClient) Upload(file vfs.File, content io.ReadSeeker) error

+ type MockStorageError struct

+ func (mse MockStorageError) Error() string

+ func (mse MockStorageError) Response() *http.Response

+ func (mse MockStorageError) ServiceCode() azblob.ServiceCodeType

+ func (mse MockStorageError) Temporary() bool

+ func (mse MockStorageError) Timeout() bool

+ type MockTokenCredentialFactory struct

+ func (f *MockTokenCredentialFactory) New(tenantID, clientID, clientSecret, azureEnvName string) (azblob.TokenCredential, error)

+ type Options struct

+ AccountKey string

+ AccountName string

+ AzureEnvName string

+ ClientID string

+ ClientSecret string

+ FileBufferSize int

+ RetryFunc vfs.Retry

+ TenantID string

+ func NewOptions() *Options

+ func (o *Options) Credential() (azblob.Credential, error)

+ type TokenCredentialFactory interface

+ New func(tenantID, clientID, clientSecret, azureEnvName string) (azblob.TokenCredential, error)