org.apache.shenyu.sync.data.apollo

Class ApolloDataService

java.lang.Object

org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService

org.apache.shenyu.sync.data.apollo.ApolloDataService

All Implemented Interfaces:

java.lang.AutoCloseable, org.apache.shenyu.sync.data.api.SyncDataService

public class ApolloDataService
extends org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService
implements org.apache.shenyu.sync.data.api.SyncDataService

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService

org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService.ChangeData

Constructor Summary

Constructors

Constructor and Description

ApolloDataService(com.ctrip.framework.apollo.Config configService, org.apache.shenyu.sync.data.api.PluginDataSubscriber pluginDataSubscriber, java.util.List<org.apache.shenyu.sync.data.api.MetaDataSubscriber> metaDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.AuthDataSubscriber> authDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.ProxySelectorDataSubscriber> proxySelectorDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.DiscoveryUpstreamDataSubscriber> discoveryUpstreamDataSubscribers) Instantiates a new Nacos sync data service.

Method Summary

Modifier and Type	Method and Description
void	close() close.
protected void	doRemoveListener(java.lang.String key)
protected java.lang.String	getServiceConfig(java.lang.String key, java.util.function.Consumer<java.lang.String> updateHandler, java.util.function.Consumer<java.lang.String> deleteHandler)

Methods inherited from class org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService

cacheAuthData, cacheDiscoveryUpstreamData, cacheMetaData, cachePluginData, cacheProxySelectorData, cacheRuleData, cacheSelectorData, startWatch, unCacheAuthData, unCacheDiscoveryUpstreamData, unCacheMetaData, unCachePluginData, unCacheProxySelectorData, unCacheRuleData, unCacheSelectorData

Methods inherited from class java.lang.Object

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

Constructor Detail

ApolloDataService

public ApolloDataService(com.ctrip.framework.apollo.Config configService,
                         org.apache.shenyu.sync.data.api.PluginDataSubscriber pluginDataSubscriber,
                         java.util.List<org.apache.shenyu.sync.data.api.MetaDataSubscriber> metaDataSubscribers,
                         java.util.List<org.apache.shenyu.sync.data.api.AuthDataSubscriber> authDataSubscribers,
                         java.util.List<org.apache.shenyu.sync.data.api.ProxySelectorDataSubscriber> proxySelectorDataSubscribers,
                         java.util.List<org.apache.shenyu.sync.data.api.DiscoveryUpstreamDataSubscriber> discoveryUpstreamDataSubscribers)

Instantiates a new Nacos sync data service.

Parameters:

configService - the config service

pluginDataSubscriber - the plugin data subscriber

metaDataSubscribers - the meta data subscribers

authDataSubscribers - the auth data subscribers

Method Detail

doRemoveListener

protected void doRemoveListener(java.lang.String key)

Specified by:

doRemoveListener in class org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService

getServiceConfig

protected java.lang.String getServiceConfig(java.lang.String key,
                                            java.util.function.Consumer<java.lang.String> updateHandler,
                                            java.util.function.Consumer<java.lang.String> deleteHandler)

Specified by:

getServiceConfig in class org.apache.shenyu.sync.data.core.AbstractNodeDataSyncService

close

public void close()

close.

Specified by:

close in interface java.lang.AutoCloseable