add PeekAll method - Githubissues

jhunters / bigqueue

Golang implements for BigQueue

Apache License 2.0

57 stars 23 forks source link

Closed jhunters closed 3 years ago

jhunters commented 3 years ago

PeekAll method could watch all avaible data but without modify offset index.

filequeue: func (q *FileQueue) PeekAll() ([][]byte, []int64, error) {}

fanoutqueue func (q *FileFanoutQueue) PeekAll(fanoutID int64) ([][]byte, []int64, error) {}