Function initP2P

IceFireDB-SQLProxy/internal/mysql/p2p.go:25–56

(m *mysqlProxy)

)

func initP2P(m *mysqlProxy) {
	p2pChans = &p2pChannels{}

	// Initialize admin P2P
	p2pChans.adminHost = p2p.NewP2P(config.Get().P2P.ServiceDiscoveryID,
		config.Get().P2P.NodeHostIP, config.Get().P2P.NodeHostPort)

	// Initialize readonly P2P
	p2pChans.readonlyHost = p2p.NewP2P(config.Get().P2P.ServiceDiscoveryID,
		config.Get().P2P.NodeHostIP, config.Get().P2P.NodeHostPort)

	// Connect both to their networks
	connectP2PNetwork(p2pChans.adminHost, config.Get().P2P.ServiceDiscoverMode)
	connectP2PNetwork(p2pChans.readonlyHost, config.Get().P2P.ServiceDiscoverMode)

	// Join pubsub channels
	var err error
	p2pChans.adminPubSub, err = p2p.JoinPubSub(p2pChans.adminHost, "mysql-admin",
		config.Get().P2P.AdminTopic)
	if err != nil {
		panic(err)
	}

	p2pChans.readonlyPubSub, err = p2p.JoinPubSub(p2pChans.readonlyHost, "mysql-readonly",
		config.Get().P2P.ReadonlyTopic)
	if err != nil {
		panic(err)
	}

	logrus.Info("Successfully initialized both admin and readonly P2P channels")
	asyncSQL(m)
}

func connectP2PNetwork(host *p2p.P2P, mode string) {
	switch strings.ToLower(mode) {