Function NewQueue

internal/utils/agents/queue.go:35–40

()

}

func NewQueue() *Queue {
	return &Queue{
		c:        make(chan string, 128),
		cacheMap: NewIPCacheMap(65535),
	}
}

func (this *Queue) Start() {
	for ip := range this.c {