Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 3e2d5b703d | |||
| 0897551a43 |
@@ -48,7 +48,7 @@ func newClientConfig(serverAddr string) *consul.Config {
|
||||
|
||||
func (s *Service) Register() error {
|
||||
def := &consul.AgentServiceRegistration{
|
||||
ID: s.AppID,
|
||||
ID: s.Name + "_" + s.AppID,
|
||||
Name: s.Name,
|
||||
Address: s.IP,
|
||||
Port: s.Port,
|
||||
@@ -74,7 +74,7 @@ func (s *Service) UpdateTTL(service *consul.AgentServiceRegistration) {
|
||||
for range ticker.C {
|
||||
ok, err := s.check()
|
||||
if !ok {
|
||||
if err := s.ConsulAgent.FailTTL("service:"+s.AppID, err.Error()); err != nil {
|
||||
if err := s.ConsulAgent.FailTTL("service:"+s.Name+"_"+s.AppID, err.Error()); err != nil {
|
||||
log.Println(err)
|
||||
}
|
||||
} else {
|
||||
@@ -121,7 +121,7 @@ func (s *Service) getTags() []string {
|
||||
// "traefik.http.services." + s.Name + ".loadbalancer.server.scheme=http",
|
||||
// "traefik.http.services." + s.Name + ".loadbalancer.server.port=" + port,
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.passhostheader=false",
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.server.url=" + bFullAddr,
|
||||
"traefik.http.services." + s.Name + ".loadbalancer.servers." + fullName + ".url=" + bFullAddr,
|
||||
"traefik.http.middlewares.compress.compress=true",
|
||||
"traefik.http.middlewares.requestid.plugin.requestid.headerName=X-Request-ID",
|
||||
// "traefik.http.services." + fullName + ".loadbalancer.healthcheck.path=/health",
|
||||
|
||||
Reference in New Issue
Block a user