This is an automated email from the ASF dual-hosted git repository.
dongeforever pushed a change to branch feature_acl
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 4915871 Expose the rpc hook
add 9e0021d acl-plug rudimentary model
add 7a03020 accomplish
add 994e29d add unit test
add 62e65d6 ad unit test
add 77b9bc0 solve conflict
add 7c2b40c save
add 693243e finishing
add 94f36e2 slove rat exception
add a1a4616 slove rat exception
add 1e3c184 clear
add f2dcde9 clean
add da09320 clean Attention: delete line 37 of the MixAllTest.java
add 3aa4359 CI No environment
add a3b9480 CI No environment
add 81560c1 CI No environment
add d360f8b CI No environment 1
add b5cf8bc CI No environment 2
add eebb299 CI No environment 3
add bd6f34d CI No environment 3
add f691013 CI No environment 4
add 45343af CI No environment 5
add eeab571 CI no environment 6
add e2c3eaa CI no environment
add dba3bad CI no environment 7
add d6d1583 CI no environment 9
add 56f81dd CI no environment 9
add aea7461 Merge branch 'feature_acl' into develop-acl
new 76ab7bd Merge pull request #485 from githublaohu/develop-acl
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
acl-plug/pom.xml | 52 ++
.../rocketmq/acl/plug/AccessContralAnalysis.java | 84 +++
.../rocketmq/acl/plug/AclPlugController.java | 59 ++
.../rocketmq/acl/plug/AclRemotingService.java | 10 +-
.../org/apache/rocketmq/acl/plug/AclUtils.java | 82 +++
.../apache/rocketmq/acl/plug/Authentication.java | 59 ++
.../acl/plug/DefaultAclRemotingServiceImpl.java | 44 ++
.../rocketmq/acl/plug/engine/AclPlugEngine.java | 29 +-
.../AuthenticationInfoManagementAclPlugEngine.java | 139 +++++
.../acl/plug/engine/LoginInfoAclPlugEngine.java | 65 ++
.../acl/plug/engine/PlainAclPlugEngine.java | 59 ++
.../rocketmq/acl/plug/entity/AccessControl.java | 93 +++
.../acl/plug/entity/AuthenticationInfo.java | 80 +++
.../acl/plug/entity/AuthenticationResult.java | 48 +-
.../acl/plug/entity/BorkerAccessControl.java | 663 +++++++++++++++++++++
.../plug/entity/BorkerAccessControlTransport.java | 36 +-
.../acl/plug/entity/ControllerParameters.java | 51 ++
.../apache/rocketmq/acl/plug/entity/LoginInfo.java | 82 +++
.../plug/exception/AclPlugRuntimeException.java | 12 +-
.../acl/plug/strategy/NetaddressStrategy.java | 10 +-
.../plug/strategy/NetaddressStrategyFactory.java | 160 +++++
.../acl/plug/AccessContralAnalysisTest.java | 63 ++
.../rocketmq/acl/plug/AclPlugControllerTest.java | 4 +-
.../org/apache/rocketmq/acl/plug/AclUtilsTest.java | 129 ++++
.../rocketmq/acl/plug/AuthenticationTest.java | 141 +++++
.../acl/plug/engine/PlainAclPlugEngineTest.java | 291 +++++++++
.../acl/plug/strategy/NetaddressStrategyTest.java | 202 +++++++
.../src/test/resources/conf/transport.yml | 26 +-
broker/pom.xml | 34 +-
.../apache/rocketmq/broker/BrokerController.java | 56 ++
.../broker/client/ClientHousekeepingService.java | 3 +
.../org/apache/rocketmq/common/BrokerConfig.java | 31 +-
.../rocketmq/common/constant/LoggerName.java | 1 +
.../org/apache/rocketmq/common/MixAllTest.java | 3 +-
distribution/conf/broker.conf | 2 +
distribution/conf/{broker.conf => transport.yml} | 26 +-
.../rocketmq/example/simple/PullConsumer.java | 4 +-
.../rocketmq/example/simple/PullConsumerTest.java | 1 +
pom.xml | 11 +-
39 files changed, 2825 insertions(+), 120 deletions(-)
create mode 100644 acl-plug/pom.xml
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AccessContralAnalysis.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclPlugController.java
copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java
=> acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclRemotingService.java
(75%)
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/AclUtils.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/Authentication.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/DefaultAclRemotingServiceImpl.java
copy
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionStore.java
=>
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/engine/AclPlugEngine.java
(56%)
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/engine/AuthenticationInfoManagementAclPlugEngine.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/engine/LoginInfoAclPlugEngine.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/engine/PlainAclPlugEngine.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/AccessControl.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/AuthenticationInfo.java
copy
common/src/main/java/org/apache/rocketmq/common/protocol/body/Connection.java
=>
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/AuthenticationResult.java
(50%)
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/BorkerAccessControl.java
copy client/src/main/java/org/apache/rocketmq/client/QueryResult.java =>
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/BorkerAccessControlTransport.java
(55%)
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/ControllerParameters.java
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/entity/LoginInfo.java
copy
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java
=>
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/exception/AclPlugRuntimeException.java
(73%)
copy common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java
=>
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/strategy/NetaddressStrategy.java
(80%)
create mode 100644
acl-plug/src/main/java/org/apache/rocketmq/acl/plug/strategy/NetaddressStrategyFactory.java
create mode 100644
acl-plug/src/test/java/org/apache/rocketmq/acl/plug/AccessContralAnalysisTest.java
copy
client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java =>
acl-plug/src/test/java/org/apache/rocketmq/acl/plug/AclPlugControllerTest.java
(91%)
create mode 100644
acl-plug/src/test/java/org/apache/rocketmq/acl/plug/AclUtilsTest.java
create mode 100644
acl-plug/src/test/java/org/apache/rocketmq/acl/plug/AuthenticationTest.java
create mode 100644
acl-plug/src/test/java/org/apache/rocketmq/acl/plug/engine/PlainAclPlugEngineTest.java
create mode 100644
acl-plug/src/test/java/org/apache/rocketmq/acl/plug/strategy/NetaddressStrategyTest.java
copy distribution/conf/broker.conf =>
acl-plug/src/test/resources/conf/transport.yml (72%)
copy distribution/conf/{broker.conf => transport.yml} (70%)
