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();

Reply via email to