程序包 org.apache.dubbo.registry.xds.util.protocol

类 AbstractProtocol<T,S extends DeltaResource<T>>

java.lang.Object

org.apache.dubbo.registry.xds.util.protocol.AbstractProtocol<T,S>

所有已实现的接口:

XdsProtocol<T>

直接已知子类:

EdsProtocol, LdsProtocol, RdsProtocol

public abstract class AbstractProtocol<T,S extends DeltaResource<T>>
extends Object
implements XdsProtocol<T>

构造器概要

构造器

构造器	说明
AbstractProtocol(XdsChannel xdsChannel, io.envoyproxy.envoy.config.core.v3.Node node, int pollingPoolSize, int pollingTimeout)

方法概要

修饰符和类型	方法	说明
T	getResource(Set<String> resourceNames)	Gets all resource by the specified resource name.
abstract String	getTypeUrl()	Abstract method to obtain Type-URL from sub-class
long	observeResource(Set<String> resourceNames, Consumer<T> consumer)	Add a observer resource with Consumer
void	updateObserve(long request, Set<String> resourceNames)	Update observed resource list in XdsProtocol.observeResource(Set, Consumer)

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

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

构造器详细资料

AbstractProtocol

public AbstractProtocol(XdsChannel xdsChannel,
                        io.envoyproxy.envoy.config.core.v3.Node node,
                        int pollingPoolSize,
                        int pollingTimeout)

方法详细资料

getTypeUrl

public abstract String getTypeUrl()

Abstract method to obtain Type-URL from sub-class

返回:

Type-URL of xDS

getResource

public T getResource(Set<String> resourceNames)

从接口复制的说明: XdsProtocol

Gets all resource by the specified resource name. For LDS, the {@param resourceNames} is ignored

指定者:

getResource 在接口中 XdsProtocol<T>

参数:

resourceNames - specified resource name

返回:

resources, null if request failed

observeResource

public long observeResource(Set<String> resourceNames,
                            Consumer<T> consumer)

从接口复制的说明: XdsProtocol

Add a observer resource with Consumer

指定者:

observeResource 在接口中 XdsProtocol<T>

参数:

resourceNames - specified resource name

consumer - resource notifier, will be called when resource updated

返回:

requestId, used when resourceNames update with XdsProtocol.updateObserve(long, Set)

updateObserve

public void updateObserve(long request,
                          Set<String> resourceNames)

从接口复制的说明: XdsProtocol

Update observed resource list in XdsProtocol.observeResource(Set, Consumer)

指定者:

updateObserve 在接口中 XdsProtocol<T>

参数:

request - requestId returned by XdsProtocol.observeResource(Set, Consumer)

resourceNames - new resource name list to observe