You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by al...@apache.org on 2022/03/19 04:44:58 UTC

[incubator-linkis] 03/07: add isAdmin method

This is an automated email from the ASF dual-hosted git repository.

alexkun pushed a commit to branch dev-1.1.1
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git

commit 0cc7d14aad00c9ce3140db7bbb55163e795bc2d7
Author: peacewong <wp...@gmail.com>
AuthorDate: Fri Mar 18 16:02:48 2022 +0800

    add isAdmin method
---
 .../main/scala/org/apache/linkis/common/conf/Configuration.scala    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/conf/Configuration.scala b/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/conf/Configuration.scala
index 4948bfa..65ba753 100644
--- a/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/conf/Configuration.scala
+++ b/linkis-commons/linkis-common/src/main/scala/org/apache/linkis/common/conf/Configuration.scala
@@ -47,6 +47,12 @@ object Configuration extends Logging {
 
   val GOVERNANCE_STATION_ADMIN = CommonVars("wds.linkis.governance.station.admin", "hadoop")
 
+  private val adminUsers = GOVERNANCE_STATION_ADMIN.getValue.split(",")
+
+  def isAdmin(username: String): Boolean = {
+    adminUsers.exists(username.equalsIgnoreCase)
+  }
+
   def getGateWayURL(): String = {
     val url = GATEWAY_URL.getValue.trim
     val gatewayUr = if (url.endsWith("/")) {

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org