cmd

Documentation

Index

• type AofCmd
  • func NewAofCmd() *AofCmd
  • func (rc *AofCmd) Cmd()
  • func (sc *AofCmd) Name() string
  • func (rc *AofCmd) Parse()
  • func (rc *AofCmd) Run() error
  • func (sc *AofCmd) Stop() error
  • func (rc *AofCmd) Verify()
• type Cmd
• type DiffCmd
  • func NewDiffCmd() *DiffCmd
  • func (sc *DiffCmd) Name() string
  • func (rc *DiffCmd) Run() error
  • func (dc *DiffCmd) Scan()
  • func (sc *DiffCmd) Stop() error
• type RdbCmd
  • func NewRdbCmd() *RdbCmd
  • func (rc *RdbCmd) Load(rdbPath string, cfg *config.RdbCmdLoad) error
  • func (sc *RdbCmd) Name() string
  • func (rc *RdbCmd) Print(rdbPath string, cfg *config.RdbCmdPrint) error
  • func (rc *RdbCmd) Run() error
  • func (sc *RdbCmd) Stop() error
• type SyncerCmd
  • func NewSyncerCmd() *SyncerCmd
  • func (sc *SyncerCmd) Name() string
  • func (sc *SyncerCmd) Run() error
  • func (sc *SyncerCmd) Stop() error
  • func (sc *SyncerCmd) Sync(req *pb.SyncRequest, stream pb.ApiService_SyncServer) error

Types

type AofCmd

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

func NewAofCmd

func NewAofCmd() *AofCmd

func (*AofCmd) Cmd

func (rc *AofCmd) Cmd()

func (*AofCmd) Name

func (sc *AofCmd) Name() string

func (*AofCmd) Parse

func (rc *AofCmd) Parse()

func (*AofCmd) Run

func (rc *AofCmd) Run() error

func (*AofCmd) Stop

func (sc *AofCmd) Stop() error

func (*AofCmd) Verify

func (rc *AofCmd) Verify()

type Cmd

type Cmd interface {
	Name() string
	Run() error  // Run is a blocking function
	Stop() error // non-block, just notify cmd to stop
}

type DiffCmd

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

func NewDiffCmd

func NewDiffCmd() *DiffCmd

func (*DiffCmd) Name

func (sc *DiffCmd) Name() string

func (*DiffCmd) Run

func (rc *DiffCmd) Run() error

func (*DiffCmd) Scan

func (dc *DiffCmd) Scan()

func (*DiffCmd) Stop

func (sc *DiffCmd) Stop() error

type RdbCmd

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

func NewRdbCmd

func NewRdbCmd() *RdbCmd

func (*RdbCmd) Load

func (rc *RdbCmd) Load(rdbPath string, cfg *config.RdbCmdLoad) error

func (*RdbCmd) Name

func (sc *RdbCmd) Name() string

func (*RdbCmd) Print

func (rc *RdbCmd) Print(rdbPath string, cfg *config.RdbCmdPrint) error

func (*RdbCmd) Run

func (rc *RdbCmd) Run() error

func (*RdbCmd) Stop

func (sc *RdbCmd) Stop() error

type SyncerCmd

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

func NewSyncerCmd

func NewSyncerCmd() *SyncerCmd

func (*SyncerCmd) Name

func (sc *SyncerCmd) Name() string

func (*SyncerCmd) Run

func (sc *SyncerCmd) Run() error

func (*SyncerCmd) Stop

func (sc *SyncerCmd) Stop() error

func (*SyncerCmd) Sync

func (sc *SyncerCmd) Sync(req *pb.SyncRequest, stream pb.ApiService_SyncServer) error