Remove unused code

gateway-ha/src/main/java/io/trino/gateway/ha/persistence/dao/ExactMatchSourceSelectors.java

@@ -75,20 +75,4 @@ public static void create(
 
         model.insert();
     }
-
-    /**
-     * Update existing exactMatchSourceSelector.
-     */
-    public static void update(
-            ExactMatchSourceSelectors model, ExactSelectorsDetail exactSelectorsDetail)
-    {
-        model.set(resourceGroupId, exactSelectorsDetail.getResourceGroupId());
-        model.set(updateTime, exactSelectorsDetail.getUpdateTime());
-
-        model.set(source, exactSelectorsDetail.getSource());
-        model.set(environment, exactSelectorsDetail.getEnvironment());
-        model.set(queryType, exactSelectorsDetail.getQueryType());
-
-        model.saveIt();
-    }
 }

gateway-ha/src/main/java/io/trino/gateway/ha/router/TrinoQueueLengthRoutingTable.java

@@ -292,18 +292,6 @@ public Map<String, Integer> getInternalWeightedRoutingTable(String routingGroup)
         return routingTable;
     }
 
-    /**
-     * A convienience method to get a peak into the state of the routing manager.
-     */
-    public Map<String, Integer> getInternalClusterQueueLength(String routingGroup)
-    {
-        if (!clusterQueueLengthMap.containsKey(routingGroup)) {
-            return null;
-        }
-
-        return clusterQueueLengthMap.get(routingGroup);
-    }
-
     /**
      * Find the cluster with least user queue else fall back to overall cluster weight based routing.
      */

gateway-ha/src/main/java/io/trino/gateway/ha/security/AuthorizationManager.java

@@ -37,17 +37,6 @@ public AuthorizationManager(AuthorizationConfiguration configuration,
         }
     }
 
-    /**
-     * Searches in LDAP for what groups a user is member of.
-     *
-     * @param sub claim
-     * @return an optional membersOf for the input user
-     */
-    public Optional<String> searchMemberOf(String sub)
-    {
-        return Optional.empty();
-    }
-
     public Optional<String> getPrivileges(String username)
     {
         //check the preset users

gateway-ha/src/main/java/io/trino/gateway/proxyserver/ProxyHandler.java

@@ -16,7 +16,6 @@
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import org.eclipse.jetty.client.api.Request;
-import org.eclipse.jetty.http.HttpFields;
 import org.eclipse.jetty.http.HttpHeader;
 import org.eclipse.jetty.util.Callback;
 import org.slf4j.Logger;
@@ -28,7 +27,6 @@
 import java.io.InputStreamReader;
 import java.nio.charset.Charset;
 import java.util.Arrays;
-import java.util.Collection;
 import java.util.Enumeration;
 import java.util.zip.GZIPInputStream;
 
@@ -83,26 +81,6 @@ protected void debugLogHeaders(HttpServletRequest request)
         }
     }
 
-    protected void debugLogHeaders(HttpServletResponse response)
-    {
-        if (log.isDebugEnabled()) {
-            log.debug("-------HttpServletResponse headers---------");
-            Collection<String> headers = response.getHeaderNames();
-            for (String header : headers) {
-                log.debug(header + "->" + response.getHeader(header));
-            }
-        }
-    }
-
-    protected void debugLogHeaders(Request proxyRequest)
-    {
-        if (log.isDebugEnabled()) {
-            log.debug("-------Request proxyRequest headers---------");
-            HttpFields httpFields = proxyRequest.getHeaders();
-            log.debug(httpFields.toString());
-        }
-    }
-
     protected boolean isGZipEncoding(HttpServletResponse response)
     {
         String contentEncoding = response.getHeader(HttpHeader.CONTENT_ENCODING.toString());

gateway-ha/src/main/java/io/trino/gateway/proxyserver/ProxyServer.java

@@ -14,7 +14,6 @@
 package io.trino.gateway.proxyserver;
 
 import jakarta.servlet.DispatcherType;
-import jakarta.servlet.Filter;
 import org.eclipse.jetty.http.HttpScheme;
 import org.eclipse.jetty.proxy.ConnectHandler;
 import org.eclipse.jetty.server.HttpConfiguration;
@@ -130,11 +129,6 @@ private void setupContext(ProxyServerConfiguration config)
         this.context.addFilter(RequestFilter.class, "/*", EnumSet.allOf(DispatcherType.class));
     }
 
-    public void addFilter(Class<? extends Filter> filterClass, String pathSpec)
-    {
-        this.context.addFilter(filterClass, pathSpec, EnumSet.allOf(DispatcherType.class));
-    }
-
     public void start()
     {
         try {

gateway-ha/src/test/java/io/trino/gateway/ha/security/TestLbFilter.java

@@ -61,9 +61,6 @@ public void setup()
 
         // Set authorization manager with membership
         authorizationManager = Mockito.mock(AuthorizationManager.class);
-        Mockito
-                .when(authorizationManager.searchMemberOf(USER))
-                .thenReturn(MEMBER_OF);
         Mockito
                 .when(authorizationManager.getPrivileges(USER))
                 .thenReturn(MEMBER_OF);