remove relay log

ledis/ledis.go

@@ -12,7 +12,6 @@ type Config struct {
 	DataDB leveldb.Config `json:"data_db"`
 
 	BinLog replication.BinLogConfig `json:"binlog"`
-	RelayLog replication.RelayLogConfig `json:"relaylog"`
 }
 
 type DB struct {
@@ -37,7 +36,6 @@ type Ledis struct {
 	dbs [MaxDBNumber]*DB
 
 	binlog *replication.Log
-	relaylog *replication.Log
 
 	quit chan struct{}
 }
@@ -73,15 +71,6 @@ func OpenWithConfig(cfg *Config) (*Ledis, error) {
 		l.binlog = nil
 	}
 
-	if len(cfg.RelayLog.Path) > 0 {
-		l.relaylog, err = replication.NewRelayLogWithConfig(&cfg.RelayLog)
-		if err != nil {
-			return nil, err
-		}
-	} else {
-		l.relaylog = nil
-	}
-
 	for i := uint8(0); i < MaxDBNumber; i++ {
 		l.dbs[i] = newDB(l, i)
 	}
@@ -117,11 +106,6 @@ func (l *Ledis) Close() {
 		l.binlog.Close()
 		l.binlog = nil
 	}
-
-	if l.relaylog != nil {
-		l.relaylog.Close()
-		l.relaylog = nil
-	}
 }
 
 func (l *Ledis) Select(index int) (*DB, error) {

ledis/replication.go

@@ -12,7 +12,6 @@ import (
 
 var (
 	errInvalidBinLogEvent = errors.New("invalid binglog event")
-	errRelayLogNotSupported = errors.New("write relay log not supported")
 )
 
 func (l *Ledis) replicateEvent(event []byte) error {
@@ -131,13 +130,3 @@ func (l *Ledis) RepliateRelayLog(relayLog string, offset int64) (int64, error) {
 	log.Error("can not go here")
 	return offset, nil
 }
-
-func (l *Ledis) WriteRelayLog(data []byte) error {
-	if l.relaylog == nil {
-		return errRelayLogNotSupported
-	}
-
-	err := l.relaylog.Log(data)
-
-	return err
-}