blob: 1453418d6fcb50f1f70ed7ff043ab06960754abf (
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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
|
<?php
namespace Elastica;
use Elastica\Node\Info;
use Elastica\Node\Stats;
/**
* Elastica cluster node object.
*
* @author Nicolas Ruflin <spam@ruflin.com>
*/
class Node
{
/**
* Client.
*
* @var \Elastica\Client
*/
protected $_client = null;
/**
* @var string Unique node id
*/
protected $_id = '';
/**
* 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 $id Node id or name
* @param \Elastica\Client $client Node object
*/
public function __construct($id, Client $client)
{
$this->_client = $client;
$this->setId($id);
}
/**
* @return string Unique node id. Can also be name if id not exists.
*/
public function getId()
{
return $this->_id;
}
/**
* @param string $id Node id
*
* @return $this Refreshed object
*/
public function setId($id)
{
$this->_id = $id;
return $this->refresh();
}
/**
* Get the name of the node.
*
* @return string Node name
*/
public function getName()
{
if (empty($this->_name)) {
$this->_name = $this->getInfo()->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.
*
* @link http://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-stats.html
*
* @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.
*
* @link http://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-info.html
*
* @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.elastic.co/guide/en/elasticsearch/reference/current/cluster-nodes-shutdown.html
*/
public function shutdown($delay = '1s')
{
$path = '_cluster/nodes/'.$this->getId().'/_shutdown?delay='.$delay;
return $this->_client->request($path, Request::POST);
}
}
|
