blobstorage

Nov 17, 2023

Changes in this version

type BlobInterface

+ CreateBlockBlobClient func(fileName, containerName string) (*blockblob.Client, error)

+ MountFile func(ctx context.Context, blockBlobClient *blockblob.Client, blockIDs *[]string) error

+ PutBlock func(ctx context.Context, blockBlockClient *blockblob.Client, blockID uint16, ...) (string, error)

Oct 26, 2023

Changes in this version

+ const DEFAULT_BS_URL_EXPIRY_TIME

Oct 24, 2023

Changes in this version

+ type BlobInfo struct

+ FileURL string

+ LastModified time.Time

+ Name string

+ type BlobInterface interface

+ DownloadBlob func(blobInfo BlobInfo, containerName string) (*azblob.DownloadStreamResponse, error)

+ DownloadFile func(blobInfo BlobInfo, containerName string) error

+ GetBlobClient func() *azblob.Client

+ GetSasUrl func(blobName, containerName string) (string, error)

+ ListBlobs func(containerName string) ([]*BlobInfo, error)

+ UploadBlobBuffer func(blobName, containerName string, data []byte) error

+ UploadBlobStream func(blobName, containerName string, data io.Reader) error

+ UploadFile func(blobName, containerName string, blobSize int) error

+ WriteToFile func(blobName string, response azblob.DownloadStreamResponse) error

+ func New(conf *config.Config) BlobInterface