Skip to content

Commit 3a2dfd9

Browse files
ekasitkekasitk
committed
Add support for Sahara data processing
1 parent 8369248 commit 3a2dfd9

File tree

72 files changed

+4031
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

72 files changed

+4031
-0
lines changed

‎samples/data_processing/cluster/create_cluster.php

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$options = [
25+
'pluginName' => '{pluginName}',
26+
'hadoopVersion' => '{hadoopVersion}',
27+
'clusterTemplateId' => '{clusterTemplateId}',
28+
'defaultImageId' => '{defaultImageId}',
29+
//user keypair id is optional
30+
'userKeypairId' => '{userKeypairId}',
31+
'name' => '{name}',
32+
'neutronManagementNetwork' => '{neutronManagementNetworkId}',
33+
];
34+
35+
$cluster = $sahara->createCluster($options);

‎samples/data_processing/cluster/delete_cluster.php

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$cluster = $sahara->getCluster(['id' => '{clusterId}']);
25+
$cluster->delete();

‎samples/data_processing/cluster/get_cluster.php

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$cluster = $sahara->getCluster(['id' => '{clusterId}']);
25+
$cluster->retrieve();
26+
print_r($cluster);

‎samples/data_processing/cluster/list_clusters.php

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$options = [
25+
'limit' => '{limit}',
26+
'marker' => '{marker}',
27+
'sortKey' => '{sortKey}'
28+
];
29+
30+
$clusters = $sahara->listClusters($options);
31+
foreach ($clusters as $cluster) {
32+
}

‎samples/data_processing/cluster/scale_cluster.php

Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$options = [
25+
'id' => '{clusterId}',
26+
'addNodeGroups' => [[
27+
'count' => '{count}',
28+
'name' => '{name}',
29+
'nodeGroupTemplateId' => '{nodeGroupTemplateId}',
30+
]],
31+
'resizeNodeGroups' => [[
32+
'count' => '{count}',
33+
'name' => '{name}',
34+
]],
35+
];
36+
37+
$cluster = $sahara->scaleCluster($options);

‎samples/data_processing/cluster/update_cluster.php

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$cluster = $sahara->getCluster(['id' => '{clusterId}']);
25+
$cluster->name = '{newName}';
26+
$cluster->isPublic = '{trueOrFalse}';
27+
$cluster->isProtected = '{trueOrFalse}';
28+
$cluster->update();

‎samples/data_processing/cluster_template/create_cluster_template.php

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
$options = [
24+
'pluginName' => '{pluginName}',
25+
'hadoopVersion' => '{hadoopVersion}',
26+
'nodeGroups' => [[
27+
'name' => '{nodeGroupName}',
28+
'count' => '{count}',
29+
'nodeGroupTemplateId' => '{nodeGroupTemplateId}',
30+
],
31+
[
32+
'name' => '{nodeGroupName}',
33+
'count' => '{count}',
34+
'nodeGroupTemplateId' => '{nodeGroupTemplateId}',
35+
],
36+
[
37+
'name' => '{NodeGroupname}',
38+
'count' => '{count}',
39+
'nodeGroupTemplateId' => '{nodeGroupTemplateId}',
40+
],
41+
],
42+
'name' => '{ClusterTemplateName}',
43+
];
44+
45+
$clusterTemplate = $sahara->createClusterTemplate($options);
46+
print_r($clusterTemplate);

‎samples/data_processing/cluster_template/delete_cluster_template.php

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$cluster = $sahara->getClusterTemplate(['id' => '{clusterTemplateId}']);
25+
$cluster->delete();

‎samples/data_processing/cluster_template/get_cluster_template.php

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$clusterTemplate = $sahara->getClusterTemplate(['id' => '{clusterTemplateId}']);
25+
$clusterTemplate->retrieve();
26+
print_r($clusterTemplate);

‎samples/data_processing/cluster_template/list_cluster_templates.php

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
<?php
2+
3+
require 'vendor/autoload.php';
4+
5+
use OpenStack\OpenStack;
6+
7+
$openstack = new OpenStack([
8+
'authUrl' => '{authUrl}',
9+
'user' => [
10+
'name' => '{userName}',
11+
'password' => '{password}',
12+
'domain' => ['name' => '{userDomain}'],
13+
],
14+
'scope' => [
15+
'project' => [
16+
'name' => '{projectName}',
17+
'domain' => ['name' => '{projectDomain}'],
18+
],
19+
],
20+
]);
21+
22+
$sahara = $openstack->dataProcessingV1(['region' => '{region}']);
23+
24+
$options = [
25+
'limit' => '{limit}',
26+
'sortBy' => '{sortBy}',
27+
];
28+
29+
$clusterTemplates = $sahara->listClusterTemplates($options);
30+
foreach ($clusterTemplates as $clusterTemplate) {
31+
print_r($clusterTemplate);
32+
}

0 commit comments

Comments
 (0)