x/solar
Code Issues Proposed changes

Fix hosts_file/riak and solard examples

Browse Source
This commit is contained in:
Dmitry Shulyak 2015-10-05 10:57:08 +03:00
parent a08e512804
commit 4d5d2c8040
6 changed files with 43 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/hosts_file/hosts.py
View File

@ -20,22 +20,22 @@ def run():
hosts1 = vr.create('hosts_file1', 'resources/hosts_file', {})[0] hosts1 = vr.create('hosts_file1', 'resources/hosts_file', {})[0]
hosts2 = vr.create('hosts_file2', 'resources/hosts_file', {})[0] hosts2 = vr.create('hosts_file2', 'resources/hosts_file', {})[0]
node1.connect_with_defaults(hosts1, { node1.connect(hosts1, {
'name': 'hosts:name', 'name': 'hosts:name',
'ip': 'hosts:ip', 'ip': 'hosts:ip',
}) })
node2.connect_with_defaults(hosts1, { node2.connect(hosts1, {
'name': 'hosts:name', 'name': 'hosts:name',
'ip': 'hosts:ip', 'ip': 'hosts:ip',
}) })
node1.connect_with_defaults(hosts2, { node1.connect(hosts2, {
'name': 'hosts:name', 'name': 'hosts:name',
'ip': 'hosts:ip', 'ip': 'hosts:ip',
}) })
node2.connect_with_defaults(hosts2, { node2.connect(hosts2, {
'name': 'hosts:name', 'name': 'hosts:name',
'ip': 'hosts:ip', 'ip': 'hosts:ip',
}) })

27
examples/riak/riaks.py
View File

@ -32,7 +32,7 @@ db = get_db()
def setup_riak(): def setup_riak():
db.clear() db.clear()
resources = vr.create('nodes', 'templates/riak_nodes.yaml', {'count': 3}) resources = vr.create('nodes', 'templates/nodes.yaml', {'count': 3})
nodes = [x for x in resources if x.name.startswith('node')] nodes = [x for x in resources if x.name.startswith('node')]
node1, node2, node3 = nodes node1, node2, node3 = nodes
@ -48,10 +48,10 @@ def setup_riak():
riak_services.append(r) riak_services.append(r)
for i, riak in enumerate(riak_services): for i, riak in enumerate(riak_services):
signals.connect(nodes[i], riak) nodes[i].connect(riak)
for i, riak in enumerate(riak_services[1:]): for i, riak in enumerate(riak_services[1:]):
signals.connect(riak_services[0], riak, {'riak_name': 'join_to'}) riak_services[0].connect(riak, {'riak_name': 'join_to'})
hosts_services = [] hosts_services = []
for i, riak in enumerate(riak_services): for i, riak in enumerate(riak_services):
@ -59,14 +59,13 @@ def setup_riak():
hosts_file = vr.create('hosts_file%d' % num, hosts_file = vr.create('hosts_file%d' % num,
'resources/hosts_file', {})[0] 'resources/hosts_file', {})[0]
hosts_services.append(hosts_file) hosts_services.append(hosts_file)
signals.connect(nodes[i], hosts_file) nodes[i].connect(hosts_file)
for riak in riak_services: for riak in riak_services:
for hosts_file in hosts_services: for hosts_file in hosts_services:
signals.connect(riak, hosts_file, riak.connect_with_events(hosts_file,
{'riak_hostname': 'hosts:name', {'riak_hostname': 'hosts:name',
'ip': 'hosts:ip'}, 'ip': 'hosts:ip'})
events=False)
errors = resource.validate_resources() errors = resource.validate_resources()
for r, error in errors: for r, error in errors:
@ -142,24 +141,26 @@ def setup_haproxies():
for single_hpsc in hpsc_http: for single_hpsc in hpsc_http:
for riak in riaks: for riak in riaks:
signals.connect(riak, single_hpsc, {'riak_hostname': 'backends:server', riak.connect(single_hpsc, {
'riak_hostname': 'backends:server',
'riak_port_http': 'backends:port'}) 'riak_port_http': 'backends:port'})
for single_hpsc in hpsc_pb: for single_hpsc in hpsc_pb:
for riak in riaks: for riak in riaks:
signals.connect(riak, single_hpsc, {'riak_hostname': 'backends:server', riak.connect(single_hpsc,
{'riak_hostname': 'backends:server',
'riak_port_pb': 'backends:port'}) 'riak_port_pb': 'backends:port'})
# haproxy config to haproxy service # haproxy config to haproxy service
for single_hpc, single_hpsc in zip(hpc, hpsc_http): for single_hpc, single_hpsc in zip(hpc, hpsc_http):
signals.connect(single_hpsc, single_hpc, {"backends": "config:backends", single_hpsc.connect(single_hpc, {"backends": "config:backends",
"listen_port": "config:listen_port", "listen_port": "config:listen_port",
"protocol": "config:protocol", "protocol": "config:protocol",
"name": "config:name"}) "name": "config:name"})
for single_hpc, single_hpsc in zip(hpc, hpsc_pb): for single_hpc, single_hpsc in zip(hpc, hpsc_pb):
signals.connect(single_hpsc, single_hpc, {"backends": "config:backends", single_hpsc.connect(single_hpc, {"backends": "config:backends",
"listen_port": "config:listen_port", "listen_port": "config:listen_port",
"protocol": "config:protocol", "protocol": "config:protocol",
"name": "config:name"}) "name": "config:name"})
@ -173,10 +174,10 @@ def setup_haproxies():
nodes = [node1, node2, node3] nodes = [node1, node2, node3]
for single_node, single_hps in zip(nodes, hps): for single_node, single_hps in zip(nodes, hps):
signals.connect(single_node, single_hps) single_node.connect(single_hps)
for single_node, single_hpc in zip(nodes, hpc): for single_node, single_hpc in zip(nodes, hpc):
signals.connect(single_node, single_hpc) single_node.connect(single_hpc)
has_errors = False has_errors = False
for r in locals().values(): for r in locals().values():

