Mode | Name | Size | |
---|---|---|---|
-rw-r--r-- | backoff.go | 1404 | logstatsplain |
-rw-r--r-- | base.go | 897 | logstatsplain |
-rw-r--r-- | base_channel.go | 2336 | logstatsplain |
-rw-r--r-- | base_channel_test.go | 364 | logstatsplain |
-rw-r--r-- | base_dummy.go | 759 | logstatsplain |
-rw-r--r-- | base_levelqueue.go | 2262 | logstatsplain |
-rw-r--r-- | base_levelqueue_common.go | 2424 | logstatsplain |
-rw-r--r-- | base_levelqueue_test.go | 2857 | logstatsplain |
-rw-r--r-- | base_levelqueue_unique.go | 2571 | logstatsplain |
-rw-r--r-- | base_redis.go | 3497 | logstatsplain |
-rw-r--r-- | base_redis_test.go | 1780 | logstatsplain |
-rw-r--r-- | base_test.go | 3580 | logstatsplain |
-rw-r--r-- | config.go | 872 | logstatsplain |
d--------- | lqinternal | 41 | logstatsplain |
-rw-r--r-- | manager.go | 3322 | logstatsplain |
-rw-r--r-- | manager_test.go | 4123 | logstatsplain |
-rw-r--r-- | queue.go | 4082 | logstatsplain |
-rw-r--r-- | testhelper.go | 809 | logstatsplain |
-rw-r--r-- | workergroup.go | 10090 | logstatsplain |
-rw-r--r-- | workerqueue.go | 7170 | logstatsplain |
-rw-r--r-- | workerqueue_test.go | 7848 | logstatsplain |