Skip to content

Commit 62dadaa

Browse files
committed
MINOR: consul: add support for from field for created backends
1 parent 8fda41a commit 62dadaa

File tree

3 files changed

+10
-1
lines changed

3 files changed

+10
-1
lines changed

discovery/aws_service_discovery_instance.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,10 @@ func (a awsService) GetName() string {
6161
return a.name
6262
}
6363

64+
func (a awsService) GetFrom() string {
65+
return ""
66+
}
67+
6468
func (a awsService) GetBackendName() string {
6569
return fmt.Sprintf("aws-%s-%s-%s", a.region, a.instanceName, a.GetName())
6670
}

discovery/consul_service_discovery_instance.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,10 @@ func (c *consulService) GetName() string {
4242
return c.name
4343
}
4444

45+
func (c *consulService) GetFrom() string {
46+
return c.params.Defaults
47+
}
48+
4549
func (c *consulService) GetBackendName() string {
4650
return fmt.Sprintf("consul-backend-%s-%d-%s", *c.params.Address, *c.params.Port, c.name)
4751
}

discovery/service_discovery_instance.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@ var mutex = &sync.Mutex{}
3232
type ServiceInstance interface {
3333
GetName() string
3434
GetBackendName() string
35+
GetFrom() string
3536
Changed() bool
3637
GetServers() []configuration.ServiceServer
3738
}
@@ -183,7 +184,7 @@ func (s *ServiceDiscoveryInstance) initService(service ServiceInstance) (bool, e
183184
if err != nil {
184185
return false, err
185186
}
186-
reload, err := se.Init(s.transactionID)
187+
reload, err := se.Init(s.transactionID, service.GetFrom())
187188
if err != nil {
188189
return false, err
189190
}

0 commit comments

Comments
 (0)