YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-15 08:16:43 +00:00
Code Issues Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
Newnius
2019-05-06 15:36:31 +08:00
parent 9c2bca2c32
commit 412bf9b8c7
2 changed files with 2 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Dockerfile.dev
View File

@@ -1,12 +0,0 @@
FROM ubuntu:16.04
RUN apt update && \
apt install -y wget vim git gcc httpie dnsutils
RUN wget https://dl.google.com/go/go1.12.4.linux-amd64.tar.gz && \
tar -C /usr/local -xzf go1.12.4.linux-amd64.tar.gz && \
rm go1.12.4.linux-amd64.tar.gz
ENV PATH $PATH:/usr/local/go/bin
RUN go get github.com/Shopify/sarama

3
src/resource_pool.go
View File

@@ -15,6 +15,7 @@ type ResourcePool struct {
func (pool *ResourcePool) start() { func (pool *ResourcePool) start() {
go func() { go func() {
/* waiting for data */ /* waiting for data */
pool.history = []PoolStatus{}
time.Sleep(time.Second * 30) time.Sleep(time.Second * 30)
for { for {
summary := PoolStatus{} summary := PoolStatus{}
@@ -58,7 +59,7 @@ func (pool *ResourcePool) start() {
pool.history = append(pool.history, summary) pool.history = append(pool.history, summary)
if len(pool.history) > 60 { if len(pool.history) > 60 {
pool.history = pool.history[0:60] pool.history = pool.history[len(pool.history)-60:]
} }
time.Sleep(time.Second * 60) time.Sleep(time.Second * 60)
} }