@@ -73,5 +73,7 @@ func (f *CommandFactory) CreateCompareAndSwapCommand(key string, value string, p
}
func (f *CommandFactory) CreateSyncCommand(now time.Time) raft.Command {
- return &SyncCommand{time.Now()}
+ return &SyncCommand{
+ Time: time.Now(),
+ }
@@ -21,7 +21,6 @@ func (c SyncCommand) CommandName() string {
func (c SyncCommand) Apply(server raft.Server) (interface{}, error) {
-
s, _ := server.StateMachine().(store.Store)
s.DeleteExpiredKeys(c.Time)