Versions in this module Expand all Collapse all v0 v0.7.2 Jan 27, 2026 v0.7.1 Aug 22, 2025 v0.7.0 Jul 29, 2025 v0.6.9 Jul 25, 2025 v0.6.8 Jul 25, 2025 v0.6.7 Jul 8, 2025 v0.6.6 Jul 3, 2025 v0.6.5 Jul 3, 2025 v0.6.4 Jul 1, 2025 v0.6.3 Jul 1, 2025 v0.6.2 Jul 1, 2025 v0.6.1 Jun 18, 2025 Changes in this version type RedisQueue + func (c *RedisQueue) Close() v0.6.0 Jun 16, 2025 Changes in this version + func NewRedisConnection(config RedisConnConfig) *redis.Client + type ChannelQueue struct + func NewChannelQueue() *ChannelQueue + func (c *ChannelQueue) Add(item CrawlItem) bool + func (c *ChannelQueue) Close() + func (c *ChannelQueue) Fetch(count int64) <-chan []CrawlItem + func (c *ChannelQueue) Reset() bool + func (c *ChannelQueue) Size() int + type CrawlItem struct + Depth int + URL string + type QueueInterface interface + Add func(item CrawlItem) bool + Close func() + Fetch func(count int64) <-chan []CrawlItem + Reset func() bool + Size func() int + type RedisConnConfig struct + Address string + DB int + Password string + Port int + Username string + type RedisQueue struct + Host string + ID int + func NewRedisQueue(ID int, host string, rdb *redis.Client) *RedisQueue + func (c *RedisQueue) Add(item CrawlItem) + func (c *RedisQueue) Fetch(count int64) <-chan []CrawlItem + func (c *RedisQueue) Reset() + func (c *RedisQueue) Size() int64 v0.0.5 Feb 21, 2025 Changes in this version + type Queue struct + In chan interface{} + Out chan interface{} + func New(parentCtx context.Context) *Queue + func (t *Queue) Add(i interface{}) + func (t *Queue) Close() + func (t *Queue) Pop() (interface{}, error) + func (t *Queue) Size() int
Go to main page