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

类 SessionConfirmStatusService

java.lang.Object

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

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

所有已实现的接口:

SnapshotProcess, NodeConfirmStatusService<SessionNode>

public class SessionConfirmStatusService
extends AbstractSnapshotProcess
implements NodeConfirmStatusService<SessionNode>

版本:

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

作者:

shangyu.wh

构造器概要

构造器

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

方法概要

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

构造器详细资料

SessionConfirmStatusService

public SessionConfirmStatusService()

constructor

SessionConfirmStatusService

public SessionConfirmStatusService(ConcurrentHashMap<SessionNode,Map<String,SessionNode>> expectNodes,
                                   BlockingQueue<NodeOperator> expectNodesOrders)

constructor

参数:

expectNodes -

expectNodesOrders -

方法详细资料

copy

public SnapshotProcess copy()

指定者:

copy 在接口中 SnapshotProcess

putConfirmNode

public void putConfirmNode(SessionNode node,
                           DataOperator nodeOperate)

指定者:

putConfirmNode 在接口中 NodeConfirmStatusService<SessionNode>

peekConfirmNode

public NodeOperator<SessionNode> peekConfirmNode()

指定者:

peekConfirmNode 在接口中 NodeConfirmStatusService<SessionNode>

pollConfirmNode

public NodeOperator<SessionNode> pollConfirmNode()
                                          throws InterruptedException

指定者:

pollConfirmNode 在接口中 NodeConfirmStatusService<SessionNode>

抛出:

InterruptedException

getAllConfirmNodes

public Queue<NodeOperator> getAllConfirmNodes()

指定者:

getAllConfirmNodes 在接口中 NodeConfirmStatusService<SessionNode>

putExpectNodes

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

指定者:

putExpectNodes 在接口中 NodeConfirmStatusService<SessionNode>

getExpectNodes

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

指定者:

getExpectNodes 在接口中 NodeConfirmStatusService<SessionNode>

removeExpectNodes

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

指定者:

removeExpectNodes 在接口中 NodeConfirmStatusService<SessionNode>

removeExpectConfirmNodes

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

指定者:

removeExpectConfirmNodes 在接口中 NodeConfirmStatusService<SessionNode>

save

public boolean save(String path)

指定者:

save 在接口中 SnapshotProcess

load

public boolean load(String path)

指定者:

load 在接口中 SnapshotProcess

getSnapshotFileNames

public Set<String> getSnapshotFileNames()

指定者:

getSnapshotFileNames 在接口中 SnapshotProcess