homelab/traefik
1
0
Fork 0
Code Activity

feat(consulcatalog): add HealthCheck tags.

Browse source
This commit is contained in:
Fernandez Ludovic 2018-01-01 03:49:06 +01:00 • committed by Traefiker
parent c9b871a03a
commit 97ce77169a
3 changed files with 76 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

18
provider/consul/consul_catalog_config.go
View file

@ -37,6 +37,7 @@ func (p *CatalogProvider) buildConfiguration(catalog []catalogUpdate) *types.Con
"getCircuitBreaker": p.getCircuitBreaker,
"getLoadBalancer": p.getLoadBalancer,
"getMaxConn": p.getMaxConn,
"getHealthCheck": p.getHealthCheck,
// Frontend functions
"getFrontendRule": p.getFrontendRule,
@ -266,6 +267,23 @@ func (p *CatalogProvider) getMaxConn(tags []string) *types.MaxConn {
}
}
func (p *CatalogProvider) getHealthCheck(tags []string) *types.HealthCheck {
path := p.getAttribute(label.SuffixBackendHealthCheckPath, tags, "")
if len(path) == 0 {
return nil
}
port := p.getIntAttribute(label.SuffixBackendHealthCheckPort, tags, label.DefaultBackendHealthCheckPort)
interval := p.getAttribute(label.SuffixBackendHealthCheckInterval, tags, "")
return &types.HealthCheck{
Path: path,
Port: port,
Interval: interval,
}
}
// Base functions
func (p *CatalogProvider) getFuncStringAttribute(name string, defaultValue string) func(tags []string) string {