x/solar-resources
Code Issues Proposed changes

Cleanup example

Browse Source
This commit is contained in:
Jedrzej Nowak 2015-10-12 13:50:38 +02:00
parent a503e835c7
commit 3c72babcbc
1 changed files with 21 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
examples/torrent/example.py
View File

@ -6,59 +6,50 @@
# solar orch run-once last
import click
import sys
import time
from solar.core import resource
from solar.core import signals
from solar.core import validation
from solar.core.resource import virtual_resource as vr
from solar import errors
from solar.interfaces.db import get_db
from solar.events.controls import React, Dep
from solar.events.api import add_event
db = get_db()
def run():
db.clear()
node = vr.create('node', 'resources/ro_node', {'name': 'first' + str(time.time()),
'ip': '10.0.0.3',
'node_id': 'node1',
'ip': '10.0.0.3',
'node_id': 'node1',
})[0]
transports = vr.create('transports_node1', 'resources/transports')[0]
ssh_transport = vr.create('ssh_transport', 'resources/transport_ssh',
{'ssh_key': '/vagrant/.vagrant/machines/solar-dev1/virtualbox/private_key',
'ssh_user': 'vagrant'})[0]
ssh_transport = vr.create('ssh_transport', 'resources/transport_ssh',
{'ssh_key': '/vagrant/.vagrant/machines/solar-dev1/virtualbox/private_key',
'ssh_user': 'vagrant'})[0]
transports.connect(node, {})
# it uses reverse mappings
ssh_transport.connect(transports, {'ssh_key': 'transports:key',
'ssh_user': 'transports:user',
'ssh_port': 'transports:port',
'name': 'transports:name'})
'ssh_user': 'transports:user',
'ssh_port': 'transports:port',
'name': 'transports:name'})
hosts = vr.create('hosts_file', 'resources/hosts_file', {})[0]
# let's add torrent transport for hosts file deployment (useless in real life)
# let's add torrent transport for hosts file deployment (useless in real
# life)
torrent_transport = vr.create('torrent_transport',
'resources/transport_torrent',
{'trackers': ['http://tracker01-bud.infra.mirantis.net:8080']})[0]
torrent_transport = vr.create('torrent_transport',
'resources/transport_torrent',
{'trackers': ['http://tracker01-bud.infra.mirantis.net:8080']})[0]
transports_for_torrent = vr.create('transports_for_torrent', 'resources/transports')[0]
transports_for_torrent = vr.create(
'transports_for_torrent', 'resources/transports')[0]
transports_for_torrent.connect(torrent_transport, {})
@ -68,16 +59,16 @@ def run():
'name': 'transports:name'},
events={})
transports_for_hosts = vr.create('transports_for_hosts', 'resources/transports')[0]
transports_for_hosts = vr.create(
'transports_for_hosts', 'resources/transports')[0]
torrent_transport.connect(transports_for_hosts, {'trackers': 'transports:trackers',
'name': 'transports:name'})
'name': 'transports:name'})
ssh_transport.connect(transports_for_hosts, {'ssh_key': 'transports:key',
'ssh_user': 'transports:user',
'ssh_port': 'transports:port',
'name': 'transports:name'})
'ssh_user': 'transports:user',
'ssh_port': 'transports:port',
'name': 'transports:name'})
transports_for_hosts.connect(hosts)
transports_for_hosts.connect_with_events(node, events={})