Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code | Sign in
(212)

Side by Side Diff: state/address.go

Issue 54230044: state: deprecate JobManageState
Patch Set: state: deprecate JobManageState Created 11 years, 2 months ago
Left:
Right:
Use n/p to move between diff chunks; N/P to move between comments. Please Sign in to add in-line comments.
Jump to:
View unified diff | Download patch
« no previous file with comments | « juju/testing/utils.go ('k') | state/api/charmrevisionupdater/updater_test.go » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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 }
OLDNEW
« no previous file with comments | « juju/testing/utils.go ('k') | state/api/charmrevisionupdater/updater_test.go » ('j') | no next file with comments »

Powered by Google App Engine
RSS Feeds Recent Issues | This issue
This is Rietveld f62528b