From 5fdd222aaa43079107a2ab28bf55a29012f27f4e Mon Sep 17 00:00:00 2001
From: Sydonian <794346190@qq.com>
Date: Thu, 24 Oct 2024 15:42:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=B9=89storage=E5=87=A0=E4=B8=AAfeat?=
 =?UTF-8?q?ure=E7=9A=84=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 common/pkgs/storage/shard/pool/pool.go          |  4 ++++
 .../pkgs/storage/shard/storages/local/config.go | 12 ------------
 .../pkgs/storage/shard/storages/local/local.go  | 17 ++++++++++++++---
 common/pkgs/storage/temp/local.go               | 13 +++++++++++++
 common/pkgs/storage/temp/temp_store.go          |  4 ++++
 5 files changed, 35 insertions(+), 15 deletions(-)
 delete mode 100644 common/pkgs/storage/shard/storages/local/config.go
 create mode 100644 common/pkgs/storage/temp/local.go
 create mode 100644 common/pkgs/storage/temp/temp_store.go

diff --git a/common/pkgs/storage/shard/pool/pool.go b/common/pkgs/storage/shard/pool/pool.go
index 12ecee8..560414a 100644
--- a/common/pkgs/storage/shard/pool/pool.go
+++ b/common/pkgs/storage/shard/pool/pool.go
@@ -12,6 +12,10 @@ func New() *ShardStorePool {
 
 }
 
+func (p *ShardStorePool) PutNew(stg cdssdk.Storage, config cdssdk.ShardStoreConfig) error {
+
+}
+
 func (p *ShardStorePool) Get(stgID cdssdk.StorageID) (types.ShardStore, error) {
 
 }
diff --git a/common/pkgs/storage/shard/storages/local/config.go b/common/pkgs/storage/shard/storages/local/config.go
deleted file mode 100644
index 256f326..0000000
--- a/common/pkgs/storage/shard/storages/local/config.go
+++ /dev/null
@@ -1,12 +0,0 @@
-package local
-
-import "gitlink.org.cn/cloudream/storage/common/pkgs/shardstore/types"
-
-type Config struct {
-	RootPath string
-	MaxSize  int64
-}
-
-func (c *Config) Build() types.ShardStore {
-	return &Local{cfg: *c}
-}
diff --git a/common/pkgs/storage/shard/storages/local/local.go b/common/pkgs/storage/shard/storages/local/local.go
index d35af7f..4acde43 100644
--- a/common/pkgs/storage/shard/storages/local/local.go
+++ b/common/pkgs/storage/shard/storages/local/local.go
@@ -3,11 +3,18 @@ package local
 import (
 	"io"
 
-	"gitlink.org.cn/cloudream/storage/common/pkgs/shardstore/types"
+	cdssdk "gitlink.org.cn/cloudream/common/sdks/storage"
+	"gitlink.org.cn/cloudream/storage/common/pkgs/storage/shard/types"
 )
 
 type Local struct {
-	cfg Config
+	cfg cdssdk.LocalShardStorage
+}
+
+func New(stg cdssdk.Storage, cfg cdssdk.LocalShardStorage) *Local {
+	return &Local{
+		cfg: cfg,
+	}
 }
 
 func (s *Local) New() io.Writer {
@@ -24,7 +31,11 @@ func (s *Local) Remove(hash types.FileHash) error {
 }
 
 // 遍历所有文件，callback返回false则停止遍历
-func (s *Local) Walk(callback func(info types.FileInfo) bool) error {
+func (s *Local) ListAll() ([]types.FileInfo, error) {
+
+}
+
+func (s *Local) Purge(availables []types.FileHash) error {
 
 }
 
diff --git a/common/pkgs/storage/temp/local.go b/common/pkgs/storage/temp/local.go
new file mode 100644
index 0000000..b7c90b8
--- /dev/null
+++ b/common/pkgs/storage/temp/local.go
@@ -0,0 +1,13 @@
+package tempstore
+
+import cdssdk "gitlink.org.cn/cloudream/common/sdks/storage"
+
+type LocalTempStore struct {
+	cfg cdssdk.BypassUploadFeature
+}
+
+func NewLocalTempStore(cfg cdssdk.BypassUploadFeature) *LocalTempStore {
+	return &LocalTempStore{
+		cfg: cfg,
+	}
+}
diff --git a/common/pkgs/storage/temp/temp_store.go b/common/pkgs/storage/temp/temp_store.go
new file mode 100644
index 0000000..eea2fdc
--- /dev/null
+++ b/common/pkgs/storage/temp/temp_store.go
@@ -0,0 +1,4 @@
+package tempstore
+
+type TempStore interface {
+}