azio

Apr 3, 2024

Changes in this version

+ const DefaultBufferSize

+ const DefaultMaxConcurrency

+ const DefaultMaxRetries

+ const DefaultMinBytes

+ func BlobOpener(ctx context.Context, p *BlobPath) (func(ctx context.Context, bufSize int) io.ReadSeeker, error)

+ func CopyContextConfig(dst, src context.Context) context.Context

+ func OpenBlob(ctx context.Context, p *BlobPath, bufSize int) (io.ReadSeeker, error)

+ func ReadBlob(ctx context.Context, p *BlobPath) ([]byte, error)

+ func ReadBlobRange(ctx context.Context, p *BlobPath, start int64, out []byte) (int, error)

+ func Stat(ctx context.Context, p *BlobPath) (fs.FileInfo, error)

+ func WriteBlob(ctx context.Context, p *BlobPath, r io.Reader) error

+ type BlobConcurrency struct

+ MaxConcurrency uint16

+ MinBytes int64

+ func DefaultBlobConcurrency() BlobConcurrency

+ func GetBlobConcurrency(ctx context.Context) BlobConcurrency

+ type BlobPath struct

+ Account string

+ Container string

+ Path string

+ func ParseBlobPath(s string) (*BlobPath, error)

+ func (b *BlobPath) Base() string

+ func (b *BlobPath) Client(ctx context.Context) (*azblob.Client, error)

+ func (b *BlobPath) Join(subPath string) *BlobPath

+ func (b *BlobPath) String() string

+ type ClientStore struct

+ func GetClientStore(ctx context.Context) *ClientStore

+ func GlobalClientStore() *ClientStore

+ func NewClientStore(options azblob.ClientOptions) *ClientStore

+ func NewDefaultClientStore() *ClientStore

+ func (c *ClientStore) Client(account string) (*azblob.Client, error)

+ type ContextKey int

+ const ContextKeyBlobConcurrency

+ const ContextKeyClientStore