scanner

Documentation

Index

• type KeyFileScanner
  • func (kfs *KeyFileScanner) Close()
  • func (kfs *KeyFileScanner) EndNode() bool
  • func (kfs *KeyFileScanner) ScanKey() ([]string, error)
• type NormalScanner
  • func (ns *NormalScanner) Close()
  • func (ns *NormalScanner) EndNode() bool
  • func (ns *NormalScanner) ScanKey() ([]string, error)
• type Scanner
  • func NewScanner(client redis.Conn, tencentNodeId string, aliyunNodeId int) Scanner
• type SpecialCloudScanner
  • func (scs *SpecialCloudScanner) Close()
  • func (scs *SpecialCloudScanner) EndNode() bool
  • func (scs *SpecialCloudScanner) ScanKey() ([]string, error)

Types

type KeyFileScanner

type KeyFileScanner struct {
	// contains filtered or unexported fields
}

func (*KeyFileScanner) Close

func (kfs *KeyFileScanner) Close()

func (*KeyFileScanner) EndNode

func (kfs *KeyFileScanner) EndNode() bool

func (*KeyFileScanner) ScanKey

func (kfs *KeyFileScanner) ScanKey() ([]string, error)

type NormalScanner

type NormalScanner struct {
	// contains filtered or unexported fields
}

func (*NormalScanner) Close

func (ns *NormalScanner) Close()

func (*NormalScanner) EndNode

func (ns *NormalScanner) EndNode() bool

func (*NormalScanner) ScanKey

func (ns *NormalScanner) ScanKey() ([]string, error)

type Scanner

type Scanner interface {
	// return scanned keys
	ScanKey() ([]string, error) // return the scanned keys

	// end current node
	EndNode() bool

	Close()
}

scanner used to scan keys

func NewScanner

func NewScanner(client redis.Conn, tencentNodeId string, aliyunNodeId int) Scanner

type SpecialCloudScanner

type SpecialCloudScanner struct {
	// contains filtered or unexported fields
}

func (*SpecialCloudScanner) Close

func (scs *SpecialCloudScanner) Close()

func (*SpecialCloudScanner) EndNode

func (scs *SpecialCloudScanner) EndNode() bool

func (*SpecialCloudScanner) ScanKey

func (scs *SpecialCloudScanner) ScanKey() ([]string, error)