Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisScanner ¶
type RedisScanner struct {
// contains filtered or unexported fields
}
RedisScanner scans redis keys and puts them in a trie
func NewScanner ¶
func NewScanner(redisService RedisServiceInterface, scanProgress adapter.ProgressWriter, logger zerolog.Logger) *RedisScanner
NewScanner creates RedisScanner
func (*RedisScanner) Scan ¶
func (s *RedisScanner) Scan(options adapter.ScanOptions, result *trie.Trie)
Scan initiates scanning process
func (*RedisScanner) ScanCluster ¶
func (s *RedisScanner) ScanCluster(options adapter.ScanOptions, result *trie.Trie)
func (*RedisScanner) ScanSingleNode ¶
func (s *RedisScanner) ScanSingleNode(options adapter.ScanOptions, result *trie.Trie)
type RedisServiceInterface ¶
type RedisServiceInterface interface {
ScanKeys(ctx context.Context, options adapter.ScanOptions, updateChan chan adapter.ShardScanUpdate)
ScanAllShards(ctx context.Context, options adapter.ScanOptions, resultChan chan adapter.ShardScanUpdate) chan adapter.ShardInit
GetKeysCount(ctx context.Context) (int64, error)
GetMemoryUsage(ctx context.Context, key string) (int64, error)
GetTotalShards(ctx context.Context) (int64, error)
GetCurrentNodeIp() string
}
RedisServiceInterface abstraction to access redis
Source Files
Click to show internal directories.
Click to hide internal directories.