Init implements consistent.Persistence
(storePath string, initNodes []proto.Node)
| 136 | |
| 137 | // Init implements consistent.Persistence |
| 138 | func (s *KVServer) Init(storePath string, initNodes []proto.Node) (err error) { |
| 139 | for _, n := range initNodes { |
| 140 | err = s.storage.SetNode(&n) |
| 141 | if err != nil { |
| 142 | log.WithError(err).Error("init dht kv server failed") |
| 143 | return |
| 144 | } |
| 145 | } |
| 146 | return |
| 147 | } |
| 148 | |
| 149 | // SetNode implements consistent.Persistence |
| 150 | func (s *KVServer) SetNode(node *proto.Node) (err error) { |