blob: a9684ca6a7a4d83ac17605851cdfcc3e98d9288d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
<?php
namespace Elastica;
use Elastica\Node\Info;
use Elastica\Node\Stats;
/**
* Elastica cluster node object
*
* @category Xodoa
* @package Elastica
* @author Nicolas Ruflin <spam@ruflin.com>
* @link http://www.elasticsearch.org/guide/reference/api/admin-indices-status.html
*/
class Node
{
/**
* Client
*
* @var \Elastica\Client
*/
protected $_client = null;
/**
* Node name
*
* @var string Node name
*/
protected $_name = '';
/**
* Node stats
*
* @var \Elastica\Node\Stats Node Stats
*/
protected $_stats = null;
/**
* Node info
*
* @var \Elastica\Node\Info Node info
*/
protected $_info = null;
/**
* Create a new node object
*
* @param string $name Node name
* @param \Elastica\Client $client Node object
*/
public function __construct($name, Client $client)
{
$this->_name = $name;
$this->_client = $client;
$this->refresh();
}
/**
* Get the name of the node
*
* @return string Node name
*/
public function getName()
{
return $this->_name;
}
/**
* Returns the current client object
*
* @return \Elastica\Client Client
*/
public function getClient()
{
return $this->_client;
}
/**
* Return stats object of the current node
*
* @return \Elastica\Node\Stats Node stats
*/
public function getStats()
{
if (!$this->_stats) {
$this->_stats = new Stats($this);
}
return $this->_stats;
}
/**
* Return info object of the current node
*
* @return \Elastica\Node\Info Node info object
*/
public function getInfo()
{
if (!$this->_info) {
$this->_info = new Info($this);
}
return $this->_info;
}
/**
* Refreshes all node information
*
* This should be called after updating a node to refresh all information
*/
public function refresh()
{
$this->_stats = null;
$this->_info = null;
}
/**
* Shuts this node down
*
* @param string $delay OPTIONAL Delay after which node is shut down (default = 1s)
* @return \Elastica\Response
* @link http://www.elasticsearch.org/guide/reference/api/admin-cluster-nodes-shutdown.html
*/
public function shutdown($delay = '1s')
{
$path = '_cluster/nodes/' . $this->getName() . '/_shutdown?delay=' . $delay;
return $this->_client->request($path, Request::POST);
}
}
|
