2 Distributed Cloud Emulator (dcemulator)
3 (c) 2015 by Manuel Peuster <manuel.peuster@upb.de>
8 DCDPID_BASE
= 1000 # start of switch dpid's used for data center switches
11 class Datacenter(object):
13 Represents a logical data center to which compute resources
14 (Docker containers) can be added at runtime.
16 Will also implement resource bookkeeping in later versions.
19 def __init__(self
, name
):
20 self
.net
= None # DCNetwork to which we belong
22 self
.switch
= None # first prototype assumes one "bigswitch" per DC
23 self
.containers
= {} # keep track of running containers
25 def _get_next_dc_dpid(self
):
32 Each data center is represented by a single switch to which
33 compute resources can be connected at run time.
35 TODO: This will be changed in the future to support multiple networks
38 self
.switch
= self
.net
.mnet
.addSwitch(
39 "%s.s1" % self
.name
, dpid
=hex(self
._get
_next
_dc
_dpid
())[2:])
40 logging
.debug("created data center switch: %s" % str(self
.switch
))
45 def addCompute(self
, name
, image
=None, network
=None):
47 Create a new container as compute resource and connect it to this
50 TODO: This interface will change to support multiple networks to which
51 a single container can be connected.
53 assert name
is not None
54 # set default parameter
58 network
= {} # {"ip": "10.0.0.254/8"}
59 # create the container and connect it to the given network
60 d
= self
.net
.addDocker("%s" % (name
), dimage
=image
)
61 self
.net
.addLink(d
, self
.switch
, params1
=network
)
62 self
.containers
[name
] = d
63 return name
# we might use UUIDs for naming later on
65 def removeCompute(self
, name
):
67 Stop and remove a container from this data center.
69 assert name
in self
.containers
71 link
=None, node1
=self
.containers
[name
], node2
=self
.switch
)
72 self
.net
.removeDocker("%s" % (name
))
73 del self
.containers
[name
]
76 def listCompute(self
):
78 Return a list of all running containers assigned to this
81 return self
.containers
.itervalues()