feat(middleware): add middleware

middleware/config/get_middleware_map.go

@@ -0,0 +1,14 @@
+package config
+
+import (
+	"gitee.com/timedb/wheatCache/middleware"
+	logMiddle "gitee.com/timedb/wheatCache/middleware/log-middle"
+)
+
+func GetMiddlewareMap() map[string]middleware.MiddlewareInterface {
+	logMiddle := logMiddle.NewLogMiddle()
+
+	return map[string]middleware.MiddlewareInterface{
+		"logMiddle": logMiddle,
+	}
+}

middleware/logmiddle/middleware.go

@@ -0,0 +1,22 @@
+package log_middle
+
+import (
+	"fmt"
+
+	"gitee.com/timedb/wheatCache/middleware"
+)
+
+type logmiddle struct {
+}
+
+func (l *logmiddle) Init() {
+	fmt.Println("1")
+}
+
+func (l *logmiddle) Exet(interface{}) (interface{}, error) {
+	return nil, nil
+}
+
+func NewLogMiddle() middleware.MiddlewareInterface {
+	return &logmiddle{}
+}

pkg/lru/define.go

@@ -6,17 +6,17 @@ type SingleWorkFunc func() interface{}
 
 const (
 	OptionEventName  = "operateEvent"
-	CleanEventName = "clearEvent"
+	CleanEventName   = "clearEvent"
 	WorkFuncEventKey = "workFunc"
 )
 
 var (
 	lruCacheOnce sync.Once
-	lruCache *singleCache
+	lruCache     *singleCache
 )
 
 const (
-	lruMaxSize = 1*1024*1024*1024*8
-	lruClearSize = 0.5*1024*1024*1024*8
+	lruMaxSize     = 1 * 1024 * 1024 * 1024 * 8
+	lruClearSize   = 0.5 * 1024 * 1024 * 1024 * 8
 	lruEventDriver = 2000
 )

pkg/middle/middleware_driver_test.go

@@ -19,7 +19,8 @@ func Test_middleware_driver(t *testing.T) {
 		driver: *NewMiddleWare(),
 	}
 
-	
+	library.driver.work(ctx)
+
 	type A struct {
 		produce event.ProduceInterface
 	}

shell/make-struct.py

@@ -62,7 +62,6 @@ def set_structure_const_template(conf: dict):
     val_set = []
     for k, v in conf.items():
         key_map.append(KeyMap(key=k, val=v))
-
         for val in v:
             val_set.append(val.upper())
 

shell/proto.py

@@ -14,7 +14,7 @@ def out_proto():
         for f in files:
             commend = comm.format(protoPath, root, sysPath, f).strip()
             err = os.system(commend)
-
+            
             if err:
                 print(f, "-> out put err")
             else:
@@ -23,3 +23,4 @@ def out_proto():
 
 if __name__ == '__main__':
     out_proto()
+