c12af858774ac15f702dc2e3bfe10aa4cf6b4772
5 from .client
import client
7 log
= logging
.getLogger(__name__
)
10 class Application(model
.ModelEntity
):
12 def _unit_match_pattern(self
):
13 return r
'^{}.*$'.format(self
.entity_id
)
15 def on_unit_add(self
, callable_
):
16 """Add a "unit added" observer to this entity, which will be called
17 whenever a unit is added to this application.
20 self
.model
.add_observer(
21 callable_
, 'unit', 'add', self
._unit
_match
_pattern
)
23 def on_unit_remove(self
, callable_
):
24 """Add a "unit removed" observer to this entity, which will be called
25 whenever a unit is removed from this application.
28 self
.model
.add_observer(
29 callable_
, 'unit', 'remove', self
._unit
_match
_pattern
)
34 unit
for unit
in self
.model
.units
.values()
35 if unit
.application
== self
.name
40 """Get the application status, as set by the charm's leader.
43 return self
.data
['status']['current']
46 def status_message(self
):
47 """Get the application status message, as set by the charm's leader.
50 return self
.data
['status']['message']
52 async def add_relation(self
, local_relation
, remote_relation
):
53 """Add a relation to another application.
55 :param str local_relation: Name of relation on this application
56 :param str remote_relation: Name of relation on the other
57 application in the form '<application>[:<relation_name>]'
60 if ':' not in local_relation
:
61 local_relation
= '{}:{}'.format(self
.name
, local_relation
)
63 return await self
.model
.add_relation(local_relation
, remote_relation
)
65 async def add_unit(self
, count
=1, to
=None):
66 """Add one or more units to this application.
68 :param int count: Number of units to add
69 :param str to: Placement directive, e.g.::
71 'lxc:7' - new lxc container on machine 7
72 '24/lxc/3' - lxc container 3 or machine 24
74 If None, a new machine is provisioned.
77 app_facade
= client
.ApplicationFacade()
78 app_facade
.connect(self
.connection
)
81 'Adding %s unit%s to %s',
82 count
, '' if count
== 1 else 's', self
.name
)
84 result
= await app_facade
.AddUnits(
85 application
=self
.name
,
90 return await asyncio
.gather(*[
91 asyncio
.ensure_future(self
.model
._wait
_for
_new
('unit', unit_id
))
92 for unit_id
in result
.units
97 def allocate(self
, budget
, value
):
98 """Allocate budget to this application.
100 :param str budget: Name of budget
101 :param int value: Budget limit
106 def attach(self
, resource_name
, file_path
):
107 """Upload a file as a resource for this application.
109 :param str resource: Name of the resource
110 :param str file_path: Path to the file to upload
115 def collect_metrics(self
):
116 """Collect metrics on this application.
121 async def destroy_relation(self
, local_relation
, remote_relation
):
122 """Remove a relation to another application.
124 :param str local_relation: Name of relation on this application
125 :param str remote_relation: Name of relation on the other
126 application in the form '<application>[:<relation_name>]'
129 if ':' not in local_relation
:
130 local_relation
= '{}:{}'.format(self
.name
, local_relation
)
132 app_facade
= client
.ApplicationFacade()
133 app_facade
.connect(self
.connection
)
136 'Destroying relation %s <-> %s', local_relation
, remote_relation
)
138 return await app_facade
.DestroyRelation([
139 local_relation
, remote_relation
])
140 remove_relation
= destroy_relation
142 async def destroy_unit(self
, *unit_names
):
143 """Destroy units by name.
146 return await self
.model
.destroy_units(*unit_names
)
147 destroy_units
= destroy_unit
149 async def destroy(self
):
150 """Remove this application from the model.
153 app_facade
= client
.ApplicationFacade()
154 app_facade
.connect(self
.connection
)
157 'Destroying %s', self
.name
)
159 return await app_facade
.Destroy(self
.name
)
162 async def expose(self
):
163 """Make this application publicly available over the network.
166 app_facade
= client
.ApplicationFacade()
167 app_facade
.connect(self
.connection
)
170 'Exposing %s', self
.name
)
172 return await app_facade
.Expose(self
.name
)
174 def get_config(self
):
175 """Return the configuration settings for this application.
180 def get_constraints(self
):
181 """Return the machine constraints for this application.
186 def get_actions(self
, schema
=False):
187 """Get actions defined for this application.
189 :param bool schema: Return the full action schema
194 def get_resources(self
, details
=False):
195 """Return resources for this application.
197 :param bool details: Include detailed info about resources used by each
203 def run(self
, command
, timeout
=None):
204 """Run command on all units for this application.
206 :param str command: The command to run
207 :param int timeout: Time to wait before command is considered failed
212 async def set_annotations(self
, annotations
):
213 """Set annotations on this application.
215 :param annotations map[string]string: the annotations as key/value
219 log
.debug('Updating annotations on application %s', self
.name
)
221 self
.ann_facade
= client
.AnnotationsFacade()
222 self
.ann_facade
.connect(self
.connection
)
224 ann
= client
.EntityAnnotations(
226 annotations
=annotations
,
228 return await self
.ann_facade
.Set([ann
])
230 def set_config(self
, to_default
=False, **config
):
231 """Set configuration options for this application.
233 :param bool to_default: Set application options to default values
234 :param \*\*config: Config key/values
239 def set_constraints(self
, constraints
):
240 """Set machine constraints for this application.
242 :param :class:`juju.Constraints` constraints: Machine constraints
247 def set_meter_status(self
, status
, info
=None):
248 """Set the meter status on this status.
250 :param str status: Meter status, e.g. 'RED', 'AMBER'
251 :param str info: Extra info message
256 def set_plan(self
, plan_name
):
257 """Set the plan for this application, effective immediately.
259 :param str plan_name: Name of plan
264 async def unexpose(self
):
265 """Remove public availability over the network for this application.
268 app_facade
= client
.ApplicationFacade()
269 app_facade
.connect(self
.connection
)
272 'Unexposing %s', self
.name
)
274 return await app_facade
.Unexpose(self
.name
)
276 def update_allocation(self
, allocation
):
277 """Update existing allocation for this application.
279 :param int allocation: The allocation to set
285 self
, channel
=None, force_series
=False, force_units
=False,
286 path
=None, resources
=None, revision
=-1, switch
=None):
287 """Upgrade the charm for this application.
289 :param str channel: Channel to use when getting the charm from the
290 charm store, e.g. 'development'
291 :param bool force_series: Upgrade even if series of deployed
292 application is not supported by the new charm
293 :param bool force_units: Upgrade all units immediately, even if in
295 :param str path: Uprade to a charm located at path
296 :param dict resources: Dictionary of resource name/filepath pairs
297 :param int revision: Explicit upgrade revision
298 :param str switch: Crossgrade charm url