File tree 2 files changed +18
-12
lines changed
2 files changed +18
-12
lines changed Original file line number Diff line number Diff line change @@ -61,13 +61,15 @@ func (r *EtcdManualResolver) SetEndpoints(endpoints []string) {
61
61
62
62
func (r EtcdManualResolver ) updateState () {
63
63
if r .CC != nil {
64
- addresses := make ([]resolver.Address , len (r .endpoints ))
64
+ eps := make ([]resolver.Endpoint , len (r .endpoints ))
65
65
for i , ep := range r .endpoints {
66
66
addr , serverName := endpoint .Interpret (ep )
67
- addresses [i ] = resolver.Address {Addr : addr , ServerName : serverName }
67
+ eps [i ] = resolver.Endpoint {Addresses : []resolver.Address {
68
+ {Addr : addr , ServerName : serverName },
69
+ }}
68
70
}
69
71
state := resolver.State {
70
- Addresses : addresses ,
72
+ Endpoints : eps ,
71
73
ServiceConfig : r .serviceConfig ,
72
74
}
73
75
r .UpdateState (state )
Original file line number Diff line number Diff line change @@ -100,22 +100,26 @@ func (r *resolver) watch() {
100
100
}
101
101
}
102
102
103
- addrs := convertToGRPCAddress (allUps )
104
- r .cc .UpdateState (gresolver.State {Addresses : addrs })
103
+ eps := convertToGRPCEndpoint (allUps )
104
+ r .cc .UpdateState (gresolver.State {Endpoints : eps })
105
105
}
106
106
}
107
107
}
108
108
109
- func convertToGRPCAddress (ups map [string ]* endpoints.Update ) []gresolver.Address {
110
- var addrs []gresolver.Address
109
+ func convertToGRPCEndpoint (ups map [string ]* endpoints.Update ) []gresolver.Endpoint {
110
+ var eps []gresolver.Endpoint
111
111
for _ , up := range ups {
112
- addr := gresolver.Address {
113
- Addr : up .Endpoint .Addr ,
114
- Metadata : up .Endpoint .Metadata ,
112
+ ep := gresolver.Endpoint {
113
+ Addresses : []gresolver.Address {
114
+ {
115
+ Addr : up .Endpoint .Addr ,
116
+ Metadata : up .Endpoint .Metadata ,
117
+ },
118
+ },
115
119
}
116
- addrs = append (addrs , addr )
120
+ eps = append (eps , ep )
117
121
}
118
- return addrs
122
+ return eps
119
123
}
120
124
121
125
// ResolveNow is a no-op here.
You can’t perform that action at this time.
0 commit comments