| 136 | } |
| 137 | |
| 138 | type RedisQueue struct { |
| 139 | log *zap.Logger |
| 140 | red *redis.Client |
| 141 | currentBlock *uint64 |
| 142 | queueName string |
| 143 | |
| 144 | Config RedisQueueConfig |
| 145 | } |
| 146 | |
| 147 | func NewRedisQueue(log *zap.Logger, red *redis.Client, queueName string) *RedisQueue { |
| 148 | currentBlock := uint64(0) |
nothing calls this directly
no outgoing calls
no test coverage detected