Package com.linkedin.d2.discovery.stores.zk

Examples of com.linkedin.d2.discovery.stores.zk.ZooKeeper

55
56
57
58
59
60
61
62
    {
      callback.get(10, TimeUnit.SECONDS);
    }
    catch (Exception e)
    {
      throw new PropertyStoreException(e);
    }
  }
View Full Code Here
70
71
72
73
74
75
76
77
    {
      callback.get(10, TimeUnit.SECONDS);
    }
    catch (Exception e)
    {
      throw new PropertyStoreException(e);
    }
  }
View Full Code Here
85
86
87
88
89
90
91
92
    {
      callback.get(10, TimeUnit.SECONDS);
    }
    catch (Exception e)
    {
      throw new PropertyStoreException(e);
    }
  }
View Full Code Here
49
50
51
52
53
54
55
56
    {
      callback.get(10, TimeUnit.SECONDS);
    }
    catch (Exception e)
    {
      throw new PropertyStoreException(e);
    }
  }
View Full Code Here
82
83
84
85
86
87
88
89
    {
      callback.get(10, TimeUnit.SECONDS);
    }
    catch (Exception e)
    {
      throw new PropertyStoreException(e);
    }
  }
View Full Code Here
134
135
136
137
138
139
140
141
142
143
144
                   boolean useDeltaWrite,
                   int maxOutstandingWrites)
  {
    _retryLimit = retryLimit;
    // use retry zkConnection
    _zkConnection = new ZKConnection(zkHosts, sessionTimeout, _retryLimit, false, null, 0);
    _basePath = basePath;
    _timeout = timeout;
    _clusterServiceConfigurations = Arrays.asList(clusterServiceConfigurations, extraClusterServiceConfigurations);
    _clusterDefaults = clusterDefaults;
    _serviceDefaults = serviceDefaults;
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
58
59
  }

  @Override
  public void getServiceNames(final Callback<List<String>> callback)
  {
    final ZooKeeper zk = _connection.getZooKeeper();
    final String path = ZKFSUtil.servicePath(_basePath);
    zk.getChildren(path, false, new AsyncCallback.Children2Callback()
    {
      @Override
      public void processResult(int rc, String path, Object ctx, List<String> children, Stat stat)
      {
        KeeperException.Code code = KeeperException.Code.get(rc);
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
85
86
  }

  @Override
  public void getClusterNames(final Callback<List<String>> callback)
  {
    final ZooKeeper zk = _connection.getZooKeeper();
    final String path = ZKFSUtil.clusterPath(_basePath);
    zk.getChildren(path, false, new AsyncCallback.Children2Callback()
    {
      @Override
      public void processResult(int rc, String path, Object ctx, List<String> children, Stat stat)
      {
        KeeperException.Code code = KeeperException.Code.get(rc);
View Full Code Here
634
635
636
637
638
639
640
641
642
643
644
645
646
  }

  public static List<String> getServicesGroups (ZKConnection zkclient, String basePath) throws Exception
  {
    List<String> servicesGroups = new ArrayList<String>();
    ZooKeeper zook = zkclient.getZooKeeper();

    List<String> children = zook.getChildren(basePath,false);

    for (String child : children)
    {
      if (! child.equalsIgnoreCase("clusters") && ! child.equalsIgnoreCase("uris"))
      {
View Full Code Here
761
762
763
764
765
766
767
768
769
770
771
772
773
774
          latch.countDown();
        }
      }
    };

    ZooKeeper zk = _zkclient.getZooKeeper();
    for (String path : expectedVersionMap.keySet())
    {
      zk.exists(path, false, statCallback, null);
    }

    // Wait for expectedVersionMap to be populated.
    if (!latch.await(5, TimeUnit.SECONDS))
    {
View Full Code Here
TOP

Related Classes of com.linkedin.d2.discovery.stores.zk.ZooKeeper

  • com.example.d2.client.BigDataClientExample
  • com.example.d2.client.CacheClientExample
  • com.example.d2.client.EmailClientExample
  • com.example.d2.client.ExampleD2Client
  • com.example.d2.client.ProfileClientExample
  • com.example.d2.server.ExampleD2Server
  • com.linkedin.d2.balancer.clients.DynamicClient
  • com.linkedin.d2.balancer.clients.DynamicClientTest
  • com.linkedin.d2.balancer.clients.DynamicClientTest$TestLoadBalancer
  • com.linkedin.d2.balancer.clients.RewriteClientTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.