storage

type FileStorage interface {
	// Save writes the contents of r to the given path, creating intermediate
	// directories as needed. If a file already exists at path it is overwritten.
	Save(ctx context.Context, path string, r io.Reader) error

	// Open returns a ReadCloser for the file at path. The caller is
	// responsible for closing the returned reader.
	Open(ctx context.Context, path string) (io.ReadCloser, error)

	// Delete removes the file at path. It is idempotent — deleting a
	// non-existent file returns nil.
	Delete(ctx context.Context, path string) error

	// Exists reports whether a file exists at path.
	Exists(ctx context.Context, path string) (bool, error)

	// List returns all file paths under the given prefix. Paths are relative
	// to the storage root. An empty prefix lists all files.
	List(ctx context.Context, prefix string) ([]string, error)
}

type LocalOption func(*LocalStorage)

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

type S3Config struct {
	Endpoint        string // e.g. "http://localhost:9000" for RustFS
	Bucket          string
	Region          string
	AccessKeyID     string
	SecretAccessKey string
	UsePathStyle    bool // true for RustFS / path-style addressing
}

type S3Option func(*S3Storage)

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

type SignOption func(*signConfig)

type SignableStorage interface {
	FileStorage

	// SignURL returns a pre-signed GET URL for the file at path that
	// expires after the given duration. Options such as WithAttachment
	// alter how the backend serves the response.
	SignURL(ctx context.Context, path string, expiry time.Duration, opts ...SignOption) (string, error)
}