| 30 | const MaxReadRetry = 10 |
| 31 | |
| 32 | type Queue struct { |
| 33 | engine storage.Engine |
| 34 | path *storage.URI |
| 35 | headPath *storage.URI |
| 36 | tailPath *storage.URI |
| 37 | tailLockPath *storage.URI |
| 38 | } |
| 39 | |
| 40 | func New(engine storage.Engine, path *storage.URI) *Queue { |
| 41 | return &Queue{ |
nothing calls this directly
no outgoing calls
no test coverage detected