replica

Documentation

Index

• type Config
• type Replica
  • func NewReplica(config *Config) (*Replica, error)
  • func (r *Replica) Close() error
  • func (r *Replica) SyncWithMaster() error

Types

type Config

type Config struct {
	MasterIP       string
	MasterPort     int
	MasterUser     string
	MasterPassword string

	AnnounceIP   string
	AnnouncePort int

	// Send command (PSYNC MasterReplicaId MasterReplicaOffset) to master.
	// Replica will start a partial synchronization if replicaId and offset exist in master.
	// Set ContinueIfPartialFailed true if you hope do a full synchronized after partial synchronization failed.
	MasterReplicaId     string
	MasterReplicaOffset int

	// Whether to do a full synchronized after partial synchronization failed.
	ContinueIfPartialFailed bool

	// Receive RDB from master in full synchronization. RdbWriter will be closed when full synchronization finished.
	RdbWriter io.WriteCloser

	// Whether to continue incremental synchronization(AOF) after full synchronization.
	ContinueAfterFullSync bool

	// Receive AOF byte stream after full synchronization if ContinueAfterFullSync is true.
	// Receive all AOF bytes stream in partial synchronization.
	AofWriter io.Writer
}

type Replica

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

func NewReplica

func NewReplica(config *Config) (*Replica, error)

func (*Replica) Close

func (r *Replica) Close() error

func (*Replica) SyncWithMaster

func (r *Replica) SyncWithMaster() error

SyncWithMaster establish a connection with the master, and sync data from master. replication.c::syncWithMaster