ZkStoreSystem extends DimitStoreSystem { public CuratorFramework zkCli() { return this.zkCli; } ZkStoreSystem(DimitStoreSystemProvider provider, Map<String, Object> env); CuratorFramework zkCli(); @Override byte[] read(DimitPath path); @Override DimitPath write(DimitPath path, byte[] data, StoreAttribute<?>... attributes); @Override List<StoreWatcher> newStoreWatcher(StoreWatchKey key); @Override List<String> children(DimitPath path);  }
@Test public void testCreateDimitConf() { DimitConf dimit = DimitConf.newBuilder().setCt(System.currentTimeMillis()).setMt(System.currentTimeMillis()) .setId(IDUtil.storeID(Const.V, MagicFlag.DIMIT_CONF)).setV(Const.V).setName("voice").build(); try { String path = dss.zkCli().create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT) .forPath("/dimit/dzh/conf/" + dimit.getId(), dimit.toByteArray()); LOG.info("create {}", path); dss.zkCli().delete().deletingChildrenIfNeeded().forPath(path); LOG.info("delete {}", path); } catch (Exception e) { LOG.error(e.getMessage(), e); } }