@Test public void testRefreshServicesEtag() throws Exception { ServiceDescriptors descriptors = createClient(createProcessor(null, "oldEtag", "testingenvironment")) .refreshServices(new ServiceDescriptors("testService", "testPool", ImmutableList.of(), new Duration(1, HOURS), "oldEtag")) .get(); assertDescriptorsExpected(descriptors, null, DEFAULT_DELAY); }
@Override public ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors) { requireNonNull(serviceDescriptors, "serviceDescriptors is null"); return lookup(serviceDescriptors.getType(), serviceDescriptors.getPool(), serviceDescriptors); }
HttpDiscoveryLookupClient implements DiscoveryLookupClient { @Override public ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors) { requireNonNull(serviceDescriptors, "serviceDescriptors is null"); return lookup(serviceDescriptors.getType(), serviceDescriptors.getPool(), serviceDescriptors); } }
HttpDiscoveryLookupClient implements DiscoveryLookupClient { @Override public ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors) { requireNonNull(serviceDescriptors, "serviceDescriptors is null"); return lookup(serviceDescriptors.getType(), serviceDescriptors.getPool(), serviceDescriptors); } @Inject  HttpDiscoveryLookupClient(NodeInfo nodeInfo,
            JsonCodec<ServiceDescriptorsRepresentation> serviceDescriptorsCodec,
            @ForDiscoveryClient HttpClient httpClient,
            ServiceInventory serviceInventory); }
HttpDiscoveryLookupClient implements DiscoveryLookupClient { @Override public ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors) { requireNonNull(serviceDescriptors, "serviceDescriptors is null"); return lookup(serviceDescriptors.getType(), serviceDescriptors.getPool(), serviceDescriptors); } @Inject  HttpDiscoveryLookupClient(NodeInfo nodeInfo,
            JsonCodec<ServiceDescriptorsRepresentation> serviceDescriptorsCodec,
            @ForDiscoveryClient HttpClient httpClient,
            ServiceInventory serviceInventory); @Flatten RequestStats getStats(); @Override ListenableFuture<ServiceDescriptors> getServices(String type); @Override ListenableFuture<ServiceDescriptors> getServices(String type, String pool); @Override ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors); }
HttpDiscoveryLookupClient implements DiscoveryLookupClient { @Override public ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors) { requireNonNull(serviceDescriptors, "serviceDescriptors is null"); return lookup(serviceDescriptors.getType(), serviceDescriptors.getPool(), serviceDescriptors); } @Inject  HttpDiscoveryLookupClient(NodeInfo nodeInfo,
            JsonCodec<ServiceDescriptorsRepresentation> serviceDescriptorsCodec,
            @ForDiscoveryClient HttpClient httpClient,
            ServiceInventory serviceInventory); @Flatten RequestStats getStats(); @Override ListenableFuture<ServiceDescriptors> getServices(String type); @Override ListenableFuture<ServiceDescriptors> getServices(String type, String pool); @Override ListenableFuture<ServiceDescriptors> refreshServices(ServiceDescriptors serviceDescriptors);  }