redisrangereader

Documentation

Index

• type RedisRangeReader
  • func NewRedisRangeReader(client *redis.Client, key string) *RedisRangeReader
  • func (r *RedisRangeReader) Read(p []byte) (n int, err error)

Types

type RedisRangeReader

type RedisRangeReader struct {
	LinesPerRead int64
	// contains filtered or unexported fields
}

RedisRangeReader reads lrange from redis

func NewRedisRangeReader

func NewRedisRangeReader(client *redis.Client, key string) *RedisRangeReader

NewRedisRangeReader creates RedisRangeReader instance

func (*RedisRangeReader) Read

func (r *RedisRangeReader) Read(p []byte) (n int, err error)