|
|
@ -16,6 +16,7 @@ package discovery
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"fmt"
|
|
|
|
"net/http"
|
|
|
|
"net/http"
|
|
|
|
|
|
|
|
"strconv"
|
|
|
|
"strings"
|
|
|
|
"strings"
|
|
|
|
"sync"
|
|
|
|
"sync"
|
|
|
|
"time"
|
|
|
|
"time"
|
|
|
@ -275,7 +276,7 @@ func (cd *ConsulDiscovery) watchService(srv *consulService, ch chan<- *config.Ta
|
|
|
|
ConsulNodeLabel: clientmodel.LabelValue(node.Node),
|
|
|
|
ConsulNodeLabel: clientmodel.LabelValue(node.Node),
|
|
|
|
ConsulTagsLabel: clientmodel.LabelValue(tags),
|
|
|
|
ConsulTagsLabel: clientmodel.LabelValue(tags),
|
|
|
|
ConsulServiceAddressLabel: clientmodel.LabelValue(node.ServiceAddress),
|
|
|
|
ConsulServiceAddressLabel: clientmodel.LabelValue(node.ServiceAddress),
|
|
|
|
ConsulServicePortLabel: clientmodel.LabelValue(node.ServicePort),
|
|
|
|
ConsulServicePortLabel: clientmodel.LabelValue(strconv.Itoa(node.ServicePort)),
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|