2 * ============LICENSE_START=======================================================
\r
4 * ================================================================================
\r
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
\r
6 * ================================================================================
\r
7 * Licensed under the Apache License, Version 2.0 (the "License");
\r
8 * you may not use this file except in compliance with the License.
\r
9 * You may obtain a copy of the License at
\r
11 * http://www.apache.org/licenses/LICENSE-2.0
\r
13 * Unless required by applicable law or agreed to in writing, software
\r
14 * distributed under the License is distributed on an "AS IS" BASIS,
\r
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
16 * See the License for the specific language governing permissions and
\r
17 * limitations under the License.
\r
18 * ============LICENSE_END=========================================================
\r
21 package com.att.nsa.cambria.backends.kafka;
\r
23 import java.util.concurrent.TimeUnit;
\r
25 import org.apache.curator.CuratorZookeeperClient;
\r
26 import org.apache.curator.framework.CuratorFramework;
\r
27 import org.apache.curator.framework.WatcherRemoveCuratorFramework;
\r
28 import org.apache.curator.framework.api.CreateBuilder;
\r
29 import org.apache.curator.framework.api.CuratorListener;
\r
30 import org.apache.curator.framework.api.DeleteBuilder;
\r
31 import org.apache.curator.framework.api.ExistsBuilder;
\r
32 import org.apache.curator.framework.api.GetACLBuilder;
\r
33 import org.apache.curator.framework.api.GetChildrenBuilder;
\r
34 import org.apache.curator.framework.api.GetConfigBuilder;
\r
35 import org.apache.curator.framework.api.GetDataBuilder;
\r
36 import org.apache.curator.framework.api.ReconfigBuilder;
\r
37 import org.apache.curator.framework.api.RemoveWatchesBuilder;
\r
38 import org.apache.curator.framework.api.SetACLBuilder;
\r
39 import org.apache.curator.framework.api.SetDataBuilder;
\r
40 import org.apache.curator.framework.api.SyncBuilder;
\r
41 import org.apache.curator.framework.api.UnhandledErrorListener;
\r
42 import org.apache.curator.framework.api.transaction.CuratorMultiTransaction;
\r
43 import org.apache.curator.framework.api.transaction.CuratorTransaction;
\r
44 import org.apache.curator.framework.api.transaction.TransactionOp;
\r
45 import org.apache.curator.framework.imps.CuratorFrameworkState;
\r
46 import org.apache.curator.framework.listen.Listenable;
\r
47 import org.apache.curator.framework.schema.SchemaSet;
\r
48 import org.apache.curator.framework.state.ConnectionStateErrorPolicy;
\r
49 import org.apache.curator.framework.state.ConnectionStateListener;
\r
50 import org.apache.curator.utils.EnsurePath;
\r
51 import org.apache.zookeeper.Watcher;
\r
52 import org.apache.zookeeper.server.quorum.flexible.QuorumVerifier;
\r
54 public class CuratorFrameworkImpl implements CuratorFramework {
\r
57 public void blockUntilConnected() throws InterruptedException {
\r
58 // TODO Auto-generated method stub
\r
63 public boolean blockUntilConnected(int arg0, TimeUnit arg1) throws InterruptedException {
\r
64 // TODO Auto-generated method stub
\r
69 public ExistsBuilder checkExists() {
\r
70 // TODO Auto-generated method stub
\r
75 public void clearWatcherReferences(Watcher arg0) {
\r
76 // TODO Auto-generated method stub
\r
81 public void close() {
\r
82 // TODO Auto-generated method stub
\r
87 public CreateBuilder create() {
\r
88 // TODO Auto-generated method stub
\r
93 public DeleteBuilder delete() {
\r
94 // TODO Auto-generated method stub
\r
99 public GetACLBuilder getACL() {
\r
100 // TODO Auto-generated method stub
\r
105 public GetChildrenBuilder getChildren() {
\r
106 // TODO Auto-generated method stub
\r
111 public Listenable<ConnectionStateListener> getConnectionStateListenable() {
\r
112 // TODO Auto-generated method stub
\r
117 public Listenable<CuratorListener> getCuratorListenable() {
\r
118 // TODO Auto-generated method stub
\r
123 public GetDataBuilder getData() {
\r
124 // TODO Auto-generated method stub
\r
129 public String getNamespace() {
\r
130 // TODO Auto-generated method stub
\r
135 public CuratorFrameworkState getState() {
\r
136 // TODO Auto-generated method stub
\r
141 public Listenable<UnhandledErrorListener> getUnhandledErrorListenable() {
\r
142 // TODO Auto-generated method stub
\r
147 public CuratorZookeeperClient getZookeeperClient() {
\r
148 // TODO Auto-generated method stub
\r
153 public CuratorTransaction inTransaction() {
\r
154 // TODO Auto-generated method stub
\r
159 public boolean isStarted() {
\r
160 // TODO Auto-generated method stub
\r
165 public EnsurePath newNamespaceAwareEnsurePath(String arg0) {
\r
166 // TODO Auto-generated method stub
\r
171 public CuratorFramework nonNamespaceView() {
\r
172 // TODO Auto-generated method stub
\r
177 public SetACLBuilder setACL() {
\r
178 // TODO Auto-generated method stub
\r
183 public SetDataBuilder setData() {
\r
184 // TODO Auto-generated method stub
\r
189 public void start() {
\r
190 // TODO Auto-generated method stub
\r
195 public SyncBuilder sync() {
\r
196 // TODO Auto-generated method stub
\r
201 public void sync(String arg0, Object arg1) {
\r
202 // TODO Auto-generated method stub
\r
207 public CuratorFramework usingNamespace(String arg0) {
\r
208 // TODO Auto-generated method stub
\r
213 public ReconfigBuilder reconfig() {
\r
214 // TODO Auto-generated method stub
\r
219 public GetConfigBuilder getConfig() {
\r
220 // TODO Auto-generated method stub
\r
225 public CuratorMultiTransaction transaction() {
\r
226 // TODO Auto-generated method stub
\r
231 public TransactionOp transactionOp() {
\r
232 // TODO Auto-generated method stub
\r
237 public void createContainers(String path) throws Exception {
\r
238 // TODO Auto-generated method stub
\r
243 public RemoveWatchesBuilder watches() {
\r
244 // TODO Auto-generated method stub
\r
249 public WatcherRemoveCuratorFramework newWatcherRemoveCuratorFramework() {
\r
250 // TODO Auto-generated method stub
\r
255 public ConnectionStateErrorPolicy getConnectionStateErrorPolicy() {
\r
256 // TODO Auto-generated method stub
\r
261 public QuorumVerifier getCurrentConfig() {
\r
262 // TODO Auto-generated method stub
\r
267 public SchemaSet getSchemaSet() {
\r
268 // TODO Auto-generated method stub
\r
273 public boolean isZk34CompatibilityMode() {
\r
274 // TODO Auto-generated method stub
\r