diff --git a/common/assets/confs/agent.config.json b/common/assets/confs/agent.config.json index 161a7b7..f1e1f66 100644 --- a/common/assets/confs/agent.config.json +++ b/common/assets/confs/agent.config.json @@ -20,7 +20,11 @@ "address": "127.0.0.1:5672", "account": "cloudream", "password": "123456", - "vhost": "/" + "vhost": "/", + "param": { + "retryNum": 5, + "retryInterval": 5000 + } }, "ipfs": { "address": "127.0.0.1:5001" diff --git a/common/assets/confs/client.config.json b/common/assets/confs/client.config.json index 94a0f29..ed23a56 100644 --- a/common/assets/confs/client.config.json +++ b/common/assets/confs/client.config.json @@ -15,7 +15,11 @@ "address": "127.0.0.1:5672", "account": "cloudream", "password": "123456", - "vhost": "/" + "vhost": "/", + "param": { + "retryNum": 5, + "retryInterval": 5000 + } }, "ipfs": null, "distlock": { diff --git a/common/assets/confs/coordinator.config.json b/common/assets/confs/coordinator.config.json index 181e3ba..af60414 100644 --- a/common/assets/confs/coordinator.config.json +++ b/common/assets/confs/coordinator.config.json @@ -15,6 +15,10 @@ "address": "127.0.0.1:5672", "account": "cloudream", "password": "123456", - "vhost": "/" + "vhost": "/", + "param": { + "retryNum": 5, + "retryInterval": 5000 + } } } \ No newline at end of file diff --git a/common/assets/confs/scanner.config.json b/common/assets/confs/scanner.config.json index f39720c..4e08823 100644 --- a/common/assets/confs/scanner.config.json +++ b/common/assets/confs/scanner.config.json @@ -18,7 +18,11 @@ "address": "106.75.6.194:5672", "account": "cloudream", "password": "cloudream123456", - "vhost": "/" + "vhost": "/", + "param": { + "retryNum": 5, + "retryInterval": 5000 + } }, "distlock": { "etcdAddress": "106.75.6.194:2379", diff --git a/common/pkgs/storage/shard/storages/local/writer.go b/common/pkgs/storage/shard/storages/local/writer.go index b93ccaf..4fb1735 100644 --- a/common/pkgs/storage/shard/storages/local/writer.go +++ b/common/pkgs/storage/shard/storages/local/writer.go @@ -1,6 +1,6 @@ package local -import "gitlink.org.cn/cloudream/storage/common/pkgs/shardstore/types" +import "gitlink.org.cn/cloudream/storage/common/pkgs/storage/shard/types" type Writer struct { } diff --git a/common/pkgs/storage/temp/temp_store.go b/common/pkgs/storage/temp/temp_store.go index eea2fdc..ce51f0a 100644 --- a/common/pkgs/storage/temp/temp_store.go +++ b/common/pkgs/storage/temp/temp_store.go @@ -1,4 +1,7 @@ package tempstore type TempStore interface { + CreateTemp() + Commited(objectName string) + Drop(objectName string) }