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
|
/*******************************************************************************
* Copyright (c) 2011 Gluster, Inc. <http://www.gluster.com>
* This file is part of Gluster Management Console.
*
* Gluster Management Console is free software; you can redistribute it and/or
* modify it under the terms of the GNU Affero General Public License as published
* by the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* Gluster Management Console is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License
* for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see
* <http://www.gnu.org/licenses/>.
*******************************************************************************/
package com.gluster.storage.management.client;
import static com.gluster.storage.management.core.constants.RESTConstants.RESOURCE_PATH_CLUSTERS;
import static com.gluster.storage.management.core.constants.RESTConstants.RESOURCE_SERVERS;
import java.net.URI;
import java.util.List;
import javax.ws.rs.core.MultivaluedMap;
import com.gluster.storage.management.core.constants.RESTConstants;
import com.gluster.storage.management.core.model.GlusterServer;
import com.gluster.storage.management.core.model.ServerStats;
import com.gluster.storage.management.core.response.GlusterServerListResponse;
import com.gluster.storage.management.core.utils.GlusterCoreUtil;
import com.sun.jersey.api.representation.Form;
import com.sun.jersey.core.util.MultivaluedMapImpl;
public class GlusterServersClient extends AbstractClient {
public GlusterServersClient() {
super();
}
public GlusterServersClient(String clusterName) {
super(clusterName);
}
public GlusterServersClient(String securityToken, String clusterName) {
super(securityToken, clusterName);
}
@Override
public String getResourcePath() {
return RESOURCE_PATH_CLUSTERS + "/" + clusterName + "/" + RESOURCE_SERVERS;
}
public List<GlusterServer> getServers() {
List<GlusterServer> servers = ((GlusterServerListResponse) fetchResource(GlusterServerListResponse.class)).getServers();
for(GlusterServer server : servers) {
GlusterCoreUtil.updateServerNameOnDevices(server);
}
return servers;
}
public GlusterServer getGlusterServer(String serverName) {
GlusterServer server = (GlusterServer) fetchSubResource(serverName, GlusterServer.class);
GlusterCoreUtil.updateServerNameOnDevices(server);
return server;
}
public void addServer(String serverName) {
Form form = new Form();
form.add(RESTConstants.FORM_PARAM_SERVER_NAME, serverName);
postRequest(form);
}
public URI initializeDisk(String serverName, String diskName, String fsType) {
Form form = new Form();
form.add(RESTConstants.FORM_PARAM_FSTYPE, fsType);
return putRequestURI(serverName + "/" + RESTConstants.RESOURCE_DISKS + "/" + diskName, form);
}
public void removeServer(String serverName) {
deleteSubResource(serverName);
}
public ServerStats getCpuStats(String serverName, String period) {
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
queryParams.add(RESTConstants.QUERY_PARAM_TYPE, RESTConstants.STATISTICS_TYPE_CPU);
queryParams.add(RESTConstants.QUERY_PARAM_PERIOD, period);
return fetchSubResource(serverName + "/" + RESTConstants.RESOURCE_STATISTICS, queryParams, ServerStats.class);
}
public ServerStats getMemoryStats(String serverName, String period) {
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
queryParams.add(RESTConstants.QUERY_PARAM_TYPE, RESTConstants.STATISTICS_TYPE_MEMORY);
queryParams.add(RESTConstants.QUERY_PARAM_PERIOD, period);
return fetchSubResource(serverName + "/" + RESTConstants.RESOURCE_STATISTICS, queryParams, ServerStats.class);
}
public ServerStats getNetworkStats(String serverName, String networkInterface, String period) {
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
queryParams.add(RESTConstants.QUERY_PARAM_TYPE, RESTConstants.STATISTICS_TYPE_NETWORK);
queryParams.add(RESTConstants.QUERY_PARAM_PERIOD, period);
queryParams.add(RESTConstants.QUERY_PARAM_INTERFACE, networkInterface);
return fetchSubResource(serverName + "/" + RESTConstants.RESOURCE_STATISTICS, queryParams, ServerStats.class);
}
public ServerStats getAggregatedCpuStats(String period) {
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
queryParams.add(RESTConstants.QUERY_PARAM_TYPE, RESTConstants.STATISTICS_TYPE_CPU);
queryParams.add(RESTConstants.QUERY_PARAM_PERIOD, period);
return fetchSubResource(RESTConstants.RESOURCE_STATISTICS, queryParams, ServerStats.class);
}
public ServerStats getAggregatedNetworkStats(String period) {
MultivaluedMap<String, String> queryParams = new MultivaluedMapImpl();
queryParams.add(RESTConstants.QUERY_PARAM_TYPE, RESTConstants.STATISTICS_TYPE_NETWORK);
queryParams.add(RESTConstants.QUERY_PARAM_PERIOD, period);
return fetchSubResource(RESTConstants.RESOURCE_STATISTICS, queryParams, ServerStats.class);
}
}
|
