blobops

type Fake struct {

	// Error injection functions - if set, these will be called and their error returned
	CreateContainerErr       func(containerName string) error
	EnsureContainerErr       func(containerName string) error
	ContainerExistsErr       func(containerName string) error
	UploadBlobErr            func(containerName, blobName string) error
	DeleteBlobErr            func(containerName, blobName string) error
	GetMetadataErr           func(containerName, blobName string) error
	GetBlobErr               func(containerName, blobName string) error
	NewListBlobsFlatPagerErr func(containerName string) error
	// contains filtered or unexported fields
}

type Ops interface {
	// CreateContainer creates a container.
	CreateContainer(ctx context.Context, containerName string) error
	// EnsureContainer creates a container if it doesn't exist.
	EnsureContainer(ctx context.Context, containerName string) error
	// ContainerExists checks if a container exists.
	ContainerExists(ctx context.Context, containerName string) (bool, error)
	// UploadBlob uploads a blob with the given metadata and data. md can be nil.
	UploadBlob(ctx context.Context, containerName, blobName string, md map[string]*string, data []byte) error
	// DeleteBlob deletes the specified blob from the given container.
	DeleteBlob(ctx context.Context, containerName string, blobName string) error
	// GetMetadata retrieves the metadata of a blob.
	GetMetadata(ctx context.Context, containerName, blobName string) (map[string]*string, error)
	// GetBlob downloads the blob data.
	GetBlob(ctx context.Context, containerName, blobName string) ([]byte, error)

	// NewListBlobsFlatPager creates a pager for listing blobs in a container.
	// Returns a pager that can be used to iterate through blob listings.
	NewListBlobsFlatPager(containerName string, options *azblob.ListBlobsFlatOptions) *runtime.Pager[azblob.ListBlobsFlatResponse]
}

type Real struct {
	Client *azblob.Client
}