From 6826a0b22ddb991a25f01aacf96665250dc96d2f Mon Sep 17 00:00:00 2001 From: Ingo Oppermann Date: Wed, 21 Jun 2023 16:37:57 +0200 Subject: [PATCH] Only accept log commands --- cluster/store/store.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/cluster/store/store.go b/cluster/store/store.go index 2372bdab..e65db3dd 100644 --- a/cluster/store/store.go +++ b/cluster/store/store.go @@ -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,