Merge pull request #2787 from gravitl/coredns_fix

don't bind coredns to publicip
This commit is contained in:
Abhishek K 2024-01-23 20:20:41 +05:30 committed by GitHub
commit 87e4d020f8
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
5 changed files with 11 additions and 20 deletions

View file

@ -61,6 +61,7 @@ services:
image: coredns/coredns:1.10.1 image: coredns/coredns:1.10.1
command: -conf /root/dnsconfig/Corefile command: -conf /root/dnsconfig/Corefile
env_file: ./netmaker.env env_file: ./netmaker.env
restart: always
depends_on: depends_on:
- netmaker - netmaker
volumes: volumes:

View file

@ -254,7 +254,7 @@ func hostUpdateFallback(w http.ResponseWriter, r *http.Request) {
return return
} }
case models.UpdateMetrics: case models.UpdateMetrics:
mq.UpdateMetricsFallBack(hostUpdate.Node.ID.String(), hostUpdate.NewMetrics) // mq.UpdateMetricsFallBack(hostUpdate.Node.ID.String(), hostUpdate.NewMetrics)
} }
logic.ReturnSuccessResponse(w, r, "updated host data") logic.ReturnSuccessResponse(w, r, "updated host data")

View file

@ -26,23 +26,16 @@ func SetDNSDir() error {
return err return err
} }
_, err = os.Stat(dir + "/config/dnsconfig") err = os.MkdirAll(dir+"/config/dnsconfig", 0744)
if os.IsNotExist(err) {
err = os.MkdirAll(dir+"/config/dnsconfig", 0744)
}
if err != nil { if err != nil {
logger.Log(0, "couldnt find or create /config/dnsconfig") logger.Log(0, "couldnt find or create /config/dnsconfig")
return err return err
} }
_, err = os.Stat(dir + "/config/dnsconfig/Corefile") err = logic.SetCorefile(".")
if os.IsNotExist(err) { if err != nil {
err = logic.SetCorefile(".") logger.Log(0, err.Error())
if err != nil {
logger.Log(0, err.Error())
}
} }
_, err = os.Stat(dir + "/config/dnsconfig/netmaker.hosts") _, err = os.Stat(dir + "/config/dnsconfig/netmaker.hosts")
if os.IsNotExist(err) { if os.IsNotExist(err) {
_, err = os.Create(dir + "/config/dnsconfig/netmaker.hosts") _, err = os.Create(dir + "/config/dnsconfig/netmaker.hosts")

View file

@ -11,7 +11,6 @@ import (
"github.com/gravitl/netmaker/database" "github.com/gravitl/netmaker/database"
"github.com/gravitl/netmaker/logger" "github.com/gravitl/netmaker/logger"
"github.com/gravitl/netmaker/models" "github.com/gravitl/netmaker/models"
"github.com/gravitl/netmaker/servercfg"
"github.com/txn2/txeh" "github.com/txn2/txeh"
) )
@ -159,17 +158,13 @@ func SetCorefile(domains string) error {
return err return err
} }
_, err = os.Stat(dir + "/config/dnsconfig") err = os.MkdirAll(dir+"/config/dnsconfig", 0744)
if os.IsNotExist(err) {
err = os.MkdirAll(dir+"/config/dnsconfig", 0744)
}
if err != nil { if err != nil {
logger.Log(0, "couldnt find or create /config/dnsconfig") logger.Log(0, "couldnt find or create /config/dnsconfig")
return err return err
} }
corefile := domains + ` { corefile := domains + ` {
bind %s
reload 15s reload 15s
hosts /root/dnsconfig/netmaker.hosts { hosts /root/dnsconfig/netmaker.hosts {
fallthrough fallthrough
@ -178,8 +173,7 @@ func SetCorefile(domains string) error {
log log
} }
` `
corebytes := []byte(fmt.Sprintf(corefile, servercfg.GetCoreDNSAddr())) err = os.WriteFile(dir+"/config/dnsconfig/Corefile", []byte(corefile), 0644)
err = os.WriteFile(dir+"/config/dnsconfig/Corefile", corebytes, 0644)
if err != nil { if err != nil {
return err return err
} }

View file

@ -118,6 +118,9 @@ func updateNodeMetrics(currentNode *models.Node, newMetrics *models.Metrics) {
attachedClients = clients attachedClients = clients
} }
} }
if newMetrics.Connectivity == nil {
newMetrics.Connectivity = make(map[string]models.Metric)
}
if len(attachedClients) > 0 { if len(attachedClients) > 0 {
// associate ext clients with IDs // associate ext clients with IDs
for i := range attachedClients { for i := range attachedClients {