azblob

Dec 20, 2024

Changes in this version

type Reader

+ func NewReaderDefaultAuth(url string, opts ...ReaderOption) (Reader, error)

Oct 8, 2024

Changes in this version

+ var ErrUnspecifiedContainer = errors.New("storer: container is unspecified")

Aug 16, 2024

Changes in this version

+ const DebugLevel

+ type Logger = logger.Logger

May 24, 2024

Changes in this version

+ type ReaderOption func(*ReaderOptions)

+ func WithAccountName(accountName string) ReaderOption

+ func WithContainer(container string) ReaderOption

+ type ReaderOptions struct

+ func ParseReaderOptions(options ...ReaderOption) ReaderOptions

May 3, 2024

Changes in this version

+ type FilterResponse struct

+ Items []*azStorageBlob.FilterBlobItem

+ Marker ListMarker

+ Status string

+ StatusCode int

type Reader

+ FilteredList func(ctx context.Context, tagsFilter string, opts ...Option) (*FilterResponse, error)

Apr 16, 2024

Changes in this version

type Option

+ func WithListMaxResults(maxResults int32) Option

Jan 31, 2024

Changes in this version

+ type Reader interface

+ List func(ctx context.Context, opts ...Option) (*ListerResponse, error)

+ Reader func(ctx context.Context, identity string, opts ...Option) (*ReaderResponse, error)

+ func NewReaderNoAuth(accountName string, url string, container string) (Reader, error)

Nov 30, 2023

Changes in this version

+ type ListMarker *string

+ type ListerResponse struct

+ Items []*azStorageBlob.BlobItemInternal

+ Marker ListMarker

+ Prefix string

+ Status string

+ StatusCode int

type Option

+ func WithListDelim(delim string) Option

+ func WithListMarker(marker ListMarker) Option

+ func WithListMetadata() Option

+ func WithListPrefix(prefix string) Option

+ func WithListTags() Option

type ReaderResponse

+ ContentLength int64

type Storer

+ func (azp *Storer) Delete(ctx context.Context, identity string) error

+ func (azp *Storer) List(ctx context.Context, opts ...Option) (*ListerResponse, error)

Nov 8, 2023

Changes in this version

+ const ContentKey

+ const HashKey

+ const MimeKey

+ const SizeKey

+ const TimeKey

+ var ErrMustSupportSeek0 = errors.New("must be seekable to position 0")

+ type BytesSeekableReaderCloser struct

+ func NewBytesReaderCloser(b []byte) *BytesSeekableReaderCloser

+ func (io *BytesSeekableReaderCloser) Close() error

+ type ContainerClient = azStorageBlob.ContainerClient

+ type DevConfig struct

+ AccountName string

+ Key string

+ URL string

+ func NewDevConfigFromEnv() DevConfig

+ type ETagCondition int

+ const ETagMatch

+ const ETagNoneMatch

+ const EtagNotUsed

+ const TagsWhere

+ type Error struct

+ func ErrorFromError(err error) *Error

+ func NewStatusError(text string, statusCode int) *Error

+ func (e *Error) Error() string

+ func (e *Error) IsConditionNotMet() bool

+ func (e *Error) StatusCode() int

+ func (e *Error) StorageErrorCode() string

+ func (e *Error) Unwrap() error

+ type GetMetadata int

+ const BothMetadataAndBlob

+ const NoMetadata

+ const OnlyMetadata

+ func (g GetMetadata) String() string

+ type HTTPError interface

+ Error func() string

+ StatusCode func() int

+ Unwrap func() error

+ type IfSinceCondition int

+ const IfConditionModifiedSince

+ const IfConditionNotUsed

+ const IfConditionUnmodifiedSince

+ type LeaseRenewer func(ctx context.Context) error

+ type Option func(*StorerOptions)

+ func WithEtagMatch(etag string) Option

+ func WithEtagNoneMatch(etag string) Option

+ func WithGetMetadata(value GetMetadata) Option

+ func WithGetTags() Option

+ func WithLeaseID(leaseID string) Option

+ func WithMetadata(metadata map[string]string) Option

+ func WithModifiedSince(since *time.Time) Option

+ func WithSizeLimit(sizeLimit int64) Option

+ func WithTags(tags map[string]string) Option

+ func WithUnmodifiedSince(since *time.Time) Option

+ func WithWhereTags(whereTags string) Option

+ type ReaderResponse struct

+ BlobClient *azStorageBlob.BlobClient

+ ETag *string

+ HashValue string

+ LastModified *time.Time

+ Metadata map[string]string

+ MimeType string

+ Reader io.ReadCloser

+ ScannedBadReason string

+ ScannedStatus string

+ ScannedTimestamp string

+ Size int64

+ Status string

+ StatusCode int

+ Tags map[string]string

+ TimestampAccepted string

+ XMsErrorCode string

+ func (r *ReaderResponse) ConditionNotMet() bool

+ func (r *ReaderResponse) DownloadToWriter(w io.Writer) error

+ func (r *ReaderResponse) Ok() bool

+ type ServiceClient = azStorageBlob.ServiceClient

+ type SharedKeyCredential = azStorageBlob.SharedKeyCredential

+ type Storer struct

+ AccountName string

+ Container string

+ ResourceGroup string

+ Subscription string

+ func New(accountName string, resourceGroup string, subscription string, ...) (*Storer, error)

+ func NewDev(cfg DevConfig, container string) (*Storer, error)

+ func (azp *Storer) AcquireLease(ctx context.Context, objectname string, leaseTimeout int32) (string, error)

+ func (azp *Storer) AcquireLeaseRenewable(ctx context.Context, objectname string, leaseTimeout int32) (string, LeaseRenewer, error)

+ func (azp *Storer) Count(ctx context.Context, tagsFilter string) (int64, error)

+ func (azp *Storer) FilteredList(ctx context.Context, tagsFilter string) ([]*azStorageBlob.FilterBlobItem, error)

+ func (azp *Storer) Put(ctx context.Context, identity string, source io.ReadSeekCloser, opts ...Option) (*WriteResponse, error)

+ func (azp *Storer) Reader(ctx context.Context, identity string, opts ...Option) (*ReaderResponse, error)

+ func (azp *Storer) ReleaseLease(ctx context.Context, objectname string, leaseID string) error

+ func (azp *Storer) ReleaseLeaseDeferable(ctx context.Context, objectname string, leaseID string)

+ func (azp *Storer) Write(ctx context.Context, identity string, source io.Reader, opts ...Option) (*WriteResponse, error)

+ func (azp *Storer) WriteStream(ctx context.Context, identity string, source *http.Request, opts ...Option) (*WriteResponse, error)

+ func (s *Storer) GetContainerClient() *azStorageBlob.ContainerClient

+ func (s *Storer) GetServiceClient() *azStorageBlob.ServiceClient

+ type StorerOptions struct

+ type WriteResponse struct

+ ETag *string

+ HashValue string

+ LastModified *time.Time

+ MimeType string

+ Size int64

+ Status string

+ StatusCode int

+ TimestampAccepted string

+ XMsErrorCode string