etcd raft如何实现Linearizable Read
// 执行ReadIndex,ctx是request idif err := s.r.ReadIndex(cctx, ctx); err != nil {cancel() if err == raft.ErrStopped { return
}
plog.Errorf("failed to get read index from raft: %v", err)
nr.notify(err) continue}//等待request id对应的ReadState从readStateC中pop出来for !timeout && !done {
select { case rs =
页:
[1]