Versions in this module Expand all Collapse all v2 v2.1.1 Sep 25, 2020 Changes in this version + type InMemoryQueueStorage struct + MaxSize int + func (q *InMemoryQueueStorage) AddRequest(r []byte) error + func (q *InMemoryQueueStorage) GetRequest() ([]byte, error) + func (q *InMemoryQueueStorage) Init() error + func (q *InMemoryQueueStorage) QueueSize() (int, error) + type Queue struct + Threads int + func New(threads int, s Storage) (*Queue, error) + func (q *Queue) AddRequest(r *colly.Request) error + func (q *Queue) AddURL(URL string) error + func (q *Queue) IsEmpty() bool + func (q *Queue) Run(c *colly.Collector) error + func (q *Queue) Size() (int, error) + type Storage interface + AddRequest func([]byte) error + GetRequest func() ([]byte, error) + Init func() error + QueueSize func() (int, error) Other modules containing this package github.com/ravilushqa/colly
Go to main page