diff options
| -rw-r--r-- | pkg/worker_watcher/container/queue/queue.go | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/pkg/worker_watcher/container/queue/queue.go b/pkg/worker_watcher/container/queue/queue.go index a792d7c1..4f611bbe 100644 --- a/pkg/worker_watcher/container/queue/queue.go +++ b/pkg/worker_watcher/container/queue/queue.go @@ -26,18 +26,15 @@ type Queue struct { head *Node tail *Node - recvCh chan worker.BaseProcess - curr uint64 - len uint64 + curr uint64 + len uint64 sliceSize uint64 } func NewQueue() *Queue { q := &Queue{ - mu: sync.Mutex{}, - // w/o buffering - recvCh: make(chan worker.BaseProcess), + mu: sync.Mutex{}, head: nil, tail: nil, curr: 0, |