Skip to content
This repository has been archived by the owner on May 14, 2022. It is now read-only.

Commit

Permalink
Remove the AgentManagement GRPC/REST endpoints in TitusGateway (#1173)
Browse files Browse the repository at this point in the history
  • Loading branch information
tbak authored Nov 15, 2021
1 parent 212566b commit 55bc031
Show file tree
Hide file tree
Showing 14 changed files with 0 additions and 423 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -21,13 +21,10 @@
import com.google.inject.AbstractModule;
import com.google.inject.Provides;
import com.netflix.archaius.ConfigProxyFactory;
import com.netflix.titus.gateway.endpoint.v3.grpc.DefaultAgentManagementServiceGrpc;
import com.netflix.titus.gateway.endpoint.v3.grpc.DefaultSchedulerServiceGrpc;
import com.netflix.titus.gateway.endpoint.v3.grpc.GrpcEndpointConfiguration;
import com.netflix.titus.gateway.endpoint.v3.grpc.TitusGatewayGrpcServer;
import com.netflix.titus.gateway.eviction.EvictionModule;
import com.netflix.titus.gateway.kubernetes.KubeApiConnector;
import com.netflix.titus.grpc.protogen.AgentManagementServiceGrpc.AgentManagementServiceImplBase;
import com.netflix.titus.grpc.protogen.AutoScalingServiceGrpc;
import com.netflix.titus.grpc.protogen.HealthGrpc;
import com.netflix.titus.grpc.protogen.JobManagementServiceGrpc;
Expand All @@ -46,7 +43,6 @@ protected void configure() {

bind(HealthGrpc.HealthImplBase.class).to(DefaultHealthServiceGrpc.class);
bind(JobManagementServiceGrpc.JobManagementServiceImplBase.class).to(DefaultJobManagementServiceGrpc.class);
bind(AgentManagementServiceImplBase.class).to(DefaultAgentManagementServiceGrpc.class);
bind(AutoScalingServiceGrpc.AutoScalingServiceImplBase.class).to(DefaultAutoScalingServiceGrpc.class);
bind(LoadBalancerServiceGrpc.LoadBalancerServiceImplBase.class).to(DefaultLoadBalancerServiceGrpc.class);
bind(SchedulerServiceGrpc.SchedulerServiceImplBase.class).to(DefaultSchedulerServiceGrpc.class);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@
import com.netflix.governator.guice.jersey.GovernatorServletContainer;
import com.netflix.governator.providers.Advises;
import com.netflix.titus.gateway.endpoint.v2.rest.TitusMasterProxyServlet;
import com.netflix.titus.gateway.endpoint.v3.rest.AgentManagementResource;
import com.netflix.titus.gateway.endpoint.v3.rest.SchedulerResource;
import com.netflix.titus.gateway.eviction.EvictionResource;
import com.netflix.titus.runtime.endpoint.common.rest.JsonMessageReaderWriter;
Expand Down Expand Up @@ -79,7 +78,6 @@ UnaryOperator<DefaultResourceConfig> getConfig() {

// resources
config.getClasses().add(HealthResource.class);
config.getClasses().add(AgentManagementResource.class);
config.getClasses().add(JobManagementResource.class);
config.getClasses().add(EvictionResource.class);
config.getClasses().add(AutoScalingResource.class);
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,6 @@
import com.netflix.titus.common.util.ExecutorsExt;
import com.netflix.titus.common.util.grpc.reactor.GrpcToReactorServerFactory;
import com.netflix.titus.gateway.kubernetes.KubeApiConnector;
import com.netflix.titus.grpc.protogen.AgentManagementServiceGrpc;
import com.netflix.titus.grpc.protogen.AgentManagementServiceGrpc.AgentManagementServiceImplBase;
import com.netflix.titus.grpc.protogen.AutoScalingServiceGrpc;
import com.netflix.titus.grpc.protogen.AutoScalingServiceGrpc.AutoScalingServiceImplBase;
import com.netflix.titus.grpc.protogen.EvictionServiceGrpc;
Expand Down Expand Up @@ -66,7 +64,6 @@ public class TitusGatewayGrpcServer {
private final HealthImplBase healthService;
private final JobManagementServiceImplBase jobManagementService;
private final EvictionServiceImplBase evictionService;
private final AgentManagementServiceImplBase agentManagementService;
private final AutoScalingServiceImplBase appAutoScalingService;
private final LoadBalancerServiceImplBase loadBalancerService;
private final SchedulerServiceImplBase schedulerService;
Expand All @@ -85,7 +82,6 @@ public TitusGatewayGrpcServer(
HealthImplBase healthService,
EvictionServiceImplBase evictionService,
JobManagementServiceImplBase jobManagementService,
AgentManagementServiceImplBase agentManagementService,
AutoScalingServiceImplBase appAutoScalingService,
LoadBalancerServiceImplBase loadBalancerService,
SchedulerServiceImplBase schedulerService,
Expand All @@ -96,7 +92,6 @@ public TitusGatewayGrpcServer(
this.healthService = healthService;
this.evictionService = evictionService;
this.jobManagementService = jobManagementService;
this.agentManagementService = agentManagementService;
this.appAutoScalingService = appAutoScalingService;
this.loadBalancerService = loadBalancerService;
this.schedulerService = schedulerService;
Expand Down Expand Up @@ -130,10 +125,6 @@ public void start() {
evictionService,
createInterceptors(EvictionServiceGrpc.getServiceDescriptor())
))
.addService(ServerInterceptors.intercept(
agentManagementService,
createInterceptors(AgentManagementServiceGrpc.getServiceDescriptor())
))
.addService(ServerInterceptors.intercept(
appAutoScalingService,
createInterceptors(AutoScalingServiceGrpc.getServiceDescriptor())
Expand Down

This file was deleted.

Loading

0 comments on commit 55bc031

Please sign in to comment.