Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
Eolink
goku-api-gateway
提交
dac55eb4
G
goku-api-gateway
项目概览
Eolink
/
goku-api-gateway
上一次同步 1 年多
通知
133
Star
2992
Fork
611
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
G
goku-api-gateway
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
提交
dac55eb4
编写于
9月 28, 2019
作者:
Y
Your Name
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
完善注释
上级
8c59d071
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
3 addition
and
73 deletion
+3
-73
app/goku-node/main.go
app/goku-node/main.go
+3
-3
goku-node/queue/queue.go
goku-node/queue/queue.go
+0
-70
未找到文件。
app/goku-node/main.go
浏览文件 @
dac55eb4
...
...
@@ -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
(
"gok
u_n
ode.InitLog"
)
log
.
Debug
(
"gok
N
ode.InitLog"
)
r
:=
redis_manager
.
Create
(
&
config
.
Redis
)
redis_manager
.
SetDefault
(
r
)
log
.
Debug
(
"redis
_
manager.SetDefault"
)
log
.
Debug
(
"redis
-
manager.SetDefault"
)
// 其他需要初始化的模块
_
=
general
.
General
()
...
...
goku-node/queue/queue.go
已删除
100644 → 0
浏览文件 @
8c59d071
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
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录