org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.service

类 ComputeNodeStatusService

java.lang.Object

org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.status.compute.service.ComputeNodeStatusService

public final class ComputeNodeStatusService
extends Object

Compute node status service.

构造器概要

构造器

构造器和说明
ComputeNodeStatusService()

方法概要

限定符和类型	方法和说明
Set<Long>	getAssignedWorkerIds() Get assigned worker ids.
Collection<org.apache.shardingsphere.infra.instance.ComputeNodeInstance>	loadAllComputeNodeInstances() Load all compute node instances.
org.apache.shardingsphere.infra.instance.ComputeNodeInstance	loadComputeNodeInstance(org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData instanceMetaData) Load compute node instance by instance definition.
Collection<String>	loadInstanceLabels(String instanceId) Load instance labels.
Collection<String>	loadInstanceStatus(String instanceId) Load instance status.
Optional<Long>	loadInstanceWorkerId(String instanceId) Load instance worker id.
void	persistInstanceLabels(String instanceId, Collection<String> labels) Persist instance labels.
void	persistInstanceWorkerId(String instanceId, Long workerId) Persist instance worker id.
void	registerOnline(org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData instanceMetaData) Register online.

从类继承的方法 java.lang.Object

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

构造器详细资料

ComputeNodeStatusService

public ComputeNodeStatusService()

方法详细资料

registerOnline

public void registerOnline(org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData instanceMetaData)

Register online.

参数:

instanceMetaData - instance definition

persistInstanceLabels

public void persistInstanceLabels(String instanceId,
                                  Collection<String> labels)

Persist instance labels.

参数:

instanceId - instance id

labels - collection of label

persistInstanceWorkerId

public void persistInstanceWorkerId(String instanceId,
                                    Long workerId)

Persist instance worker id.

参数:

instanceId - instance id

workerId - worker id

loadInstanceLabels

public Collection<String> loadInstanceLabels(String instanceId)

Load instance labels.

参数:

instanceId - instance id

返回:

labels

loadInstanceStatus

public Collection<String> loadInstanceStatus(String instanceId)

Load instance status.

参数:

instanceId - instance id

返回:

status

loadInstanceWorkerId

public Optional<Long> loadInstanceWorkerId(String instanceId)

Load instance worker id.

参数:

instanceId - instance id

返回:

worker id

loadAllComputeNodeInstances

public Collection<org.apache.shardingsphere.infra.instance.ComputeNodeInstance> loadAllComputeNodeInstances()

Load all compute node instances.

返回:

compute node instances

loadComputeNodeInstance

public org.apache.shardingsphere.infra.instance.ComputeNodeInstance loadComputeNodeInstance(org.apache.shardingsphere.infra.instance.metadata.InstanceMetaData instanceMetaData)

Load compute node instance by instance definition.

参数:

instanceMetaData - instance definition

返回:

compute node instance

getAssignedWorkerIds

public Set<Long> getAssignedWorkerIds()

Get assigned worker ids.

返回:

assigned worker ids