azure

Documentation

Index

• Constants
• Variables
• func ConvertHeaderToStruct(msg map[string][]string) (*pstruct.Struct, error)
• func ConvertStructToAzureMetadata(pbs *pstruct.Struct) (azfile.Metadata, error)
• func ConvertStructToStructMap(msg map[string]string) (*pstruct.Struct, error)
• type AzureAdapter
  • func (ad *AzureAdapter) Close() error
  • func (ad *AzureAdapter) CreateFileShare(ctx context.Context, fs *file.CreateFileShareRequest) (*file.CreateFileShareResponse, error)
  • func (ad *AzureAdapter) DeleteFileShare(ctx context.Context, fs *file.DeleteFileShareRequest) (*file.DeleteFileShareResponse, error)
  • func (ad *AzureAdapter) GetFileShare(ctx context.Context, fs *file.GetFileShareRequest) (*file.GetFileShareResponse, error)
  • func (ad *AzureAdapter) GetFileSharePermissions(ctx context.Context, fileshareName string) (*azfile.SignedIdentifiers, error)
  • func (ad *AzureAdapter) GetFileShareProperties(ctx context.Context, fileshareName string) (*azfile.ShareGetPropertiesResponse, error)
  • func (ad *AzureAdapter) GetFileShareStatistics(ctx context.Context, fileshareName string) (*azfile.ShareStats, error)
  • func (ad *AzureAdapter) ListFileShare(ctx context.Context, fs *file.ListFileShareRequest) (*file.ListFileShareResponse, error)
  • func (ad *AzureAdapter) ParseFileShare(fs storage.Share) (*file.FileShare, error)
  • func (ad *AzureAdapter) UpdatefileShare(ctx context.Context, fs *file.UpdateFileShareRequest) (*file.UpdateFileShareResponse, error)
  • func (ad *AzureAdapter) UpdatefileShareMetadata(ctx context.Context, fs *file.UpdateFileShareRequest, shareURL azfile.ShareURL) (map[string][]string, error)
  • func (ad *AzureAdapter) UpdatefileShareQuota(ctx context.Context, fs *file.UpdateFileShareRequest, ...) (*file.FileShare, error)
• type AzureFSDriverFactory
  • func (factory *AzureFSDriverFactory) CreateFileStorageDriver(backend *backendpb.BackendDetail) (driver.FileStorageDriver, error)

Constants

const (
	AZURE_FILESHARE_USAGE_BYTES = "Share-Usage-Bytes"

	AZURE_ETAG = "Etag"

	AZURE_LAST_MODIFIED = "Last-Modified"

	AZURE_URL = "URL"

	AZURE_X_MS_SHARE_QUOTA = "X-Ms-Share-Quota"
)

Variables

var MaxTimeForSingleHttpRequest = 50 * time.Minute

TryTimeout indicates the maximum time allowed for any single try of an HTTP request.

Functions

func ConvertHeaderToStruct

func ConvertHeaderToStruct(msg map[string][]string) (*pstruct.Struct, error)

func ConvertStructToAzureMetadata

func ConvertStructToAzureMetadata(pbs *pstruct.Struct) (azfile.Metadata, error)

func ConvertStructToStructMap

func ConvertStructToStructMap(msg map[string]string) (*pstruct.Struct, error)

Types

type AzureAdapter

type AzureAdapter struct {
	// contains filtered or unexported fields
}

func (*AzureAdapter) Close

func (ad *AzureAdapter) Close() error

func (*AzureAdapter) CreateFileShare

func (ad *AzureAdapter) CreateFileShare(ctx context.Context, fs *file.CreateFileShareRequest) (*file.CreateFileShareResponse, error)

func (*AzureAdapter) DeleteFileShare

func (ad *AzureAdapter) DeleteFileShare(ctx context.Context, fs *file.DeleteFileShareRequest) (*file.DeleteFileShareResponse, error)

func (*AzureAdapter) GetFileShare

func (ad *AzureAdapter) GetFileShare(ctx context.Context, fs *file.GetFileShareRequest) (*file.GetFileShareResponse, error)

func (*AzureAdapter) GetFileSharePermissions

func (ad *AzureAdapter) GetFileSharePermissions(ctx context.Context, fileshareName string) (*azfile.SignedIdentifiers, error)

func (*AzureAdapter) GetFileShareProperties

func (ad *AzureAdapter) GetFileShareProperties(ctx context.Context, fileshareName string) (*azfile.ShareGetPropertiesResponse, error)

func (*AzureAdapter) GetFileShareStatistics

func (ad *AzureAdapter) GetFileShareStatistics(ctx context.Context, fileshareName string) (*azfile.ShareStats, error)

func (*AzureAdapter) ListFileShare

func (ad *AzureAdapter) ListFileShare(ctx context.Context, fs *file.ListFileShareRequest) (*file.ListFileShareResponse, error)

func (*AzureAdapter) ParseFileShare

func (ad *AzureAdapter) ParseFileShare(fs storage.Share) (*file.FileShare, error)

func (*AzureAdapter) UpdatefileShare

func (ad *AzureAdapter) UpdatefileShare(ctx context.Context, fs *file.UpdateFileShareRequest) (*file.UpdateFileShareResponse, error)

func (*AzureAdapter) UpdatefileShareMetadata

func (ad *AzureAdapter) UpdatefileShareMetadata(ctx context.Context, fs *file.UpdateFileShareRequest,
	shareURL azfile.ShareURL) (map[string][]string, error)

func (*AzureAdapter) UpdatefileShareQuota

func (ad *AzureAdapter) UpdatefileShareQuota(ctx context.Context, fs *file.UpdateFileShareRequest,
	fsMeta map[string][]string, shareURL azfile.ShareURL) (*file.FileShare, error)

type AzureFSDriverFactory

type AzureFSDriverFactory struct {
}

func (*AzureFSDriverFactory) CreateFileStorageDriver

func (factory *AzureFSDriverFactory) CreateFileStorageDriver(backend *backendpb.BackendDetail) (driver.FileStorageDriver, error)