diff options
author | Charles Strahan <charles@cstrahan.com> | 2016-12-28 00:19:51 -0500 |
---|---|---|
committer | Charles Strahan <charles@cstrahan.com> | 2016-12-29 20:09:46 -0500 |
commit | 7ebcada02028e5ce8199cc123fda6aa1aba72e64 (patch) | |
tree | fc4a4c2c31aeddf0625593ee5be48caa30741d4f /nixos/tests/mesos_test.py | |
parent | da70d3da0f11b22eac77756b39b349215e06b2e3 (diff) | |
download | nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.tar nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.tar.gz nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.tar.bz2 nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.tar.lz nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.tar.xz nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.tar.zst nixlib-7ebcada02028e5ce8199cc123fda6aa1aba72e64.zip |
mesos: 1.0.1 -> 1.1.0
Diffstat (limited to 'nixos/tests/mesos_test.py')
-rw-r--r-- | nixos/tests/mesos_test.py | 72 |
1 files changed, 72 insertions, 0 deletions
diff --git a/nixos/tests/mesos_test.py b/nixos/tests/mesos_test.py new file mode 100644 index 000000000000..be8bb32e49a7 --- /dev/null +++ b/nixos/tests/mesos_test.py @@ -0,0 +1,72 @@ +#!/usr/bin/env python +import uuid +import time +import subprocess +import os + +import sys + +from mesos.interface import Scheduler +from mesos.native import MesosSchedulerDriver +from mesos.interface import mesos_pb2 + +def log(msg): + process = subprocess.Popen("systemd-cat", stdin=subprocess.PIPE) + (out,err) = process.communicate(msg) + +class NixosTestScheduler(Scheduler): + def __init__(self): + self.master_ip = sys.argv[1] + self.download_uri = sys.argv[2] + + def resourceOffers(self, driver, offers): + log("XXX got resource offer") + + offer = offers[0] + task = self.new_task(offer) + uri = task.command.uris.add() + uri.value = self.download_uri + task.command.value = "cat test.result" + driver.launchTasks(offer.id, [task]) + + def statusUpdate(self, driver, update): + log("XXX status update") + if update.state == mesos_pb2.TASK_FAILED: + log("XXX test task failed with message: " + update.message) + driver.stop() + sys.exit(1) + elif update.state == mesos_pb2.TASK_FINISHED: + driver.stop() + sys.exit(0) + + def new_task(self, offer): + task = mesos_pb2.TaskInfo() + id = uuid.uuid4() + task.task_id.value = str(id) + task.slave_id.value = offer.slave_id.value + task.name = "task {}".format(str(id)) + + cpus = task.resources.add() + cpus.name = "cpus" + cpus.type = mesos_pb2.Value.SCALAR + cpus.scalar.value = 0.1 + + mem = task.resources.add() + mem.name = "mem" + mem.type = mesos_pb2.Value.SCALAR + mem.scalar.value = 32 + + return task + +if __name__ == '__main__': + log("XXX framework started") + + framework = mesos_pb2.FrameworkInfo() + framework.user = "root" + framework.name = "nixos-test-framework" + driver = MesosSchedulerDriver( + NixosTestScheduler(), + framework, + sys.argv[1] + ":5050" + ) + driver.run() |