Skip to content

Commit

Permalink
fix: fix bug
Browse files Browse the repository at this point in the history
  • Loading branch information
gsmini committed Apr 11, 2023
1 parent bdc3a52 commit 1550510
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 0 deletions.
1 change: 1 addition & 0 deletions dns.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import (

//dns for headless service in k8s: (service_name).$(k8s_namespace).svc.cluster.local
func getDnsForPodIP(svc []*Service) (ipMaps map[string][]string, err error) {
ipMaps = make(map[string][]string, 10)
for _, value := range svc {
dnsForK8sSvc := fmt.Sprintf("%s.%s.svc.cluster.local", value.SvcName, value.Namespace)
ipRecords, err := net.LookupIP(dnsForK8sSvc)
Expand Down
9 changes: 9 additions & 0 deletions k8s-headless-svc.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package k8s_headless_svc

import (
"fmt"
"go-micro.dev/v4/registry"
)

Expand Down Expand Up @@ -67,6 +68,9 @@ func (k *k8sSvcRegister) GetService(string, ...registry.GetOption) ([]*registry.

//nodes = append(nodes, &registry.Node{Address: "127.0.0.1:8080"})
//service = append(service, &registry.Service{Name: "user", Version: "latest", Nodes: nodes})
fmt.Println("1111111")
fmt.Println(service)
fmt.Println("1111111")

return service, nil
}
Expand All @@ -87,6 +91,11 @@ func (k *k8sSvcRegister) ListServices(...registry.ListOption) ([]*registry.Servi
service = append(service, &registry.Service{Name: svcName, Version: "latest", Nodes: nodes})

}
fmt.Println("222222")

fmt.Println(service)
fmt.Println("2222")

return service, nil
}

Expand Down

0 comments on commit 1550510

Please sign in to comment.