import io.fabric8.kubernetes.client.dsl.MixedOperation; //导入依赖的package包/类
private static ServiceList getServicesByLabel(Map<String, String> labels, KubernetesClient client)
    throws KubernetesClientException {
  Objects.requireNonNull(client, "no client available");
  final MixedOperation<Service, ServiceList, DoneableService, Resource<Service, DoneableService>>
      services = client.services();
  final FilterWatchListDeletable<Service, ServiceList, Boolean, Watch, Watcher<Service>>
      listable = createLabelFilterQuery(labels, services);
  return listable.list();
}
 

import io.fabric8.kubernetes.client.dsl.MixedOperation; //导入依赖的package包/类
private static FilterWatchListDeletable<Service, ServiceList, Boolean, Watch, Watcher<Service>>
    createLabelFilterQuery(
        Map<String, String> labels,
        MixedOperation<Service, ServiceList, DoneableService, Resource<Service, DoneableService>>
            services) {
  FilterWatchListDeletable<Service, ServiceList, Boolean, Watch, Watcher<Service>> listable =
      null;
  for (Entry<String, String> entry : labels.entrySet()) {
    listable =
        listable == null
            ? services.withLabel(entry.getKey(), entry.getValue())
            : listable.withLabel(entry.getKey(), entry.getValue());
  }
  return listable;
}
 

import io.fabric8.kubernetes.client.dsl.MixedOperation; //导入依赖的package包/类
@Test
public void testRemovesPVCWhenCleanupCalled() throws Exception {
  final MixedOperation mixedOperation = mock(MixedOperation.class);
  final NonNamespaceOperation namespace = mock(NonNamespaceOperation.class);
  final FilterWatchListDeletable filterList = mock(FilterWatchListDeletable.class);
  doReturn(mixedOperation).when(client).persistentVolumeClaims();
  doReturn(namespace).when(mixedOperation).inNamespace(PROJECT_NAME);
  doReturn(filterList).when(namespace).withLabel(CHE_WORKSPACE_ID_LABEL, WORKSPACE_ID);
  when(filterList.delete()).thenReturn(true);

  strategy.cleanup(WORKSPACE_ID);

  verify(filterList).delete();
}
 

import io.fabric8.kubernetes.client.dsl.MixedOperation; //导入依赖的package包/类
@Test
public void testDoNothingWhenNoPVCFoundInNamespaceOnCleanup() throws Exception {
  final MixedOperation mixedOperation = mock(MixedOperation.class);
  final NonNamespaceOperation namespace = mock(NonNamespaceOperation.class);
  final FilterWatchListDeletable filterList = mock(FilterWatchListDeletable.class);
  doReturn(mixedOperation).when(client).persistentVolumeClaims();
  doReturn(namespace).when(mixedOperation).inNamespace(PROJECT_NAME);
  doReturn(filterList).when(namespace).withLabel(CHE_WORKSPACE_ID_LABEL, WORKSPACE_ID);
  when(filterList.delete()).thenReturn(false);

  strategy.cleanup(WORKSPACE_ID);

  verify(filterList).delete();
}
 

import io.fabric8.kubernetes.client.dsl.MixedOperation; //导入依赖的package包/类
@Test
public void testLogger() {
    String ns = "myspace";
    String component = "me";
    Clock clock = Clock.fixed(Instant.ofEpochSecond(10), ZoneId.of("UTC"));

    String message = "it crashed";

    KubernetesClient mockClient = mock(KubernetesClient.class);
    MixedOperation<Event, EventList, DoneableEvent, Resource<Event, DoneableEvent>> eventOperation = mock(MixedOperation.class);
    Resource<Event, DoneableEvent> eventResource = mock(Resource.class);

    when(mockClient.events()).thenReturn(eventOperation);
    when(eventOperation.inNamespace(any())).thenReturn(eventOperation);
    when(eventOperation.withName(startsWith("me."))).thenReturn(eventResource);
    when(eventResource.get()).thenReturn(null);

    EventLogger logger = new KubeEventLogger(mockClient, ns, clock, component);
    logger.log(TestReason.NONE, "it crashed", Warning, TestKind.KIND, "myqueue");

    ArgumentCaptor<Event> eventArgumentCaptor = ArgumentCaptor.forClass(Event.class);
    verify(eventResource).create(eventArgumentCaptor.capture());
    Event newEvent = eventArgumentCaptor.getValue();
    assertNotNull(newEvent);
    assertThat(newEvent.getMessage(), is(message));
    assertThat(newEvent.getReason(), is(TestReason.NONE.name()));
    assertThat(newEvent.getType(), is(Warning.name()));
    assertThat(newEvent.getFirstTimestamp(), is(clock.instant().toString()));
    assertThat(newEvent.getLastTimestamp(), is(clock.instant().toString()));
    assertThat(newEvent.getCount(), is(1));
    assertThat(newEvent.getInvolvedObject().getName(), is("myqueue"));
    assertThat(newEvent.getInvolvedObject().getKind(), is(TestKind.KIND.name()));

    newEvent.setFirstTimestamp(Instant.ofEpochSecond(5).toString());
    when(eventResource.get()).thenReturn(newEvent);
    logger.log(TestReason.NONE, "it crashed", Warning, TestKind.KIND, "myqueue");

    eventArgumentCaptor = ArgumentCaptor.forClass(Event.class);
    verify(eventResource).create(eventArgumentCaptor.capture());
    newEvent = eventArgumentCaptor.getValue();
    assertNotNull(newEvent);
    assertThat(newEvent.getMessage(), is(message));
    assertThat(newEvent.getReason(), is(TestReason.NONE.name()));
    assertThat(newEvent.getType(), is(Warning.name()));
    assertThat(newEvent.getFirstTimestamp(), is(Instant.ofEpochSecond(5).toString()));
    assertThat(newEvent.getLastTimestamp(), is(clock.instant().toString()));
    assertThat(newEvent.getCount(), is(2));
}