1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
// Copyright 2011, 2012, 2013 Canonical Ltd.
// Licensed under the AGPLv3, see LICENCE file for details.
package environs
import (
"fmt"
"io/ioutil"
"launchpad.net/juju-core/environs/config"
"launchpad.net/juju-core/errors"
)
var InvalidEnvironmentError error = fmt.Errorf(
"environment is not a juju-core environment")
// Open creates a new Environ using the environment configuration with the
// given name. If name is empty, the default environment will be used.
func (envs *Environs) Open(name string) (Environ, error) {
if name == "" {
name = envs.Default
if name == "" {
return nil, fmt.Errorf("no default environment found")
}
}
e, ok := envs.environs[name]
if !ok {
return nil, fmt.Errorf("unknown environment %q", name)
}
if e.err != nil {
return nil, e.err
}
return New(e.config)
}
// ConfigForName returns the configuration for the
// environment with the given name from the default
// environments file. If the name is blank, the default
// environment will be used.
func ConfigForName(name string) (*config.Config, error) {
envs, err := ReadEnvirons("")
if err != nil {
return nil, err
}
if name == "" {
name = envs.Default
if name == "" {
return nil, fmt.Errorf("no default environment found")
}
}
e, ok := envs.environs[name]
if !ok {
return nil, fmt.Errorf("unknown environment %q", name)
}
if e.err != nil {
return nil, e.err
}
return e.config, nil
}
// NewFromName opens the environment with the given
// name from the default environments file. If the
// name is blank, the default environment will be used.
func NewFromName(name string) (Environ, error) {
cfg, err := ConfigForName(name)
if err != nil {
return nil, err
}
return New(cfg)
}
// PrepareFromName is the same as NewFromName except
// that the environment is is prepared as well as opened.
func PrepareFromName(name string) (Environ, error) {
cfg, err := ConfigForName(name)
if err != nil {
return nil, err
}
return Prepare(cfg)
}
// NewFromAttrs returns a new environment based on the provided configuration
// attributes.
func NewFromAttrs(attrs map[string]interface{}) (Environ, error) {
cfg, err := config.New(attrs)
if err != nil {
return nil, err
}
return New(cfg)
}
// New returns a new environment based on the provided configuration.
func New(config *config.Config) (Environ, error) {
p, err := Provider(config.Type())
if err != nil {
return nil, err
}
return p.Open(config)
}
// Prepare prepares a new environment based on the provided configuration.
func Prepare(config *config.Config) (Environ, error) {
p, err := Provider(config.Type())
if err != nil {
return nil, err
}
return p.Prepare(config)
}
// CheckEnvironment checks if an environment has a bootstrap-verify
// that is written by juju-core commands (as compared to one being
// written by Python juju).
//
// If there is no bootstrap-verify file in the storage, it is still
// considered to be a Juju-core environment since early versions have
// not written it out.
//
// Returns InvalidEnvironmentError on failure, nil otherwise.
func CheckEnvironment(environ Environ) error {
storage := environ.Storage()
reader, err := storage.Get(verificationFilename)
if errors.IsNotFoundError(err) {
// When verification file does not exist, this is a juju-core
// environment.
return nil
} else if err != nil {
return err
} else if content, err := ioutil.ReadAll(reader); err != nil {
return err
} else if string(content) != verificationContent {
return InvalidEnvironmentError
}
return nil
}
|