11package com .example .grpc .client ;
22
33import io .fabric8 .kubernetes .api .model .Endpoints ;
4- import io .fabric8 .kubernetes .api .model .Service ;
54import io .fabric8 .kubernetes .client .DefaultKubernetesClient ;
65import io .fabric8 .kubernetes .client .KubernetesClient ;
76import io .fabric8 .kubernetes .client .KubernetesClientException ;
109import io .grpc .EquivalentAddressGroup ;
1110import io .grpc .NameResolver ;
1211import io .grpc .internal .SharedResourceHolder ;
13- import io .netty .resolver .InetSocketAddressResolver ;
1412
1513import javax .annotation .concurrent .GuardedBy ;
16- import java .net .Inet4Address ;
17- import java .net .InetAddress ;
1814import java .net .InetSocketAddress ;
19- import java .net .SocketAddress ;
2015import java .util .ArrayList ;
2116import java .util .Collections ;
2217import java .util .List ;
18+ import java .util .concurrent .Executor ;
2319import java .util .concurrent .ExecutorService ;
2420import java .util .concurrent .ScheduledExecutorService ;
2521import java .util .concurrent .TimeUnit ;
26- import java .util .concurrent .atomic .AtomicBoolean ;
27- import java .util .stream .Collectors ;
2822
2923/**
3024 * Created by rayt on 6/22/17.
@@ -35,14 +29,14 @@ public class KubernetesNameResolver extends NameResolver {
3529 private final int port ;
3630 private final Attributes params ;
3731 private final SharedResourceHolder .Resource <ScheduledExecutorService > timerServiceResource ;
38- private final SharedResourceHolder .Resource <ExecutorService > sharedChannelExecutorResource ;
32+ private final SharedResourceHolder .Resource <Executor > sharedChannelExecutorResource ;
3933 private final KubernetesClient kubernetesClient ;
4034 private Listener listener ;
4135
4236 private volatile boolean refreshing = false ;
4337 private volatile boolean watching = false ;
4438
45- public KubernetesNameResolver (String namespace , String name , int port , Attributes params , SharedResourceHolder .Resource <ScheduledExecutorService > timerServiceResource , SharedResourceHolder .Resource <ExecutorService > sharedChannelExecutorResource ) {
39+ public KubernetesNameResolver (String namespace , String name , int port , Attributes params , SharedResourceHolder .Resource <ScheduledExecutorService > timerServiceResource , SharedResourceHolder .Resource <Executor > sharedChannelExecutorResource ) {
4640 this .namespace = namespace ;
4741 this .name = name ;
4842 this .port = port ;
0 commit comments