View Javadoc

1   package org.apache.helix.participant;
2   
3   /*
4    * Licensed to the Apache Software Foundation (ASF) under one
5    * or more contributor license agreements.  See the NOTICE file
6    * distributed with this work for additional information
7    * regarding copyright ownership.  The ASF licenses this file
8    * to you under the Apache License, Version 2.0 (the
9    * "License"); you may not use this file except in compliance
10   * with the License.  You may obtain a copy of the License at
11   *
12   *   http://www.apache.org/licenses/LICENSE-2.0
13   *
14   * Unless required by applicable law or agreed to in writing,
15   * software distributed under the License is distributed on an
16   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
17   * KIND, either express or implied.  See the License for the
18   * specific language governing permissions and limitations
19   * under the License.
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      // TODO Auto-generated method stub
75  
76    }
77  
78    @Override
79    public boolean isConnected()
80    {
81      // TODO Auto-generated method stub
82      return false;
83    }
84  
85    @Override
86    public void disconnect()
87    {
88      // TODO Auto-generated method stub
89  
90    }
91  
92    @Override
93    public void addIdealStateChangeListener(IdealStateChangeListener listener) throws Exception
94    {
95      // TODO Auto-generated method stub
96  
97    }
98  
99    @Override
100   public void addLiveInstanceChangeListener(LiveInstanceChangeListener listener) throws Exception
101   {
102     // TODO Auto-generated method stub
103 
104   }
105 
106   @Override
107   public void addConfigChangeListener(ConfigChangeListener listener) throws Exception
108   {
109     // TODO Auto-generated method stub
110 
111   }
112 
113   @Override
114   public void addMessageListener(MessageListener listener, String instanceName) throws Exception
115   {
116     // TODO Auto-generated method stub
117 
118   }
119 
120   @Override
121   public void addCurrentStateChangeListener(CurrentStateChangeListener listener,
122                                             String instanceName,
123                                             String sessionId) throws Exception
124   {
125     // TODO Auto-generated method stub
126 
127   }
128 
129   @Override
130   public void addExternalViewChangeListener(ExternalViewChangeListener listener) throws Exception
131   {
132     // TODO Auto-generated method stub
133 
134   }
135 
136   @Override
137   public boolean removeListener(PropertyKey key, Object listener)
138   {
139     // TODO Auto-generated method stub
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     // TODO Auto-generated method stub
165     return UUID.randomUUID().toString();
166   }
167 
168   @Override
169   public long getLastNotificationTime()
170   {
171     // TODO Auto-generated method stub
172     return 0;
173   }
174 
175   @Override
176   public void addControllerListener(ControllerChangeListener listener)
177   {
178     // TODO Auto-generated method stub
179 
180   }
181 
182   @Override
183   public HelixAdmin getClusterManagmentTool()
184   {
185     // TODO Auto-generated method stub
186     return null;
187   }
188 
189   @Override
190   public ClusterMessagingService getMessagingService()
191   {
192     // TODO Auto-generated method stub
193     return null;
194   }
195 
196   @Override
197   public ParticipantHealthReportCollector getHealthReportCollector()
198   {
199     // TODO Auto-generated method stub
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     // TODO Auto-generated method stub
214 
215   }
216 
217   @Override
218   public String getVersion()
219   {
220     // TODO Auto-generated method stub
221     return UUID.randomUUID().toString();
222   }
223 
224   @Override
225   public StateMachineEngine getStateMachineEngine()
226   {
227     // TODO Auto-generated method stub
228     return null;
229   }
230 
231   @Override
232   public boolean isLeader()
233   {
234     // TODO Auto-generated method stub
235     return false;
236   }
237 
238   @Override
239   public ConfigAccessor getConfigAccessor()
240   {
241     // TODO Auto-generated method stub
242     return null;
243   }
244 
245   @Override
246   public void startTimerTasks()
247   {
248     // TODO Auto-generated method stub
249 
250   }
251 
252   @Override
253   public void stopTimerTasks()
254   {
255     // TODO Auto-generated method stub
256 
257   }
258 
259   @Override
260   public void addPreConnectCallback(PreConnectCallback callback)
261   {
262     // TODO Auto-generated method stub
263     
264   }
265 
266   @Override
267   public ZkHelixPropertyStore<ZNRecord> getHelixPropertyStore()
268   {
269     // TODO Auto-generated method stub
270     return null;
271   }
272   
273   @Override
274   public void addInstanceConfigChangeListener(InstanceConfigChangeListener listener) throws Exception {
275   	// TODO Auto-generated method stub
276 
277   }
278 
279   @Override
280   public void addConfigChangeListener(ScopedConfigChangeListener listener, ConfigScopeProperty scope)
281           throws Exception {
282   	// TODO Auto-generated method stub
283 
284   }
285 
286   @Override
287   public void setLiveInstanceInfoProvider(
288       LiveInstanceInfoProvider liveInstanceInfoProvider)
289   {
290     // TODO Auto-generated method stub
291     
292   }
293 
294   @Override
295   public HelixManagerProperties getProperties() {
296     // TODO Auto-generated method stub
297     return null;
298   }
299 
300 }