run

package
v0.0.0-...-d7cb029 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 24, 2020 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDbRumperExecutor

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

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
}

Directories

Path Synopsis
redis command struct.
redis command struct.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL