This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from b9b509c [INLONG-2187] support audit view (#2222)
add cfd4fe1 [INLONG-2220] move dataproxy-sdk to inlong-sdk (#2221)
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/bug-report.yml | 2 +-
.github/ISSUE_TEMPLATE/improve-request.yml | 2 +-
.github/labeler.yml | 7 ++++++-
.../inlong/agent/plugin/sinks/SenderManager.java | 8 ++++----
.../dataproxy-sdk}/pom.xml | 2 +-
.../inlong/sdk}/dataproxy/ConfigConstants.java | 2 +-
.../sdk}/dataproxy/DefaultMessageSender.java | 22 +++++++++++-----------
.../apache/inlong/sdk}/dataproxy/FileCallback.java | 2 +-
.../inlong/sdk}/dataproxy/MessageSender.java | 4 ++--
.../sdk}/dataproxy/MessageSenderFactory.java | 2 +-
.../inlong/sdk}/dataproxy/ProxyClientConfig.java | 6 +++---
.../inlong/sdk}/dataproxy/SendMessageCallback.java | 2 +-
.../apache/inlong/sdk}/dataproxy/SendResult.java | 2 +-
.../inlong/sdk}/dataproxy/codec/EncodeObject.java | 4 ++--
.../inlong/sdk}/dataproxy/codec/ErrorCode.java | 2 +-
.../sdk}/dataproxy/codec/ProtocolDecoder.java | 2 +-
.../sdk}/dataproxy/codec/ProtocolEncoder.java | 16 ++++++++--------
.../sdk}/dataproxy/config/EncryptConfigEntry.java | 4 ++--
.../inlong/sdk}/dataproxy/config/EncryptInfo.java | 2 +-
.../inlong/sdk}/dataproxy/config/HostInfo.java | 2 +-
.../sdk}/dataproxy/config/ProxyConfigEntry.java | 2 +-
.../sdk}/dataproxy/config/ProxyConfigManager.java | 12 ++++++------
.../apache/inlong/sdk}/dataproxy/demo/Event.java | 2 +-
.../inlong/sdk}/dataproxy/demo/MyFileCallBack.java | 8 ++++----
.../sdk}/dataproxy/demo/MyMessageCallBack.java | 8 ++++----
.../inlong/sdk}/dataproxy/demo/SendMsgThread.java | 6 +++---
.../sdk}/dataproxy/http/InternalHttpSender.java | 14 +++++++-------
.../sdk}/dataproxy/metric/MessageRecord.java | 2 +-
.../dataproxy/metric/MetricTimeNumSummary.java | 2 +-
.../sdk}/dataproxy/network/ClientHandler.java | 4 ++--
.../inlong/sdk}/dataproxy/network/ClientMgr.java | 16 ++++++++--------
.../dataproxy/network/ClientPipelineFactory.java | 6 +++---
.../inlong/sdk}/dataproxy/network/HttpMessage.java | 4 ++--
.../sdk}/dataproxy/network/HttpProxySender.java | 18 +++++++++---------
.../inlong/sdk}/dataproxy/network/NettyClient.java | 6 +++---
.../sdk}/dataproxy/network/ProxysdkException.java | 2 +-
.../inlong/sdk}/dataproxy/network/QueueObject.java | 4 ++--
.../inlong/sdk}/dataproxy/network/Sender.java | 21 +++++++++++----------
.../sdk}/dataproxy/network/SequentialID.java | 2 +-
.../dataproxy/network/SyncMessageCallable.java | 6 +++---
.../sdk}/dataproxy/network/TimeScanObject.java | 2 +-
.../inlong/sdk}/dataproxy/network/Utils.java | 2 +-
.../sdk}/dataproxy/threads/IndexCollectThread.java | 2 +-
.../dataproxy/threads/ManagerFetcherThread.java | 6 +++---
.../sdk}/dataproxy/threads/MetricWorkerThread.java | 20 ++++++++++----------
.../sdk}/dataproxy/threads/TimeoutScanThread.java | 14 +++++++-------
.../sdk}/dataproxy/utils/ConcurrentHashSet.java | 2 +-
.../inlong/sdk}/dataproxy/utils/EncryptUtil.java | 2 +-
.../inlong/sdk}/dataproxy/utils/MapBackedSet.java | 2 +-
.../inlong/sdk}/dataproxy/utils/ProxyUtils.java | 6 +++---
.../dataproxy/utils/ServiceDiscoveryUtils.java | 10 +++++-----
.../org/apache/inlong/sdk}/dataproxy/AppTest.java | 2 +-
.../sdk}/dataproxy/TestMetricWorkerThread.java | 6 +++---
inlong-sdk/pom.xml | 1 +
inlong-sdk/sort-sdk/pom.xml | 2 +-
.../sort-standalone-source/pom.xml | 2 +-
pom.xml | 1 -
57 files changed, 164 insertions(+), 158 deletions(-)
rename {inlong-dataproxy-sdk => inlong-sdk/dataproxy-sdk}/pom.xml (98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/ConfigConstants.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/DefaultMessageSender.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/FileCallback.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/MessageSender.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/MessageSenderFactory.java
(95%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/ProxyClientConfig.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/SendMessageCallback.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/SendResult.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/codec/EncodeObject.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/codec/ErrorCode.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/codec/ProtocolDecoder.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/codec/ProtocolEncoder.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/config/EncryptConfigEntry.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/config/EncryptInfo.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/config/HostInfo.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/config/ProxyConfigEntry.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/config/ProxyConfigManager.java
(99%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/demo/Event.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/demo/MyFileCallBack.java
(89%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/demo/MyMessageCallBack.java
(89%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/demo/SendMsgThread.java
(94%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/http/InternalHttpSender.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/metric/MessageRecord.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/metric/MetricTimeNumSummary.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/ClientHandler.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/ClientMgr.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/ClientPipelineFactory.java
(91%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/HttpMessage.java
(94%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/HttpProxySender.java
(93%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/NettyClient.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/ProxysdkException.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/QueueObject.java
(95%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/Sender.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/SequentialID.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/SyncMessageCallable.java
(93%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/TimeScanObject.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/network/Utils.java
(99%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/threads/IndexCollectThread.java
(98%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/threads/ManagerFetcherThread.java
(93%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/threads/MetricWorkerThread.java
(95%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/threads/TimeoutScanThread.java
(94%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/utils/ConcurrentHashSet.java
(96%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/utils/EncryptUtil.java
(99%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/utils/MapBackedSet.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/utils/ProxyUtils.java
(97%)
rename {inlong-dataproxy-sdk/src/main/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk}/dataproxy/utils/ServiceDiscoveryUtils.java
(97%)
rename {inlong-dataproxy-sdk/src/test/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk}/dataproxy/AppTest.java
(97%)
rename {inlong-dataproxy-sdk/src/test/java/org/apache/inlong =>
inlong-sdk/dataproxy-sdk/src/test/java/org/apache/inlong/sdk}/dataproxy/TestMetricWorkerThread.java
(92%)