Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Pipe: Implemented new config receiver for new permission #14775

Draft
wants to merge 22 commits into
base: master
Choose a base branch
from
Draft

Pipe: Implemented new config receiver for new permission #14775

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
2324702
Update IoTDBConfigNodeReceiver.java
Caideyipi Jan 25, 2025
dc26311
Update IoTDBConfigNodeReceiver.java
Caideyipi Jan 25, 2025
19860c1
Update IoTDBConfigNodeReceiver.java
Caideyipi Jan 25, 2025
23489a4
Update IoTDBConfigNodeReceiver.java
Caideyipi Jan 25, 2025
c17b3da
Update ConfigPhysicalPlanVisitor.java
Caideyipi Jan 25, 2025
f834cb5
Update ConfigPhysicalPlanVisitor.java
Caideyipi Jan 25, 2025
ca605dc
partial
Caideyipi Jan 25, 2025
d44bc50
Update ConfigPhysicalPlanVisitor.java
Caideyipi Jan 25, 2025
48be521
Update ConfigPhysicalPlanVisitor.java
Caideyipi Jan 25, 2025
3ebe1ef
next
Caideyipi Jan 25, 2025
0c7c358
Update PipeConfigPhysicalPlanTreePatternParseVisitor.java
Caideyipi Jan 25, 2025
779ff2f
Update IoTDBConfigNodeReceiver.java
Caideyipi Jan 25, 2025
92ba95d
Merge branch 'master' of https://github.com/apache/iotdb into config-…
Caideyipi Jan 25, 2025
c77c644
Update IoTDBConfigNodeReceiver.java
Caideyipi Jan 25, 2025
990e2f8
Update ConfigRegionListeningFilter.java
Caideyipi Jan 26, 2025
d44f72c
refactor
Caideyipi Jan 26, 2025
2b4e1a4
partial
Caideyipi Jan 26, 2025
375f432
Update IoTDBConfigRegionExtractor.java
Caideyipi Jan 26, 2025
1517867
Fix
Caideyipi Jan 26, 2025
bc142e5
fix
Caideyipi Jan 26, 2025
a3a0334
Fix
Caideyipi Jan 26, 2025
8801b1f
partial
Caideyipi Jan 26, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
220 changes: 196 additions & 24 deletions ...rc/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanVisitor.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,8 @@
package org.apache.iotdb.confignode.consensus.request;

