Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisLPOPReader ¶
type RedisLPOPReader struct {
// contains filtered or unexported fields
}
RedisLPOPReader is a abstraction of LPOP list and behaves like a reader
func NewLPOPReader ¶
func NewLPOPReader(rc *redis.Conn, db int, queue string) *RedisLPOPReader
NewLPOPReader creates a new RedisLPOPScanner
func (*RedisLPOPReader) Read ¶
func (rl *RedisLPOPReader) Read(p []byte) (n int, err error)
Read LPOP the redis queue and use a bytes reader to copy the resulting data in p
func (*RedisLPOPReader) Teardown ¶
func (rl *RedisLPOPReader) Teardown()
Teardown is called on error to close the redis connection
Source Files
Click to show internal directories.
Click to hide internal directories.