From dac55eb4fc62c8fa3d668b7a9d6bd33048cf384e Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: Sat, 28 Sep 2019 10:57:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84=E6=B3=A8=E9=87=8A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/goku-node/main.go    |  6 ++--
 goku-node/queue/queue.go | 70 ----------------------------------------
 2 files changed, 3 insertions(+), 73 deletions(-)
 delete mode 100644 goku-node/queue/queue.go

diff --git a/app/goku-node/main.go b/app/goku-node/main.go
index 6e3937d1..0554b556 100644
--- a/app/goku-node/main.go
+++ b/app/goku-node/main.go
@@ -13,7 +13,7 @@ import (
 
 	"github.com/eolinker/goku-api-gateway/common/database"
 	"github.com/eolinker/goku-api-gateway/common/general"
-	"github.com/eolinker/goku-api-gateway/common/redis-manager"
+	redis_manager "github.com/eolinker/goku-api-gateway/common/redis-manager"
 	goku_node "github.com/eolinker/goku-api-gateway/goku-node"
 	"github.com/eolinker/goku-api-gateway/server/entity"
 )
@@ -69,11 +69,11 @@ func main() {
 		return
 	}
 	goku_node.InitLog()
-	log.Debug("goku_node.InitLog")
+	log.Debug("gokNode.InitLog")
 	r := redis_manager.Create(&config.Redis)
 	redis_manager.SetDefault(r)
 
-	log.Debug("redis_manager.SetDefault")
+	log.Debug("redis-manager.SetDefault")
 	// 其他需要初始化的模块
 	_ = general.General()
 
diff --git a/goku-node/queue/queue.go b/goku-node/queue/queue.go
deleted file mode 100644
index 651039cd..00000000
--- a/goku-node/queue/queue.go
+++ /dev/null
@@ -1,70 +0,0 @@
-package queue
-
-type GokuQueue interface {
-	Size() int                //大小
-	Front() interface{}       //第一个元素
-	End() interface{}         //最后一个元素
-	IsEmpty() bool            //是否为空
-	Enqueue(data interface{}) //入队
-	Dequeue() interface{}     //出对
-	Clear()                   //清空
-}
-
-type Queue struct {
-	datastore []interface{}
-	theSize   int
-}
-
-func (goku_queue *Queue) Clear() {
-	goku_queue.datastore = make([]interface{}, 0) //开辟内存
-	goku_queue.theSize = 0
-}
-
-func NewQueue() *Queue {
-	goku_queue := new(Queue)
-	goku_queue.Clear()
-	return goku_queue
-
-}
-
-func (goku_queue *Queue) Size() int {
-	return goku_queue.theSize //大小
-}
-
-func (goku_queue *Queue) Front() interface{} {
-	if goku_queue.Size() == 0 { //判断是否为空
-		return nil
-	}
-	return goku_queue.datastore[0]
-}
-
-func (goku_queue *Queue) End() interface{} {
-	if goku_queue.Size() == 0 { //判断是否为空
-		return nil
-	}
-	return goku_queue.datastore[goku_queue.theSize-1]
-}
-
-func (goku_queue *Queue) IsEmpty() bool {
-	return goku_queue.theSize == 0
-}
-
-func (goku_queue *Queue) Enqueue(data interface{}) {
-	goku_queue.datastore = append(goku_queue.datastore, data) //入队
-	goku_queue.theSize = goku_queue.theSize + 1
-}
-
-func (goku_queue *Queue) Dequeue() interface{} {
-	size := len(goku_queue.datastore)
-	if size < 1 { //判断是否为空
-		return nil
-	}
-	datastore := make([]interface{}, 0)
-	data := goku_queue.datastore[0]
-	if goku_queue.theSize > 1 {
-		datastore = goku_queue.datastore[1:] //截取
-	}
-	goku_queue.datastore = datastore
-	goku_queue.theSize = goku_queue.theSize - 1
-	return data
-}
-- 
GitLab