Mode | Name | Size | |
---|---|---|---|
-rw-r--r-- | backoff.go | 1611 | logstatsplain |
-rw-r--r-- | base.go | 897 | logstatsplain |
-rw-r--r-- | base_channel.go | 2322 | 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 | 3562 | logstatsplain |
-rw-r--r-- | config.go | 872 | logstatsplain |
d--------- | lqinternal | 41 | logstatsplain |
-rw-r--r-- | manager.go | 3470 | 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 | 11549 | logstatsplain |
-rw-r--r-- | workerqueue.go | 7535 | logstatsplain |
-rw-r--r-- | workerqueue_test.go | 9418 | logstatsplain |