storage

type Adapter interface {
	UploadStream(ctx context.Context, objectName string, stream io.Reader) error
	CopyObject(ctx context.Context, sourceObjectName, destinationObjectName string) error
	CreateDownloadStream(ctx context.Context, objectName string) (io.ReadCloser, error)
	// CreateRangedDownloadStream returns exactly count bytes beginning at offset.
	// A short underlying object must surface as io.ErrUnexpectedEOF rather than
	// a successful EOF so callers never serve a silently truncated range.
	CreateRangedDownloadStream(ctx context.Context, objectName string, offset, count int64) (io.ReadCloser, error)
	InspectObject(ctx context.Context, objectName string) (ObjectMetadata, error)
	InspectFolderSummary(ctx context.Context, folderName string) (FolderSummary, error)
	InspectIndexedFolder(ctx context.Context, folderName string, expectedObjects int) (int64, error)
	// InspectIndexedFolderSizes validates the same contiguous numeric object set
	// as InspectIndexedFolder and returns sizes ordered by object index.
	InspectIndexedFolderSizes(ctx context.Context, folderName string, expectedObjects int) ([]int64, error)
	WalkTopLevelFolders(ctx context.Context, visit func(folderName string) error) error
	ObjectExists(ctx context.Context, objectName string) (bool, error)
	DeleteFolder(ctx context.Context, folderName string) error
	CountFilesInFolder(ctx context.Context, folderName string) (int, error)
	Clear(ctx context.Context) error
}

type ComposeAdapter interface {
	ComposeObjects(ctx context.Context, destinationObjectName string, sourceObjectNames []string) error
}

type DirectDownloadAdapter interface {
	CreateDownloadURL(ctx context.Context, objectName string, ttl time.Duration) (string, error)
}

type FilesystemAdapter struct {
	// contains filtered or unexported fields
}

type FilesystemUsage struct {
	CapacityBytes int64
	UsedBytes     int64
}

type FilesystemUsageAdapter interface {
	FilesystemUsage(ctx context.Context) (FilesystemUsage, error)
}

type FolderSummary struct {
	FolderName       string
	Exists           bool
	ObjectCount      int64
	PhysicalBytes    int64
	NewestModifiedAt time.Time
}

type IndexedObjectLimitExceededError struct {
	Count int
	Limit int
}

type IndexedObjectMissingError struct {
	Index int
}

type ObjectMetadata struct {
	Name       string
	SizeBytes  int64
	ModifiedAt time.Time
}

type ObjectNotFoundError struct {
	ObjectName string
}

type S3Adapter struct {
	// contains filtered or unexported fields
}

type TemporaryUploadCleaner interface {
	WalkTemporaryUploads(ctx context.Context, visit func(ObjectMetadata) error) error
	CleanupTemporaryUploads(ctx context.Context, candidates []ObjectMetadata, cutoff time.Time) (int, error)
}