This commit is contained in:
parent
d7c836ee86
commit
2441f259cf
1 changed files with 5 additions and 0 deletions
5
main.go
5
main.go
|
@ -181,6 +181,11 @@ func main() {
|
||||||
if svc.Spec.Type != "ClusterIP" {
|
if svc.Spec.Type != "ClusterIP" {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if val, ok := svc.Metadata.Annotations["haproxy/enabled"]; !ok || val != "true" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
key := svc.Metadata.Namespace + "/" + svc.Metadata.Name
|
key := svc.Metadata.Namespace + "/" + svc.Metadata.Name
|
||||||
ep, found := endpointMap[key]
|
ep, found := endpointMap[key]
|
||||||
if !found || len(ep.Subsets) == 0 {
|
if !found || len(ep.Subsets) == 0 {
|
||||||
|
|
Loading…
Add table
Reference in a new issue