run

Documentation

Index

• func NewDbRumperExecutor(rumperId, executorId int, ...) *dbRumperExecutor
• func NewDbSyncer(id int, source, sourcePassword string, target []string, targetPassword string, ...) *dbSyncer
• type CmdDecode
  • func (cmd *CmdDecode) GetDetailedInfo() interface{}
  • func (cmd *CmdDecode) Main()
  • func (cmd *CmdDecode) Stat() *cmdDecodeStat
• type CmdDump
  • func (cmd *CmdDump) GetDetailedInfo() interface{}
  • func (cmd *CmdDump) Main()
• type CmdRestore
  • func (cmd *CmdRestore) GetDetailedInfo() interface{}
  • func (cmd *CmdRestore) Main()
• type CmdRump
  • func (cr *CmdRump) GetDetailedInfo() interface{}
  • func (cr *CmdRump) Main()
• type CmdSync
  • func (cmd *CmdSync) GetDetailedInfo() interface{}
  • func (cmd *CmdSync) Main()
• type KeyNode

Functions

func NewDbRumperExecutor

func NewDbRumperExecutor(rumperId, executorId int, sourceClient, targetClient, targetBigKeyClient redis.Conn,
	tencentNodeId string) *dbRumperExecutor

func NewDbSyncer

func NewDbSyncer(id int, source, sourcePassword string, target []string, targetPassword string, httpPort int) *dbSyncer

------------------------------------------------------ one sync link corresponding to one dbSyncer

Types

type CmdDecode

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

func (*CmdDecode) GetDetailedInfo

func (cmd *CmdDecode) GetDetailedInfo() interface{}

func (*CmdDecode) Main

func (cmd *CmdDecode) Main()

func (*CmdDecode) Stat

func (cmd *CmdDecode) Stat() *cmdDecodeStat

type CmdDump

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

func (*CmdDump) GetDetailedInfo

func (cmd *CmdDump) GetDetailedInfo() interface{}

func (*CmdDump) Main

func (cmd *CmdDump) Main()

type CmdRestore

type CmdRestore struct {
}

func (*CmdRestore) GetDetailedInfo

func (cmd *CmdRestore) GetDetailedInfo() interface{}

func (*CmdRestore) Main

func (cmd *CmdRestore) Main()

type CmdRump

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

func (*CmdRump) GetDetailedInfo

func (cr *CmdRump) GetDetailedInfo() interface{}

func (*CmdRump) Main

func (cr *CmdRump) Main()

type CmdSync

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

main struct

func (*CmdSync) GetDetailedInfo

func (cmd *CmdSync) GetDetailedInfo() interface{}

return send buffer length, delay channel length, target db offset

func (*CmdSync) Main

func (cmd *CmdSync) Main()

type KeyNode

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