OLD | NEW |
1 // Copyright 2013 Canonical Ltd. | 1 // Copyright 2013 Canonical Ltd. |
2 // Licensed under the AGPLv3, see LICENCE file for details. | 2 // Licensed under the AGPLv3, see LICENCE file for details. |
3 | 3 |
4 package state | 4 package state |
5 | 5 |
6 import ( | 6 import ( |
7 "fmt" | 7 "fmt" |
8 | 8 |
9 "launchpad.net/juju-core/instance" | 9 "launchpad.net/juju-core/instance" |
10 ) | 10 ) |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
55 } | 55 } |
56 | 56 |
57 // stateServerAddresses returns the list of internal addresses of the state | 57 // stateServerAddresses returns the list of internal addresses of the state |
58 // server machines. | 58 // server machines. |
59 func (st *State) stateServerAddresses() ([]string, error) { | 59 func (st *State) stateServerAddresses() ([]string, error) { |
60 type addressMachine struct { | 60 type addressMachine struct { |
61 Addresses []address | 61 Addresses []address |
62 } | 62 } |
63 var allAddresses []addressMachine | 63 var allAddresses []addressMachine |
64 // TODO(rog) 2013/10/14 index machines on jobs. | 64 // TODO(rog) 2013/10/14 index machines on jobs. |
65 » err := st.machines.Find(D{{"jobs", JobManageState}}).All(&allAddresses) | 65 » err := st.machines.Find(D{{"jobs", JobManageEnviron}}).All(&allAddresses
) |
66 if err != nil { | 66 if err != nil { |
67 return nil, err | 67 return nil, err |
68 } | 68 } |
69 if len(allAddresses) == 0 { | 69 if len(allAddresses) == 0 { |
70 return nil, fmt.Errorf("no state server machines found") | 70 return nil, fmt.Errorf("no state server machines found") |
71 } | 71 } |
72 apiAddrs := make([]string, 0, len(allAddresses)) | 72 apiAddrs := make([]string, 0, len(allAddresses)) |
73 for _, addrs := range allAddresses { | 73 for _, addrs := range allAddresses { |
74 instAddrs := addressesToInstanceAddresses(addrs.Addresses) | 74 instAddrs := addressesToInstanceAddresses(addrs.Addresses) |
75 addr := instance.SelectInternalAddress(instAddrs, false) | 75 addr := instance.SelectInternalAddress(instAddrs, false) |
(...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
135 config, err := st.EnvironConfig() | 135 config, err := st.EnvironConfig() |
136 if err != nil { | 136 if err != nil { |
137 return nil, err | 137 return nil, err |
138 } | 138 } |
139 return &DeployerConnectionValues{ | 139 return &DeployerConnectionValues{ |
140 StateAddresses: appendPort(addrs, config.StatePort()), | 140 StateAddresses: appendPort(addrs, config.StatePort()), |
141 APIAddresses: appendPort(addrs, config.APIPort()), | 141 APIAddresses: appendPort(addrs, config.APIPort()), |
142 SyslogPort: config.SyslogPort(), | 142 SyslogPort: config.SyslogPort(), |
143 }, nil | 143 }, nil |
144 } | 144 } |
OLD | NEW |