diff options
Diffstat (limited to 'modules/queue/queue_disk.go')
| -rw-r--r-- | modules/queue/queue_disk.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/modules/queue/queue_disk.go b/modules/queue/queue_disk.go index 911233a5d9..2691ab02f5 100644 --- a/modules/queue/queue_disk.go +++ b/modules/queue/queue_disk.go @@ -94,6 +94,11 @@ func (fifo *LevelQueueByteFIFO) PushFunc(ctx context.Context, data []byte, fn fu return fifo.internal.LPush(data) } +// PushBack pushes data to the top of the fifo +func (fifo *LevelQueueByteFIFO) PushBack(ctx context.Context, data []byte) error { + return fifo.internal.RPush(data) +} + // Pop pops data from the start of the fifo func (fifo *LevelQueueByteFIFO) Pop(ctx context.Context) ([]byte, error) { data, err := fifo.internal.RPop() |