Mode | Name | Size | |
---|---|---|---|
-rw-r--r-- | backoff.go | 1404 | 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 | 2893 | logstatsplain |
-rw-r--r-- | base_levelqueue_unique.go | 2571 | logstatsplain |
-rw-r--r-- | base_redis.go | 4166 | logstatsplain |
-rw-r--r-- | base_redis_test.go | 3488 | logstatsplain |
-rw-r--r-- | base_redis_with_server_test.go | 3549 | logstatsplain |
-rw-r--r-- | base_test.go | 3626 | 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 | 4167 | logstatsplain |
d--------- | mock | 99 | logstatsplain |
-rw-r--r-- | queue.go | 4082 | logstatsplain |
-rw-r--r-- | testhelper.go | 809 | logstatsplain |
-rw-r--r-- | workergroup.go | 10683 | logstatsplain |
-rw-r--r-- | workerqueue.go | 7287 | logstatsplain |
-rw-r--r-- | workerqueue_test.go | 9130 | logstatsplain |