This is an automated email from the ASF dual-hosted git repository.
abhay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ranger.git
The following commit(s) were added to refs/heads/master by this push:
new 245de9179 RANGER-4009:Open read access to some Policy Engine objects
and metrics
245de9179 is described below
commit 245de9179b0a3270adcbc20f9cb128ea7dd79e49
Author: Abhay Kulkarni <[email protected]>
AuthorDate: Fri Dec 9 11:15:17 2022 -0800
RANGER-4009:Open read access to some Policy Engine objects and metrics
---
.../plugin/policyengine/RangerPolicyEngineImpl.java | 6 +++++-
.../plugin/policyengine/RangerPolicyRepository.java | 16 ++++++++++++++++
.../apache/ranger/plugin/service/RangerBasePlugin.java | 4 ++++
3 files changed, 25 insertions(+), 1 deletion(-)
diff --git
a/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyEngineImpl.java
b/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyEngineImpl.java
index 8d80ad6a3..4f65d3da2 100644
---
a/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyEngineImpl.java
+++
b/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyEngineImpl.java
@@ -599,10 +599,14 @@ public class RangerPolicyEngineImpl implements
RangerPolicyEngine {
return ret;
}
- PolicyEngine getPolicyEngine() {
+ public PolicyEngine getPolicyEngine() {
return policyEngine;
}
+ public RangerAccessRequestProcessor getRequestProcessor() {
+ return requestProcessor;
+ }
+
private RangerPolicyEngineImpl(final PolicyEngine policyEngine,
RangerPolicyEngineImpl other) {
this.policyEngine = policyEngine;
this.requestProcessor = new
RangerDefaultRequestProcessor(policyEngine);
diff --git
a/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyRepository.java
b/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyRepository.java
index 85a3afd01..297f5e635 100644
---
a/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyRepository.java
+++
b/agents-common/src/main/java/org/apache/ranger/plugin/policyengine/RangerPolicyRepository.java
@@ -566,6 +566,22 @@ public class RangerPolicyRepository {
return policyEvaluators;
}
+ public int getPolicyEvaluatorCount() {
+ return policyEvaluators.size();
+ }
+
+ public int getDataMaskPolicyEvaluatorCount() {
+ return dataMaskPolicyEvaluators.size();
+ }
+
+ public int getRowFilterPolicyEvaluatorCount() {
+ return rowFilterPolicyEvaluators.size();
+ }
+
+ public int getAuditPolicyEvaluatorCount() {
+ return auditPolicyEvaluators.size();
+ }
+
List<RangerPolicyEvaluator> getDataMaskPolicyEvaluators() {
return dataMaskPolicyEvaluators;
}
diff --git
a/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java
b/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java
index ba1467828..b1e2ecbcc 100644
---
a/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java
+++
b/agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBasePlugin.java
@@ -1137,6 +1137,10 @@ public class RangerBasePlugin {
return baseACLs;
}
+ protected RangerPolicyEngine getPolicyEngine() {
+ return policyEngine;
+ }
+
private RangerAdminClient getAdminClient() throws Exception {
PolicyRefresher refresher = this.refresher;
RangerAdminClient admin = refresher == null ? null :
refresher.getRangerAdminClient();