Method SetNode

cmd/cqld/adapter.go:69–110

SetNode handles dht storage node update.

(node *proto.Node)

// SetNode handles dht storage node update.
func (s *LocalStorage) SetNode(node *proto.Node) (err error) {
	query := "INSERT OR REPLACE INTO `dht` (`id`, `node`) VALUES (?, ?);"
	log.Debugf("sql: %#v", query)

	nodeBuf, err := utils.EncodeMsgPack(node)
	if err != nil {
		err = errors.Wrap(err, "encode node failed")
		return
	}

	err = route.SetNodeAddrCache(node.ID.ToRawNodeID(), node.Addr)
	if err != nil {
		log.WithFields(log.Fields{
			"id":   node.ID,
			"addr": node.Addr,
		}).WithError(err).Error("set node addr cache failed")
	}
	err = kms.SetNode(node)
	if err != nil {
		log.WithField("node", node).WithError(err).Error("kms set node failed")
	}

	// if s.consistent == nil, it is called during Init. and AddCache will be called by consistent.InitConsistent
	if s.consistent != nil {
		s.consistent.AddCache(*node)
	}

	// execute query
	if _, err = s.Storage.Exec(context.Background(), []storage.Query{
		{
			Pattern: query,
			Args: []sql.NamedArg{
				sql.Named("", node.ID),
				sql.Named("", nodeBuf.Bytes()),
			},
		},
	}); err != nil {
		err = errors.Wrap(err, "execute query in dht database failed")
	}

	return
}

// KVServer holds LocalStorage instance and implements consistent persistence interface.
type KVServer struct {