本文整理了Java中com.spotify.helios.servicescommon.coordination.ZooKeeperOperations.create()方法的一些代码示例，展示了ZooKeeperOperations.create()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperOperations.create()方法的具体详情如下：
包路径：com.spotify.helios.servicescommon.coordination.ZooKeeperOperations
类名称：ZooKeeperOperations
方法名：create

ZooKeeperOperations.create介绍

暂无

代码示例

代码示例来源：origin: spotify/helios

public static ZooKeeperOperation create(final String path, final Descriptor data,
                    final int version) {
 return create(path, data.toJsonBytes(), version);
}

代码示例来源：origin: spotify/helios

public static ZooKeeperOperation create(final String path, final Descriptor data) {
 return create(path, data.toJsonBytes());
}

代码示例来源：origin: spotify/helios

operations.add(create(Paths.statusHost(host)));
operations.add(create(Paths.statusHostJobs(host)));
operations.add(create(Paths.configHostId(host), hostId.getBytes(UTF_8)));

代码示例来源：origin: spotify/helios

try {
 client.ensurePath(Paths.historyJob(id));
 client.transaction(create(Paths.configJob(id), job),
   create(Paths.configJobRefShort(id), id),
   create(Paths.configJobHosts(id)),
   create(creationPath),

代码示例来源：origin: spotify/helios

final List<ZooKeeperOperation> operations = Lists.newArrayList(
  check(jobPath),
  create(portNodes),
  create(Paths.configJobHost(id, host)));
  checkForPortConflicts(client, host, port, id);
 operations.add(create(taskPath, task));
 operations.add(create(taskCreationPath));
} catch (KeeperException e) {
 throw new HeliosRuntimeException("reading existing task description failed", e);

代码示例来源：origin: spotify/helios

client.ensurePath(Paths.statusDeploymentGroups());
client.transaction(
  create(Paths.configDeploymentGroup(deploymentGroup.getName()), deploymentGroup),
  create(Paths.statusDeploymentGroup(deploymentGroup.getName())),
  create(Paths.statusDeploymentGroupHosts(deploymentGroup.getName()),
    Json.asBytesUnchecked(emptyList())),
  create(Paths.statusDeploymentGroupRemovedHosts(deploymentGroup.getName()),
    Json.asBytesUnchecked(emptyList()))
);

代码示例来源：origin: spotify/helios

operations.add(create(tasksPath));
operations.add(delete(tasksPath));

代码示例来源：origin: spotify/helios

ops.add(create(Paths.statusDeploymentGroupTasks(deploymentGroup.getName())));

代码示例来源：origin: spotify/helios

operations.add(create(path));

代码示例来源：origin: spotify/helios

final List<ZooKeeperOperation> operations = Lists.newArrayList(
  check(jobPath),
  create(portNodes),
  create(Paths.configJobHost(id, host)));
 operations.add(create(taskPath, task));
 operations.add(create(taskCreationPath));
} catch (KeeperException e) {
 throw new HeliosRuntimeException("reading existing task description failed", e);

代码示例来源：origin: at.molindo/helios-services

public static ZooKeeperOperation create(final String path, final Descriptor data) {
 return create(path, data.toJsonBytes());
}

代码示例来源：origin: at.molindo/helios-services

public static ZooKeeperOperation create(final String path, final Descriptor data,
                    final int version) {
 return create(path, data.toJsonBytes(), version);
}

代码示例来源：origin: at.molindo/helios-services

try {
 client.ensurePath(Paths.historyJob(id));
 client.transaction(create(Paths.configJob(id), job),
           create(Paths.configJobRefShort(id), id),
           create(Paths.configJobHosts(id)),
           create(creationPath),

代码示例来源：origin: at.molindo/helios-services

@Override
public void addDeploymentGroup(final DeploymentGroup deploymentGroup)
  throws DeploymentGroupExistsException {
 log.info("adding deployment-group: {}", deploymentGroup);
 final ZooKeeperClient client = provider.get("addDeploymentGroup");
 try {
  try {
   client.ensurePath(Paths.configDeploymentGroups());
   client.ensurePath(Paths.statusDeploymentGroups());
   client.transaction(
     create(Paths.configDeploymentGroup(deploymentGroup.getName()), deploymentGroup),
     create(Paths.statusDeploymentGroup(deploymentGroup.getName())),
     create(Paths.statusDeploymentGroupHosts(deploymentGroup.getName()))
    );
  } catch (final NodeExistsException e) {
   throw new DeploymentGroupExistsException(deploymentGroup.getName());
  }
 } catch (final KeeperException e) {
  throw new HeliosRuntimeException("adding deployment-group " + deploymentGroup + " failed", e);
 }
}

代码示例来源：origin: at.molindo/helios-services

final List<ZooKeeperOperation> operations = Lists.newArrayList(
  check(jobPath),
  create(portNodes),
  create(Paths.configJobHost(id, host)));
 operations.add(create(taskPath, task));
 operations.add(create(taskCreationPath));
} catch (KeeperException e) {
 throw new HeliosRuntimeException("reading existing task description failed", e);

代码示例来源：origin: at.molindo/helios-services

final List<ZooKeeperOperation> operations = Lists.newArrayList(
  check(jobPath),
  create(portNodes),
  create(Paths.configJobHost(id, host)));
 operations.add(create(taskPath, task));
 operations.add(create(taskCreationPath));
} catch (KeeperException e) {
 throw new HeliosRuntimeException("reading existing task description failed", e);