package tech.powerjob.server.extension.dfs;
|
|
import java.io.IOException;
|
import java.util.Optional;
|
|
/**
|
* 分布式文件服务
|
*
|
* @author tjq
|
* @since 2023/7/16
|
*/
|
public interface DFsService {
|
|
/**
|
* 存储文件
|
* @param storeRequest 存储请求
|
* @throws IOException 异常
|
*/
|
void store(StoreRequest storeRequest) throws Exception;
|
|
/**
|
* 下载文件
|
* @param downloadRequest 文件下载请求
|
* @throws IOException 异常
|
*/
|
void download(DownloadRequest downloadRequest) throws Exception;
|
|
/**
|
* 获取文件元信息
|
* @param fileLocation 文件位置
|
* @return 存在则返回文件元信息
|
* @throws IOException 异常
|
*/
|
Optional<FileMeta> fetchFileMeta(FileLocation fileLocation) throws Exception;
|
|
/**
|
* 清理 powerjob 认为“过期”的文件
|
* 部分存储系统自带生命周期管理（如阿里云OSS，则不需要单独实现该方法）
|
* @param bucket bucket
|
* @param days 天数，需要清理超过 X 天的文件
|
*/
|
default void cleanExpiredFiles(String bucket, int days) {
|
}
|
}
|
