This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 3c6587fe5 [INLONG-7915][Dashboard] Clickhouse sink engine field
optimization (#7916)
add cd429f568 [INLONG-7904][DataProxy] Add blacklist and whitelist
mechanism (#7919)
No new revisions were added by this update.
Summary of changes:
.../inlong/common/enums/DataProxyErrCode.java | 1 +
inlong-dataproxy/bin/dataproxy-start.sh | 2 +-
.../inlong/dataproxy/config/ConfigHolder.java | 9 +-
.../inlong/dataproxy/config/ConfigManager.java | 30 ++++-
.../dataproxy/config/RemoteConfigManager.java | 2 +-
.../dataproxy/config/holder/FileConfigHolder.java | 98 --------------
.../config/holder/GroupIdPropertiesHolder.java | 3 +-
.../config/holder/IPVisitConfigHolder.java | 131 ++++++++++++++++++
.../config/holder/MQClusterConfigHolder.java | 3 +-
.../config/holder/MxPropertiesHolder.java | 3 +-
.../config/holder/PropertiesConfigHolder.java | 3 +-
.../inlong/dataproxy/consts/ConfigConstants.java | 1 +
.../inlong/dataproxy/http/MessageFilter.java | 10 ++
.../dataproxy/source/ServerMessageHandler.java | 71 ++++------
.../dataproxy/source/SimpleMessageHandler.java | 59 +++-----
.../inlong/dataproxy/source/SimpleTcpSource.java | 150 +++++----------------
.../source/tcp/InlongTcpChannelHandler.java | 28 +++-
.../inlong/dataproxy/utils/AddressUtils.java | 43 +++---
.../config/holder/TestIPVisitConfigHolder.java | 21 ++-
.../src/test/resources/blacklist.properties | 1 +
.../src/test/resources/common.properties | 2 +
.../{blacklist.properties => whitelist.properties} | 1 +
22 files changed, 322 insertions(+), 350 deletions(-)
delete mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/FileConfigHolder.java
create mode 100644
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/IPVisitConfigHolder.java
copy
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/OracleSource.java
=>
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/utils/AddressUtils.java
(55%)
copy
inlong-tubemq/tubemq-server/src/test/java/org/apache/inlong/tubemq/server/broker/utils/DataStoreUtilsTest.java
=>
inlong-dataproxy/dataproxy-source/src/test/java/org/apache/inlong/dataproxy/config/holder/TestIPVisitConfigHolder.java
(61%)
copy
inlong-dataproxy/dataproxy-source/src/test/resources/{blacklist.properties =>
whitelist.properties} (98%)