com.alipay.sofa.registry.server.meta.repository.service

类 DataConfirmStatusService

java.lang.Object

com.alipay.sofa.registry.jraft.processor.AbstractSnapshotProcess

com.alipay.sofa.registry.server.meta.repository.service.DataConfirmStatusService

所有已实现的接口:

SnapshotProcess, NodeConfirmStatusService<DataNode>

public class DataConfirmStatusService
extends AbstractSnapshotProcess
implements NodeConfirmStatusService<DataNode>

版本:

$Id: DataConfirmStatusService.java, v 0.1 2018-05-15 17:53 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
DataConfirmStatusService() constructor
DataConfirmStatusService(ConcurrentHashMap<DataNode,Map<String,DataNode>> expectNodes, BlockingQueue<NodeOperator> expectNodesOrders) constructor

方法概要

限定符和类型	方法和说明
SnapshotProcess	copy()
Queue<NodeOperator>	getAllConfirmNodes()
Map<String,DataNode>	getExpectNodes(DataNode confirmNode)
Set<String>	getSnapshotFileNames()
boolean	load(String path)
NodeOperator<DataNode>	peekConfirmNode()
NodeOperator<DataNode>	pollConfirmNode()
void	putConfirmNode(DataNode node, DataOperator nodeOperate)
Map<String,DataNode>	putExpectNodes(DataNode confirmNode, Map<String,DataNode> addNodes)
Map<String,DataNode>	removeExpectConfirmNodes(DataNode confirmNode, Collection<String> ips)
Map<String,DataNode>	removeExpectNodes(DataNode confirmNode)
boolean	save(String path)

从类继承的方法 com.alipay.sofa.registry.jraft.processor.AbstractSnapshotProcess

load, save

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

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

构造器详细资料

DataConfirmStatusService

public DataConfirmStatusService()

constructor

DataConfirmStatusService

public DataConfirmStatusService(ConcurrentHashMap<DataNode,Map<String,DataNode>> expectNodes,
                                BlockingQueue<NodeOperator> expectNodesOrders)

constructor

参数:

expectNodes -

expectNodesOrders -

方法详细资料

copy

public SnapshotProcess copy()

指定者:

copy 在接口中 SnapshotProcess

putConfirmNode

public void putConfirmNode(DataNode node,
                           DataOperator nodeOperate)

指定者:

putConfirmNode 在接口中 NodeConfirmStatusService<DataNode>

peekConfirmNode

public NodeOperator<DataNode> peekConfirmNode()

指定者:

peekConfirmNode 在接口中 NodeConfirmStatusService<DataNode>

pollConfirmNode

public NodeOperator<DataNode> pollConfirmNode()
                                       throws InterruptedException

指定者:

pollConfirmNode 在接口中 NodeConfirmStatusService<DataNode>

抛出:

InterruptedException

getAllConfirmNodes

public Queue<NodeOperator> getAllConfirmNodes()

指定者:

getAllConfirmNodes 在接口中 NodeConfirmStatusService<DataNode>

putExpectNodes

public Map<String,DataNode> putExpectNodes(DataNode confirmNode,
                                           Map<String,DataNode> addNodes)

指定者:

putExpectNodes 在接口中 NodeConfirmStatusService<DataNode>

getExpectNodes

public Map<String,DataNode> getExpectNodes(DataNode confirmNode)

指定者:

getExpectNodes 在接口中 NodeConfirmStatusService<DataNode>

removeExpectConfirmNodes

public Map<String,DataNode> removeExpectConfirmNodes(DataNode confirmNode,
                                                     Collection<String> ips)

指定者:

removeExpectConfirmNodes 在接口中 NodeConfirmStatusService<DataNode>

removeExpectNodes

public Map<String,DataNode> removeExpectNodes(DataNode confirmNode)

指定者:

removeExpectNodes 在接口中 NodeConfirmStatusService<DataNode>

save

public boolean save(String path)

指定者:

save 在接口中 SnapshotProcess

load

public boolean load(String path)

指定者:

load 在接口中 SnapshotProcess

getSnapshotFileNames

public Set<String> getSnapshotFileNames()

指定者:

getSnapshotFileNames 在接口中 SnapshotProcess