gsadmin/rustfs
1
0
Fork 0
mirror of https://github.com/rustfs/rustfs.git synced 2026-07-26 08:18:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix init_global_action_cred

Browse Source
This commit is contained in:
weisd
2024-12-10 20:47:48 +08:00
parent 47231c559c
commit e80ca05a2e
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
rustfs/src/main.rs
+12 -10
View File
@@ -89,7 +89,18 @@ async fn run(opt: config::Opt) -> Result<()> {
debug!("server_address {}", &server_address);
iam::init_global_action_cred(None, None).unwrap();
//设置AK和SK
//其中部份内容从config配置文件中读取
let mut access_key = String::from_str(config::DEFAULT_ACCESS_KEY).unwrap();
let mut secret_key = String::from_str(config::DEFAULT_SECRET_KEY).unwrap();
// Enable authentication
if let (Some(ak), Some(sk)) = (opt.access_key, opt.secret_key) {
access_key = ak;
secret_key = sk;
}
iam::init_global_action_cred(Some(access_key.clone()), Some(secret_key.clone())).unwrap();
set_global_rustfs_port(server_port);
//监听地址,端口从参数中获取
@@ -124,16 +135,7 @@ async fn run(opt: config::Opt) -> Result<()> {
let store = storage::ecfs::FS::new();
// let mut b = S3ServiceBuilder::new(storage::ecfs::FS::new(server_address.clone(), endpoint_pools).await?);
let mut b = S3ServiceBuilder::new(store.clone());
//设置AK和SK
//其中部份内容从config配置文件中读取
let mut access_key = String::from_str(config::DEFAULT_ACCESS_KEY).unwrap();
let mut secret_key = String::from_str(config::DEFAULT_SECRET_KEY).unwrap();
// Enable authentication
if let (Some(ak), Some(sk)) = (opt.access_key, opt.secret_key) {
access_key = ak;
secret_key = sk;
}
//显示info信息
info!("authentication is enabled {}, {}", &access_key, &secret_key);
b.set_auth(IAMAuth::new(access_key, secret_key));