com.gigaspaces.internal.zookeeper

Class ZNodePathFactory

java.lang.Object

com.gigaspaces.internal.zookeeper.ZNodePathFactory

public class ZNodePathFactory
extends Object

Since:

14.2

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor and Description
ZNodePathFactory()

Method Summary

Modifier and Type	Method and Description
static String	connector_started(String pipeline)
static String	consumerConfig(String consumer)
static String	consumerPu(String pipeline)
static String	consumerUrl(String pipeline)
static String	createOnContainerRequest(String machineId)
static String	createOnContainerRequest(String machineId, int agentId)
static String	createPreContainerRequest(String machineId)
static String	createPreContainerRequest(String machineId, String uuid)
static String	createRequestsPath()
static String	createRestartContainerRequest(String machineId)
static String	createRestartContainerRequest(String machineId, String uuid)
static String	deleteContainerRequest(String containerId)
static String	deployProcessingUnitRequest(String puName)
static String	full_sync_completed(String pipeline)
static String	getConsumers()
static String	lockPersistentName(String puName)
static String	lockPuName(String puName)
static String	lockPuSlaName(String puName)
static String	lockScaleOutScaleStatus(String puName)
static String	path(String... elements)
static String	pipeline(String pipeline)
static String	pipeline(String pipeline, String component)
static String	pipelineConfig(String pipeline)
static String	pipelines()
static String	processingUnit(String puName)
static String	processingUnit(String puName, String component)
static String	processingUnit(String puName, String component, int partitionId, String... elements)
static String	processingUnit(String puName, String component, String instanceId, String... elements)
static String	space(String spaceName)
static String	space(String spaceName, String component)
static String	space(String spaceName, String component, int partitionId, String... elements)
static String	space(String spaceName, String component, String partitionId, String... elements)
static String	totalOperation(String pipeline)
static String	undeployProcessingUnitRequest(String puName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZNodePathFactory

public ZNodePathFactory()

Method Detail

path

public static String path(String... elements)

processingUnit

public static String processingUnit(String puName)

lockPuName

public static String lockPuName(String puName)

lockPersistentName

public static String lockPersistentName(String puName)

lockScaleOutScaleStatus

public static String lockScaleOutScaleStatus(String puName)

lockPuSlaName

public static String lockPuSlaName(String puName)

processingUnit

public static String processingUnit(String puName,
                                    String component)

pipeline

public static String pipeline(String pipeline)

pipelineConfig

public static String pipelineConfig(String pipeline)

consumerConfig

public static String consumerConfig(String consumer)

pipeline

public static String pipeline(String pipeline,
                              String component)

pipelines

public static String pipelines()

getConsumers

public static String getConsumers()

consumerUrl

public static String consumerUrl(String pipeline)

consumerPu

public static String consumerPu(String pipeline)

totalOperation

public static String totalOperation(String pipeline)

connector_started

public static String connector_started(String pipeline)

full_sync_completed

public static String full_sync_completed(String pipeline)

processingUnit

public static String processingUnit(String puName,
                                    String component,
                                    int partitionId,
                                    String... elements)

processingUnit

public static String processingUnit(String puName,
                                    String component,
                                    String instanceId,
                                    String... elements)

space

public static String space(String spaceName)

space

public static String space(String spaceName,
                           String component,
                           int partitionId,
                           String... elements)

space

public static String space(String spaceName,
                           String component,
                           String partitionId,
                           String... elements)

space

public static String space(String spaceName,
                           String component)

createPreContainerRequest

public static String createPreContainerRequest(String machineId,
                                               String uuid)

createRequestsPath

public static String createRequestsPath()

createPreContainerRequest

public static String createPreContainerRequest(String machineId)

createOnContainerRequest

public static String createOnContainerRequest(String machineId)

createRestartContainerRequest

public static String createRestartContainerRequest(String machineId)

createRestartContainerRequest

public static String createRestartContainerRequest(String machineId,
                                                   String uuid)

createOnContainerRequest

public static String createOnContainerRequest(String machineId,
                                              int agentId)

deleteContainerRequest

public static String deleteContainerRequest(String containerId)

deployProcessingUnitRequest

public static String deployProcessingUnitRequest(String puName)

undeployProcessingUnitRequest

public static String undeployProcessingUnitRequest(String puName)