neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Only accept log commands

Browse Source
This commit is contained in:
Ingo Oppermann 2023-06-21 16:37:57 +02:00
parent 69e264f22c
commit 6826a0b22d
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cluster/store/store.go
View File

@ -164,6 +164,10 @@ func NewStore(config Config) (Store, error) {
}
func (s *store) Apply(entry *raft.Log) interface{} {
if entry.Type != raft.LogCommand {
return nil
}
logger := s.logger.WithFields(log.Fields{
"index": entry.Index,
"term": entry.Term,