public interface NodeConfirmStatusService<T extends Node>
| 限定符和类型 | 方法和说明 |
|---|---|
Queue<NodeOperator> |
getAllConfirmNodes() |
Map<String,T> |
getExpectNodes(T confirmNode) |
NodeOperator<T> |
peekConfirmNode() |
NodeOperator<T> |
pollConfirmNode() |
void |
putConfirmNode(T node,
DataOperator nodeOperate) |
Map<String,T> |
putExpectNodes(T confirmNode,
Map<String,T> addNodes) |
Map<String,T> |
removeExpectConfirmNodes(T confirmNode,
Collection<String> ips) |
Map<String,T> |
removeExpectNodes(T confirmNode) |
void putConfirmNode(T node, DataOperator nodeOperate)
NodeOperator<T> peekConfirmNode()
NodeOperator<T> pollConfirmNode() throws InterruptedException
Queue<NodeOperator> getAllConfirmNodes()
Copyright © 2019 The Ant Financial. All rights reserved.