Left: | ||
Right: |
OLD | NEW |
---|---|
(Empty) | |
1 package mstate | |
2 | |
3 import ( | |
4 "launchpad.net/juju-core/juju/log" | |
5 "launchpad.net/mgo" | |
6 ) | |
7 | |
8 func Dial(servers string) (st *State, err error) { | |
9 log.Printf("state: opening state; MongoDB servers: %q", servers) | |
10 session, err := mgo.Dial(servers) | |
11 if err != nil { | |
12 return | |
13 } | |
14 db := session.DB("juju") | |
15 db.Session = session.Clone() | |
16 session.Close() | |
17 st = &State{ | |
18 db: db, | |
19 machines: db.C("machines"), | |
20 } | |
21 return | |
22 } | |
23 | |
24 func (st *State) Close() (err error) { | |
25 st.db.Session.Close() | |
26 return | |
27 } | |
OLD | NEW |