Skip to content

Commit 5ea679f

Browse files
authored
Implement audit log for tree model (apache#16475)
1 parent c73e0c0 commit 5ea679f

File tree

182 files changed

+3251
-1529
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

182 files changed

+3251
-1529
lines changed

example/pipe-count-point-processor/src/main/java/org/apache/iotdb/CountPointProcessor.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,8 @@ public void customize(
5959

6060
@Override
6161
public void process(
62-
final TabletInsertionEvent tabletInsertionEvent, final EventCollector eventCollector) {
62+
final TabletInsertionEvent tabletInsertionEvent, final EventCollector eventCollector)
63+
throws Exception {
6364
tabletInsertionEvent.processTablet(
6465
(tablet, rowCollector) -> writePointCount.addAndGet(tablet.getRowSize()));
6566
}

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppCommonConfig.java

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -627,6 +627,30 @@ public CommonConfig setDatanodeMemoryProportion(String datanodeMemoryProportion)
627627
return this;
628628
}
629629

630+
@Override
631+
public CommonConfig setEnableAuditLog(boolean enableAuditLog) {
632+
setProperty("enable_audit_log", String.valueOf(enableAuditLog));
633+
return this;
634+
}
635+
636+
@Override
637+
public CommonConfig setAuditableOperationType(String auditableOperationType) {
638+
setProperty("auditable_operation_type", auditableOperationType);
639+
return this;
640+
}
641+
642+
@Override
643+
public CommonConfig setAuditableOperationLevel(String auditableOperationLevel) {
644+
setProperty("auditable_operation_level", auditableOperationLevel);
645+
return this;
646+
}
647+
648+
@Override
649+
public CommonConfig setAuditableOperationResult(String auditableOperationResult) {
650+
setProperty("auditable_operation_result", auditableOperationResult);
651+
return this;
652+
}
653+
630654
// For part of the log directory
631655
public String getClusterConfigStr() {
632656
return fromConsensusFullNameToAbbr(properties.getProperty(CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS))

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppSharedCommonConfig.java

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -656,4 +656,32 @@ public CommonConfig setDatanodeMemoryProportion(String datanodeMemoryProportion)
656656
cnConfig.setDatanodeMemoryProportion(datanodeMemoryProportion);
657657
return this;
658658
}
659+
660+
@Override
661+
public CommonConfig setEnableAuditLog(boolean enableAuditLog) {
662+
dnConfig.setEnableAuditLog(enableAuditLog);
663+
cnConfig.setEnableAuditLog(enableAuditLog);
664+
return this;
665+
}
666+
667+
@Override
668+
public CommonConfig setAuditableOperationType(String auditableOperationType) {
669+
dnConfig.setAuditableOperationType(auditableOperationType);
670+
cnConfig.setAuditableOperationType(auditableOperationType);
671+
return this;
672+
}
673+
674+
@Override
675+
public CommonConfig setAuditableOperationLevel(String auditableOperationLevel) {
676+
dnConfig.setAuditableOperationLevel(auditableOperationLevel);
677+
cnConfig.setAuditableOperationLevel(auditableOperationLevel);
678+
return this;
679+
}
680+
681+
@Override
682+
public CommonConfig setAuditableOperationResult(String auditableOperationResult) {
683+
dnConfig.setAuditableOperationResult(auditableOperationResult);
684+
cnConfig.setAuditableOperationResult(auditableOperationResult);
685+
return this;
686+
}
659687
}

integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteCommonConfig.java

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -457,4 +457,24 @@ public CommonConfig setTrustStorePwd(String trustStorePwd) {
457457
public CommonConfig setDatanodeMemoryProportion(String datanodeMemoryProportion) {
458458
return this;
459459
}
460+
461+
@Override
462+
public CommonConfig setEnableAuditLog(boolean enableAuditLog) {
463+
return this;
464+
}
465+
466+
@Override
467+
public CommonConfig setAuditableOperationType(String auditableOperationType) {
468+
return this;
469+
}
470+
471+
@Override
472+
public CommonConfig setAuditableOperationLevel(String auditableOperationLevel) {
473+
return this;
474+
}
475+
476+
@Override
477+
public CommonConfig setAuditableOperationResult(String auditableOperationResult) {
478+
return this;
479+
}
460480
}

integration-test/src/main/java/org/apache/iotdb/itbase/env/CommonConfig.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -203,4 +203,12 @@ default CommonConfig setDefaultStorageGroupLevel(int defaultStorageGroupLevel) {
203203
CommonConfig setTrustStorePwd(String trustStorePwd);
204204

205205
CommonConfig setDatanodeMemoryProportion(String datanodeMemoryProportion);
206+
207+
CommonConfig setEnableAuditLog(boolean enableAuditLog);
208+
209+
CommonConfig setAuditableOperationType(String auditableOperationType);
210+
211+
CommonConfig setAuditableOperationLevel(String auditableOperationLevel);
212+
213+
CommonConfig setAuditableOperationResult(String auditableOperationResult);
206214
}

0 commit comments

Comments
 (0)