14
examples/solard/example.py
View File

@ -32,29 +32,27 @@ def run():
{'solard_user': 'vagrant', {'solard_user': 'vagrant',
'solard_password': 'password'})[0] 'solard_password': 'password'})[0]
signals.connect(transports_for_solard, solard_transport, {}) transports_for_solard.connect(solard_transport, {})
ssh_transport.connect(transports_for_solard,{'ssh_key': 'transports:key',
signals.connect(ssh_transport, transports_for_solard, {'ssh_key': 'transports:key',
'ssh_user': 'transports:user', 'ssh_user': 'transports:user',
'ssh_port': 'transports:port', 'ssh_port': 'transports:port',
'name': 'transports:name'}) 'name': 'transports:name'})
# set transports_id # set transports_id
signals.connect(transports, node, {}) transports.connect(node, {})
# it uses reverse mappings # it uses reverse mappings
signals.connect(ssh_transport, transports, {'ssh_key': 'transports:key', ssh_transport.connect(transports, {'ssh_key': 'transports:key',
'ssh_user': 'transports:user', 'ssh_user': 'transports:user',
'ssh_port': 'transports:port', 'ssh_port': 'transports:port',
'name': 'transports:name'}) 'name': 'transports:name'})
solard_transport.connect(transports, {'solard_user': 'transports:user',
signals.connect(solard_transport, transports, {'solard_user': 'transports:user',
'solard_port': 'transports:port', 'solard_port': 'transports:port',
'solard_password': 'transports:password', 'solard_password': 'transports:password',
'name': 'transports:name'}) 'name': 'transports:name'})
hosts = vr.create('hosts_file', 'resources/hosts_file', {})[0] hosts = vr.create('hosts_file', 'resources/hosts_file', {})[0]
signals.connect(node, hosts, { node.connect(hosts, {
'ip': 'hosts:ip', 'ip': 'hosts:ip',
'name': 'hosts:name' 'name': 'hosts:name'
}) })

2
solar/solar/core/resource/resource.py
View File

@ -258,7 +258,7 @@ class Resource(object):
if events: if events:
api.add_events(self.name, events) api.add_events(self.name, events)
def connect_with_defaults(self, receiver, mapping=None, events=None): def connect(self, receiver, mapping=None, events=None):
return self.connect_with_events( return self.connect_with_events(
receiver, mapping=mapping, events=events, use_defaults=True) receiver, mapping=mapping, events=events, use_defaults=True)

6
solar/solar/core/resource/virtual_resource.py
View File

@ -129,7 +129,7 @@ def create_resources(resources, tags=None):
if node: if node:
node = load_resource(node) node = load_resource(node)
r = new_resources[0] r = new_resources[0]
signals.connect(node, r, {}) node.connect(r, mapping={})
r.add_tags('location={}'.format(node.name)) r.add_tags('location={}'.format(node.name))
update_inputs(resource_name, args) update_inputs(resource_name, args)
return created_resources return created_resources
@ -167,8 +167,10 @@ def update_inputs(child, args):
mapping = {} mapping = {}
parent = load_resource(c['parent']) parent = load_resource(c['parent'])
events = c['events'] events = c['events']
use_defaults = not c['events'] is False
mapping[c['parent_input']] = c['child_input'] mapping[c['parent_input']] = c['child_input']
parent.connect_with_events(child, mapping, events) parent.connect_with_events(
child, mapping, events, use_defaults=use_defaults)
child.update(assignments) child.update(assignments)

4
solar/solar/core/signals.py
View File

@ -127,9 +127,9 @@ def location_and_transports(emitter, receiver, orig_mapping):
return return
def connect(emitter, receiver, mapping=None): def connect(emitter, receiver, mapping=None):
mapping = mapping or guess_mapping(emitter, receiver) if mapping is None:
mapping = guess_mapping(emitter, receiver)
# XXX: we didn't agree on that "reverse" there # XXX: we didn't agree on that "reverse" there
location_and_transports(emitter, receiver, mapping) location_and_transports(emitter, receiver, mapping)