examples: improve examples
This commit is contained in:
parent
c8da2c8b3f
commit
c3fa113769
@ -1,10 +1,15 @@
|
|||||||
<?php
|
<?php
|
||||||
|
|
||||||
|
// this just adds a bunch of meaningless tasks, for testing purposees
|
||||||
|
//
|
||||||
|
// in a real world, you will have additional fields in your table
|
||||||
|
// like 'job_name' and 'job_data'
|
||||||
|
|
||||||
$db = new mysqli();
|
$db = new mysqli();
|
||||||
if (!$db->real_connect('10.211.55.6', 'jobd', 'password', 'jobd'))
|
if (!$db->real_connect('10.211.55.6', 'jobd', 'password', 'jobd'))
|
||||||
die('Failed to connect.');
|
die('Failed to connect.');
|
||||||
|
|
||||||
$target = 'server1';
|
$target = 'server3';
|
||||||
$slots = ['low', 'normal', 'high'];
|
$slots = ['low', 'normal', 'high'];
|
||||||
|
|
||||||
for ($i = 0; $i < 100; $i++) {
|
for ($i = 0; $i < 100; $i++) {
|
||||||
|
@ -3,12 +3,14 @@
|
|||||||
require_once 'vendor/autoload.php';
|
require_once 'vendor/autoload.php';
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
// connecting to jobd
|
||||||
$client = new jobd\Client(jobd\Client::MASTER_PORT);
|
$client = new jobd\Client(jobd\Client::MASTER_PORT);
|
||||||
|
|
||||||
|
// asking master to ask workers responsible for server1 to poll new jobs
|
||||||
|
$client->poke(['server1']);
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
die($e->getMessage());
|
die($e->getMessage());
|
||||||
}
|
}
|
||||||
|
|
||||||
// $status = $client->status();
|
// closing connection
|
||||||
// var_dump($status->getData());
|
$client->close();
|
||||||
|
|
||||||
var_dump($client->poke(['server1']));
|
|
||||||
|
29
example/run-manual.php
Normal file
29
example/run-manual.php
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
require_once 'vendor/autoload.php';
|
||||||
|
|
||||||
|
// connecting to mysql
|
||||||
|
$db = new mysqli();
|
||||||
|
if (!$db->real_connect('10.211.55.6', 'jobd', 'password', 'jobd'))
|
||||||
|
die('Failed to connect.');
|
||||||
|
|
||||||
|
// adding manual task
|
||||||
|
$target = 'server1';
|
||||||
|
$time = time();
|
||||||
|
if (!$db->query("INSERT INTO jobs (target, slot, time_created, status) VALUES ('server1', 'normal', $time, 'manual')"))
|
||||||
|
die($db->error);
|
||||||
|
|
||||||
|
$id = $db->insert_id;
|
||||||
|
|
||||||
|
try {
|
||||||
|
// connecting to jobd
|
||||||
|
$client = new jobd\Client(jobd\Client::WORKER_PORT);
|
||||||
|
|
||||||
|
// launching task
|
||||||
|
$result = $client->runManual($id);
|
||||||
|
|
||||||
|
// printing the result
|
||||||
|
print_r($result->getData());
|
||||||
|
} catch (Exception $e) {
|
||||||
|
die($e->getMessage());
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user