Documentation
¶
Index ¶
- Variables
- func AdminVisibility(status model.BucketStatus) bool
- func S3Visibility(status model.BucketStatus) bool
- type BucketVisibility
- type Reader
- func (r *Reader) Open(ctx context.Context, bucketName, key string, visible BucketVisibility) (*Result, error)
- func (r *Reader) OpenVersion(ctx context.Context, bucketName, key, versionID string, ...) (*Result, error)
- func (r *Reader) OpenVersionForCopy(ctx context.Context, bucketName, key, versionID string, ...) (*Result, error)
- type Result
- type Source
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidArgument = errors.New("object reader: invalid argument") ErrNoSuchBucket = errors.New("object reader: bucket not found") ErrNoSuchKey = errors.New("object reader: object not found") ErrNoSuchVersion = errors.New("object reader: object version not found") ErrMethodNotAllowed = errors.New("object reader: method not allowed") ErrCacheRead = errors.New("object reader: cache read failed") ErrCacheMiss = errors.New("object reader: cache miss") ErrProviderDownload = errors.New("object reader: provider download failed") )
Functions ¶
func AdminVisibility ¶
func AdminVisibility(status model.BucketStatus) bool
func S3Visibility ¶
func S3Visibility(status model.BucketStatus) bool
Types ¶
type BucketVisibility ¶
type BucketVisibility func(model.BucketStatus) bool
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func New ¶
func New( repos *repository.Repositories, cache cache.Cache, storage synapse.StorageClient, cacheGate *cacheaccess.Gate, accessTracker *cacheaccess.Tracker, logger *slog.Logger, ) *Reader
func (*Reader) OpenVersion ¶
func (*Reader) OpenVersionForCopy ¶
func (r *Reader) OpenVersionForCopy(ctx context.Context, bucketName, key, versionID string, visible BucketVisibility) (*Result, error)
OpenVersionForCopy opens an explicit version without rehydrating a missing source cache entry.
Source Files
Click to show internal directories.
Click to hide internal directories.