import org.apache.iotdb.confignode.consensus.request.write.auth.AuthorPlan;
import org.apache.iotdb.confignode.consensus.request.write.auth.AuthorRelationalPlan;
import org.apache.iotdb.confignode.consensus.request.write.auth.AuthorTreePlan;
import org.apache.iotdb.confignode.consensus.request.write.database.DatabaseSchemaPlan;
import org.apache.iotdb.confignode.consensus.request.write.database.DeleteDatabasePlan;
import org.apache.iotdb.confignode.consensus.request.write.database.SetTTLPlan;
Expand Down Expand Up @@ -65,29 +67,83 @@ public R process(final ConfigPhysicalPlan plan, final C context) {
case PipeDeactivateTemplate:
return visitPipeDeactivateTemplate((PipeDeactivateTemplatePlan) plan, context);
case CreateRole:
return visitCreateRole((AuthorPlan) plan, context);
return visitCreateRole((AuthorTreePlan) plan, context);
case DropRole:
return visitDropRole((AuthorPlan) plan, context);
return visitDropRole((AuthorTreePlan) plan, context);
case GrantRole:
return visitGrantRole((AuthorPlan) plan, context);
return visitGrantRole((AuthorTreePlan) plan, context);
case RevokeRole:
return visitRevokeRole((AuthorPlan) plan, context);
return visitRevokeRole((AuthorTreePlan) plan, context);
case CreateUser:
return visitCreateUser((AuthorPlan) plan, context);
return visitCreateUser((AuthorTreePlan) plan, context);
case CreateUserWithRawPassword:
return visitCreateRawUser((AuthorPlan) plan, context);
return visitCreateRawUser((AuthorTreePlan) plan, context);
case UpdateUser:
return visitUpdateUser((AuthorPlan) plan, context);
return visitUpdateUser((AuthorTreePlan) plan, context);
case DropUser:
return visitDropUser((AuthorPlan) plan, context);
return visitDropUser((AuthorTreePlan) plan, context);
case GrantUser:
return visitGrantUser((AuthorPlan) plan, context);
return visitGrantUser((AuthorTreePlan) plan, context);
case RevokeUser:
return visitRevokeUser((AuthorPlan) plan, context);
return visitRevokeUser((AuthorTreePlan) plan, context);
case GrantRoleToUser:
return visitGrantRoleToUser((AuthorPlan) plan, context);
return visitGrantRoleToUser((AuthorTreePlan) plan, context);
case RevokeRoleFromUser:
return visitRevokeRoleFromUser((AuthorPlan) plan, context);
return visitRevokeRoleFromUser((AuthorTreePlan) plan, context);
case RCreateUser:
return visitRCreateUser((AuthorRelationalPlan) plan, context);
case RCreateRole:
return visitRCreateRole((AuthorRelationalPlan) plan, context);
case RUpdateUser:
return visitRUpdateUser((AuthorRelationalPlan) plan, context);
case RDropUser:
return visitRDropUserPlan((AuthorRelationalPlan) plan, context);
case RDropRole:
return visitRDropRolePlan((AuthorRelationalPlan) plan, context);
case RGrantUserRole:
return visitRGrantUserRole((AuthorRelationalPlan) plan, context);
case RRevokeUserRole:
return visitRRevokeUserRole((AuthorRelationalPlan) plan, context);
case RGrantUserAny:
return visitRGrantUserAny((AuthorRelationalPlan) plan, context);
case RGrantRoleAny:
return visitRGrantRoleAny((AuthorRelationalPlan) plan, context);
case RGrantUserAll:
return visitRGrantUserAll((AuthorRelationalPlan) plan, context);
case RGrantRoleAll:
return visitRGrantRoleAll((AuthorRelationalPlan) plan, context);
case RGrantUserDBPriv:
return visitRGrantUserDB((AuthorRelationalPlan) plan, context);
case RGrantUserTBPriv:
return visitRGrantUserTB((AuthorRelationalPlan) plan, context);
case RGrantRoleDBPriv:
return visitRGrantRoleDB((AuthorRelationalPlan) plan, context);
case RGrantRoleTBPriv:
return visitRGrantRoleTB((AuthorRelationalPlan) plan, context);
case RRevokeUserAny:
return visitRRevokeUserAny((AuthorRelationalPlan) plan, context);
case RRevokeRoleAny:
return visitRRevokeRoleAny((AuthorRelationalPlan) plan, context);
case RRevokeUserAll:
return visitRRevokeUserAll((AuthorRelationalPlan) plan, context);
case RRevokeRoleAll:
return visitRRevokeRoleAll((AuthorRelationalPlan) plan, context);
case RRevokeUserDBPriv:
return visitRRevokeUserDBPrivilege((AuthorRelationalPlan) plan, context);
case RRevokeUserTBPriv:
return visitRRevokeUserTBPrivilege((AuthorRelationalPlan) plan, context);
case RRevokeRoleDBPriv:
return visitRRevokeRoleDBPrivilege((AuthorRelationalPlan) plan, context);
case RRevokeRoleTBPriv:
return visitRRevokeRoleTBPrivilege((AuthorRelationalPlan) plan, context);
case RGrantUserSysPri:
return visitRGrantUserSysPrivilege((AuthorRelationalPlan) plan, context);
case RGrantRoleSysPri:
return visitRGrantRoleSysPrivilege((AuthorRelationalPlan) plan, context);
case RRevokeUserSysPri:
return visitRRevokeUserSysPrivilege((AuthorRelationalPlan) plan, context);
case RRevokeRoleSysPri:
return visitRRevokeRoleSysPrivilege((AuthorRelationalPlan) plan, context);
case SetTTL:
return visitTTL((SetTTLPlan) plan, context);
case PipeCreateTable:
Expand Down Expand Up @@ -164,54 +220,170 @@ public R visitPipeDeactivateTemplate(
return visitPlan(pipeDeactivateTemplatePlan, context);
}

public R visitCreateUser(final AuthorPlan createUserPlan, final C context) {
public R visitCreateUser(final AuthorTreePlan createUserPlan, final C context) {
return visitPlan(createUserPlan, context);
}

public R visitCreateRawUser(final AuthorPlan createRawUserPlan, final C context) {
public R visitCreateRawUser(final AuthorTreePlan createRawUserPlan, final C context) {
return visitPlan(createRawUserPlan, context);
}

public R visitUpdateUser(final AuthorPlan updateUserPlan, final C context) {
public R visitUpdateUser(final AuthorTreePlan updateUserPlan, final C context) {
return visitPlan(updateUserPlan, context);
}

public R visitDropUser(final AuthorPlan dropUserPlan, final C context) {
public R visitDropUser(final AuthorTreePlan dropUserPlan, final C context) {
return visitPlan(dropUserPlan, context);
}

public R visitGrantUser(final AuthorPlan grantUserPlan, final C context) {
public R visitGrantUser(final AuthorTreePlan grantUserPlan, final C context) {
return visitPlan(grantUserPlan, context);
}

public R visitRevokeUser(final AuthorPlan revokeUserPlan, final C context) {
public R visitRevokeUser(final AuthorTreePlan revokeUserPlan, final C context) {
return visitPlan(revokeUserPlan, context);
}

public R visitCreateRole(final AuthorPlan createRolePlan, final C context) {
public R visitCreateRole(final AuthorTreePlan createRolePlan, final C context) {
return visitPlan(createRolePlan, context);
}

public R visitDropRole(final AuthorPlan dropRolePlan, final C context) {
public R visitDropRole(final AuthorTreePlan dropRolePlan, final C context) {
return visitPlan(dropRolePlan, context);
}

public R visitGrantRole(final AuthorPlan grantRolePlan, final C context) {
public R visitGrantRole(final AuthorTreePlan grantRolePlan, final C context) {
return visitPlan(grantRolePlan, context);
}

public R visitRevokeRole(final AuthorPlan revokeRolePlan, final C context) {
public R visitRevokeRole(final AuthorTreePlan revokeRolePlan, final C context) {
return visitPlan(revokeRolePlan, context);
}

public R visitGrantRoleToUser(final AuthorPlan grantRoleToUserPlan, final C context) {
public R visitGrantRoleToUser(final AuthorTreePlan grantRoleToUserPlan, final C context) {
return visitPlan(grantRoleToUserPlan, context);
}

public R visitRevokeRoleFromUser(final AuthorPlan revokeRoleFromUserPlan, final C context) {
public R visitRevokeRoleFromUser(final AuthorTreePlan revokeRoleFromUserPlan, final C context) {
return visitPlan(revokeRoleFromUserPlan, context);
}

public R visitRCreateUser(final AuthorRelationalPlan rCreateUserPlan, final C context) {
return visitPlan(rCreateUserPlan, context);
}

public R visitRCreateRole(final AuthorRelationalPlan rCreateRolePlan, final C context) {
return visitPlan(rCreateRolePlan, context);
}

public R visitRUpdateUser(final AuthorRelationalPlan rUpdateUserPlan, final C context) {
return visitPlan(rUpdateUserPlan, context);
}

public R visitRDropUserPlan(final AuthorRelationalPlan rDropUserPlan, final C context) {
return visitPlan(rDropUserPlan, context);
}

public R visitRDropRolePlan(final AuthorRelationalPlan rDropRolePlan, final C context) {
return visitPlan(rDropRolePlan, context);
}

public R visitRGrantUserRole(final AuthorRelationalPlan rGrantUserRolePlan, final C context) {
return visitPlan(rGrantUserRolePlan, context);
}

public R visitRRevokeUserRole(final AuthorRelationalPlan rRevokeUserRolePlan, final C context) {
return visitPlan(rRevokeUserRolePlan, context);
}

public R visitRGrantUserAny(final AuthorRelationalPlan rGrantUserAnyPlan, final C context) {
return visitPlan(rGrantUserAnyPlan, context);
}

public R visitRGrantRoleAny(final AuthorRelationalPlan rGrantRoleAnyPlan, final C context) {
return visitPlan(rGrantRoleAnyPlan, context);
}

public R visitRGrantUserAll(final AuthorRelationalPlan rGrantUserAllPlan, final C context) {
return visitPlan(rGrantUserAllPlan, context);
}

public R visitRGrantRoleAll(final AuthorRelationalPlan rGrantRoleAllPlan, final C context) {
return visitPlan(rGrantRoleAllPlan, context);
}

public R visitRGrantUserDB(final AuthorRelationalPlan rGrantUserDBPlan, final C context) {
return visitPlan(rGrantUserDBPlan, context);
}

public R visitRGrantUserTB(final AuthorRelationalPlan rGrantUserTBPlan, final C context) {
return visitPlan(rGrantUserTBPlan, context);
}

public R visitRGrantRoleDB(final AuthorRelationalPlan rGrantRoleDBPlan, final C context) {
return visitPlan(rGrantRoleDBPlan, context);
}

public R visitRGrantRoleTB(final AuthorRelationalPlan rGrantRoleTBPlan, final C context) {
return visitPlan(rGrantRoleTBPlan, context);
}

public R visitRRevokeUserAny(final AuthorRelationalPlan rRevokeUserAnyPlan, final C context) {
return visitPlan(rRevokeUserAnyPlan, context);
}

public R visitRRevokeRoleAny(final AuthorRelationalPlan rRevokeRoleAnyPlan, final C context) {
return visitPlan(rRevokeRoleAnyPlan, context);
}

public R visitRRevokeUserAll(final AuthorRelationalPlan rRevokeUserAllPlan, final C context) {
return visitPlan(rRevokeUserAllPlan, context);
}

public R visitRRevokeRoleAll(final AuthorRelationalPlan rRevokeRoleAllPlan, final C context) {
return visitPlan(rRevokeRoleAllPlan, context);
}

public R visitRRevokeUserDBPrivilege(
final AuthorRelationalPlan rRevokeUserDBPrivilegePlan, final C context) {
return visitPlan(rRevokeUserDBPrivilegePlan, context);
}

public R visitRRevokeUserTBPrivilege(
final AuthorRelationalPlan rRevokeUserTBPrivilegePlan, final C context) {
return visitPlan(rRevokeUserTBPrivilegePlan, context);
}

public R visitRRevokeRoleDBPrivilege(
final AuthorRelationalPlan rRevokeRoleTBPrivilegePlan, final C context) {
return visitPlan(rRevokeRoleTBPrivilegePlan, context);
}

public R visitRRevokeRoleTBPrivilege(
final AuthorRelationalPlan rRevokeRoleTBPrivilegePlan, final C context) {
return visitPlan(rRevokeRoleTBPrivilegePlan, context);
}

public R visitRGrantUserSysPrivilege(
final AuthorRelationalPlan rGrantUserSysPrivilegePlan, final C context) {
return visitPlan(rGrantUserSysPrivilegePlan, context);
}

public R visitRGrantRoleSysPrivilege(
final AuthorPlan rGrantRoleSysPrivilegePlan, final C context) {
return visitPlan(rGrantRoleSysPrivilegePlan, context);
}

public R visitRRevokeUserSysPrivilege(
final AuthorRelationalPlan rRevokeUserSysPrivilegePlan, final C context) {
return visitPlan(rRevokeUserSysPrivilegePlan, context);
}

public R visitRRevokeRoleSysPrivilege(
final AuthorRelationalPlan rRevokeRoleSysPrivilegePlan, final C context) {
return visitPlan(rRevokeRoleSysPrivilegePlan, context);
}

public R visitTTL(final SetTTLPlan setTTLPlan, final C context) {
return visitPlan(setTTLPlan, context);
}
Expand Down
Loading
Loading