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)
	InspectObject(ctx context.Context, objectName string) (ObjectMetadata, error)
	InspectFolder(ctx context.Context, folderName string) (FolderContents, error)
	Inventory(ctx context.Context) (Inventory, 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 FolderContents struct {
	FolderName       string
	Exists           bool
	Objects          []ObjectMetadata
	ObjectCount      int64
	PhysicalBytes    int64
	NewestModifiedAt time.Time
}

type FolderInventory struct {
	FolderName       string
	Parts            []PartObject
	Blocks           ObjectSummary
	Merged           *ObjectMetadata
	Unknown          ObjectSummary
	ObjectCount      int64
	PhysicalBytes    int64
	NewestModifiedAt time.Time
}

type IndexedObjectMissingError struct {
	Index int
}

type Inventory struct {
	Folders          []FolderInventory
	LooseObjects     []ObjectMetadata
	TemporaryUploads []ObjectMetadata
	ObjectCount      int64
	PhysicalBytes    int64
	NewestModifiedAt time.Time
}

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

type ObjectNotFoundError struct {
	ObjectName string
}

type ObjectSummary struct {
	ObjectCount      int64
	PhysicalBytes    int64
	NewestModifiedAt time.Time
}

type PartObject struct {
	Index      int
	SizeBytes  int64
	ModifiedAt time.Time
}

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

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