run

Documentation

Index

• type CmdDecode
  • func (cmd *CmdDecode) GetDetailedInfo() []interface{}
  • func (cmd *CmdDecode) Main()
  • func (cmd *CmdDecode) Stat() *cmdDecodeStat
• type CmdDump
  • func (cmd *CmdDump) DumpCommand(reader *bufio.Reader, writer *bufio.Writer, nsize int64)
  • func (cmd *CmdDump) DumpRDBFile(reader *bufio.Reader, writer *bufio.Writer, nsize int64)
  • func (cmd *CmdDump) GetDetailedInfo() []interface{}
  • func (cmd *CmdDump) Main()
  • func (cmd *CmdDump) SendCmd(master, auth_type, passwd string) (net.Conn, int64)
• type CmdRestore
  • func (cmd *CmdRestore) GetDetailedInfo() []interface{}
  • func (cmd *CmdRestore) Main()
  • func (cmd *CmdRestore) RestoreCommand(reader *bufio.Reader, target, auth_type, passwd string)
  • func (cmd *CmdRestore) RestoreRDBFile(reader *bufio.Reader, target, auth_type, passwd string, nsize int64)
  • func (cmd *CmdRestore) Stat() *cmdRestoreStat
• type CmdRump
  • func (cr *CmdRump) GetDetailedInfo() []interface{}
  • func (cr *CmdRump) Main()
• type CmdSync
  • func (cmd *CmdSync) GetDetailedInfo() []interface{}
  • func (cmd *CmdSync) Main()
  • func (cmd *CmdSync) PSyncPipeCopy(c net.Conn, br *bufio.Reader, bw *bufio.Writer, offset int64, copyto io.Writer) (int64, error)
  • func (cmd *CmdSync) SendPSyncCmd(master, auth_type, passwd string) (pipe.Reader, int64)
  • func (cmd *CmdSync) SendSyncCmd(master, auth_type, passwd string) (net.Conn, int64)
  • func (cmd *CmdSync) Stat() *cmdSyncStat
  • func (cmd *CmdSync) SyncCommand(reader *bufio.Reader, target, auth_type, passwd string)
  • func (cmd *CmdSync) SyncRDBFile(reader *bufio.Reader, target, auth_type, passwd string, nsize int64)
• type KeyNode

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 {
}

func (*CmdDump) DumpCommand

func (cmd *CmdDump) DumpCommand(reader *bufio.Reader, writer *bufio.Writer, nsize int64)

func (*CmdDump) DumpRDBFile

func (cmd *CmdDump) DumpRDBFile(reader *bufio.Reader, writer *bufio.Writer, nsize int64)

func (*CmdDump) GetDetailedInfo

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

func (*CmdDump) Main

func (cmd *CmdDump) Main()

func (*CmdDump) SendCmd

func (cmd *CmdDump) SendCmd(master, auth_type, passwd string) (net.Conn, int64)

type CmdRestore

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

func (*CmdRestore) GetDetailedInfo

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

func (*CmdRestore) Main

func (cmd *CmdRestore) Main()

func (*CmdRestore) RestoreCommand

func (cmd *CmdRestore) RestoreCommand(reader *bufio.Reader, target, auth_type, passwd string)

func (*CmdRestore) RestoreRDBFile

func (cmd *CmdRestore) RestoreRDBFile(reader *bufio.Reader, target, auth_type, passwd string, nsize int64)

func (*CmdRestore) Stat

func (cmd *CmdRestore) Stat() *cmdRestoreStat

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
}

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()

func (*CmdSync) PSyncPipeCopy

func (cmd *CmdSync) PSyncPipeCopy(c net.Conn, br *bufio.Reader, bw *bufio.Writer, offset int64, copyto io.Writer) (int64, error)

func (*CmdSync) SendPSyncCmd

func (cmd *CmdSync) SendPSyncCmd(master, auth_type, passwd string) (pipe.Reader, int64)

func (*CmdSync) SendSyncCmd

func (cmd *CmdSync) SendSyncCmd(master, auth_type, passwd string) (net.Conn, int64)

func (*CmdSync) Stat

func (cmd *CmdSync) Stat() *cmdSyncStat

func (*CmdSync) SyncCommand

func (cmd *CmdSync) SyncCommand(reader *bufio.Reader, target, auth_type, passwd string)

func (*CmdSync) SyncRDBFile

func (cmd *CmdSync) SyncRDBFile(reader *bufio.Reader, target, auth_type, passwd string, nsize int64)

type KeyNode

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