1 package org.apache.helix.participant;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.UUID;
23
24 import org.apache.helix.ClusterMessagingService;
25 import org.apache.helix.ConfigAccessor;
26 import org.apache.helix.ConfigChangeListener;
27 import org.apache.helix.ControllerChangeListener;
28 import org.apache.helix.CurrentStateChangeListener;
29 import org.apache.helix.ExternalViewChangeListener;
30 import org.apache.helix.HealthStateChangeListener;
31 import org.apache.helix.HelixAdmin;
32 import org.apache.helix.HelixDataAccessor;
33 import org.apache.helix.HelixManager;
34 import org.apache.helix.HelixManagerProperties;
35 import org.apache.helix.IdealStateChangeListener;
36 import org.apache.helix.InstanceConfigChangeListener;
37 import org.apache.helix.InstanceType;
38 import org.apache.helix.LiveInstanceChangeListener;
39 import org.apache.helix.LiveInstanceInfoProvider;
40 import org.apache.helix.MessageListener;
41 import org.apache.helix.PreConnectCallback;
42 import org.apache.helix.PropertyKey;
43 import org.apache.helix.ScopedConfigChangeListener;
44 import org.apache.helix.ZNRecord;
45 import org.apache.helix.healthcheck.ParticipantHealthReportCollector;
46 import org.apache.helix.manager.zk.ZKHelixDataAccessor;
47 import org.apache.helix.manager.zk.ZkBaseDataAccessor;
48 import org.apache.helix.manager.zk.ZkClient;
49 import org.apache.helix.model.HelixConfigScope.ConfigScopeProperty;
50 import org.apache.helix.store.zk.ZkHelixPropertyStore;
51
52
53 public class MockZKHelixManager implements HelixManager
54 {
55 private final ZKHelixDataAccessor _accessor;
56 private final String _instanceName;
57 private final String _clusterName;
58 private final InstanceType _type;
59
60 public MockZKHelixManager(String clusterName,
61 String instanceName,
62 InstanceType type,
63 ZkClient zkClient)
64 {
65 _instanceName = instanceName;
66 _clusterName = clusterName;
67 _type = type;
68 _accessor = new ZKHelixDataAccessor(clusterName, new ZkBaseDataAccessor(zkClient));
69 }
70
71 @Override
72 public void connect() throws Exception
73 {
74
75
76 }
77
78 @Override
79 public boolean isConnected()
80 {
81
82 return false;
83 }
84
85 @Override
86 public void disconnect()
87 {
88
89
90 }
91
92 @Override
93 public void addIdealStateChangeListener(IdealStateChangeListener listener) throws Exception
94 {
95
96
97 }
98
99 @Override
100 public void addLiveInstanceChangeListener(LiveInstanceChangeListener listener) throws Exception
101 {
102
103
104 }
105
106 @Override
107 public void addConfigChangeListener(ConfigChangeListener listener) throws Exception
108 {
109
110
111 }
112
113 @Override
114 public void addMessageListener(MessageListener listener, String instanceName) throws Exception
115 {
116
117
118 }
119
120 @Override
121 public void addCurrentStateChangeListener(CurrentStateChangeListener listener,
122 String instanceName,
123 String sessionId) throws Exception
124 {
125
126
127 }
128
129 @Override
130 public void addExternalViewChangeListener(ExternalViewChangeListener listener) throws Exception
131 {
132
133
134 }
135
136 @Override
137 public boolean removeListener(PropertyKey key, Object listener)
138 {
139
140 return false;
141 }
142
143 @Override
144 public HelixDataAccessor getHelixDataAccessor()
145 {
146 return _accessor;
147 }
148
149 @Override
150 public String getClusterName()
151 {
152 return _clusterName;
153 }
154
155 @Override
156 public String getInstanceName()
157 {
158 return _instanceName;
159 }
160
161 @Override
162 public String getSessionId()
163 {
164
165 return UUID.randomUUID().toString();
166 }
167
168 @Override
169 public long getLastNotificationTime()
170 {
171
172 return 0;
173 }
174
175 @Override
176 public void addControllerListener(ControllerChangeListener listener)
177 {
178
179
180 }
181
182 @Override
183 public HelixAdmin getClusterManagmentTool()
184 {
185
186 return null;
187 }
188
189 @Override
190 public ClusterMessagingService getMessagingService()
191 {
192
193 return null;
194 }
195
196 @Override
197 public ParticipantHealthReportCollector getHealthReportCollector()
198 {
199
200 return null;
201 }
202
203 @Override
204 public InstanceType getInstanceType()
205 {
206 return _type;
207 }
208
209 @Override
210 public void addHealthStateChangeListener(HealthStateChangeListener listener,
211 String instanceName) throws Exception
212 {
213
214
215 }
216
217 @Override
218 public String getVersion()
219 {
220
221 return UUID.randomUUID().toString();
222 }
223
224 @Override
225 public StateMachineEngine getStateMachineEngine()
226 {
227
228 return null;
229 }
230
231 @Override
232 public boolean isLeader()
233 {
234
235 return false;
236 }
237
238 @Override
239 public ConfigAccessor getConfigAccessor()
240 {
241
242 return null;
243 }
244
245 @Override
246 public void startTimerTasks()
247 {
248
249
250 }
251
252 @Override
253 public void stopTimerTasks()
254 {
255
256
257 }
258
259 @Override
260 public void addPreConnectCallback(PreConnectCallback callback)
261 {
262
263
264 }
265
266 @Override
267 public ZkHelixPropertyStore<ZNRecord> getHelixPropertyStore()
268 {
269
270 return null;
271 }
272
273 @Override
274 public void addInstanceConfigChangeListener(InstanceConfigChangeListener listener) throws Exception {
275
276
277 }
278
279 @Override
280 public void addConfigChangeListener(ScopedConfigChangeListener listener, ConfigScopeProperty scope)
281 throws Exception {
282
283
284 }
285
286 @Override
287 public void setLiveInstanceInfoProvider(
288 LiveInstanceInfoProvider liveInstanceInfoProvider)
289 {
290
291
292 }
293
294 @Override
295 public HelixManagerProperties getProperties() {
296
297 return null;
298 }
299
300 }