程序包 com.alibaba.csp.sentinel.slots.clusterbuilder

类 ClusterBuilderSlot

java.lang.Object

com.alibaba.csp.sentinel.slotchain.AbstractLinkedProcessorSlot<DefaultNode>

com.alibaba.csp.sentinel.slots.clusterbuilder.ClusterBuilderSlot

所有已实现的接口:

ProcessorSlot<DefaultNode>

@Spi(isSingleton=false,
     order=-9000)
public class ClusterBuilderSlot
extends AbstractLinkedProcessorSlot<DefaultNode>

This slot maintains resource running statistics (response time, qps, thread count, exception), and a list of callers as well which is marked by ContextUtil.enter(String origin)

One resource has only one cluster node, while one resource can have multiple default nodes.

作者:

jialiang.linjl

构造器概要

构造器

构造器	说明
ClusterBuilderSlot()

方法概要

修饰符和类型	方法	说明
void	entry(Context context, ResourceWrapper resourceWrapper, DefaultNode node, int count, boolean prioritized, Object... args)	Entrance of this slot.
void	exit(Context context, ResourceWrapper resourceWrapper, int count, Object... args)	Exit of this slot.
static ClusterNode	getClusterNode(String id)	Get ClusterNode of the resource name.
static ClusterNode	getClusterNode(String id, EntryType type)	Get ClusterNode of the resource of the specific type.
static Map<ResourceWrapper,ClusterNode>	getClusterNodeMap()	Get ClusterNodes map, this map holds all ClusterNodes, it's key is resource name, value is the related ClusterNode.
static void	resetClusterNodes()	Reset all ClusterNodes.

从类继承的方法 com.alibaba.csp.sentinel.slotchain.AbstractLinkedProcessorSlot

fireEntry, fireExit, getNext, setNext

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

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

构造器详细资料

ClusterBuilderSlot

public ClusterBuilderSlot()

方法详细资料

entry

public void entry(Context context,
 ResourceWrapper resourceWrapper,
 DefaultNode node,
 int count,
 boolean prioritized,
 Object... args)
           throws Throwable

从接口复制的说明: ProcessorSlot

Entrance of this slot.

参数:

context - current Context

resourceWrapper - current resource

node - generics parameter, usually is a Node

count - tokens needed

prioritized - whether the entry is prioritized

args - parameters of the original call

抛出:

Throwable - blocked exception or unexpected error

exit

public void exit(Context context,
 ResourceWrapper resourceWrapper,
 int count,
 Object... args)

从接口复制的说明: ProcessorSlot

Exit of this slot.

参数:

context - current Context

resourceWrapper - current resource

count - tokens needed

args - parameters of the original call

getClusterNode

public static ClusterNode getClusterNode(String id,
 EntryType type)

Get ClusterNode of the resource of the specific type.

参数:

id - resource name.

type - invoke type.

返回:

the ClusterNode

getClusterNode

public static ClusterNode getClusterNode(String id)

Get ClusterNode of the resource name.

参数:

id - resource name.

返回:

the ClusterNode.

getClusterNodeMap

public static Map<ResourceWrapper,ClusterNode> getClusterNodeMap()

Get ClusterNodes map, this map holds all ClusterNodes, it's key is resource name, value is the related ClusterNode.
DO NOT MODIFY the map returned.

返回:

all ClusterNodes

resetClusterNodes

public static void resetClusterNodes()

Reset all ClusterNodes. Reset is needed when IntervalProperty.INTERVAL or SampleCountProperty.SAMPLE_COUNT is changed.