ljnelson

private final void processObserverMethod(@Observes final ProcessObserverMethod<? extends org.microbean.kubernetes.controller.Event<? extends HasMetadata>, ?> event, final BeanManager beanManager) {
  if (event != null) {
    this.processPotentialEventSelectorObserverMethod(event.getObserverMethod(), beanManager);
  }
}

private final void processSyntheticObserverMethod(@Observes final ProcessSyntheticObserverMethod<? extends org.microbean.kubernetes.controller.Event<? extends HasMetadata>, ?> event, final BeanManager beanManager) {
  if (event != null) {
    this.processPotentialEventSelectorObserverMethod(event.getObserverMethod(), beanManager);
  }

ljnelson

private final void processAfterBeanDiscovery(@Observes final AfterBeanDiscovery event) {
  if (event != null) {
      this.eventSelectorBeans.clear();
  }
}

ljnelson

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import javax.inject.Qualifier;

@Documented
@Retention(value = RetentionPolicy.RUNTIME)
@Target({ ElementType.ANNOTATION_TYPE })

ljnelson

@Documented
@KubernetesEventSelector
@Qualifier
@Retention(value = RetentionPolicy.RUNTIME)
@Target({ ElementType.METHOD, ElementType.PARAMETER })
public @interface AllConfigMapEvents {

}

ljnelson

import javax.enterprise.event.Observes;
import io.fabric8.kubernetes.api.model.HasMetadata;
import org.microbean.kubernetes.controller.Event;

private final void onConfigMapEvent(@Observes @AllConfigMapEvents final Event<? extends HasMetadata> event) {

}

ljnelson

import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.Produces;
import io.fabric8.kubernetes.api.model.ConfigMap;
import io.fabric8.kubernetes.api.model.ConfigMapList;
import io.fabric8.kubernetes.api.model.DoneableConfigMap;
import io.fabric8.kubernetes.api.model.HasMetadata;
import io.fabric8.kubernetes.client.KubernetesClient;
import io.fabric8.kubernetes.client.dsl.Operation;
import io.fabric8.kubernetes.client.dsl.Resource;

ljnelson

private final <T extends HasMetadata, X extends Listable<? extends KubernetesResourceList> & VersionWatchable<? extends Closeable, Watcher<T>>> void startControllers(@Observes @Initialized(ApplicationScoped.class) @Priority(LIBRARY_AFTER) final Object ignored, final BeanManager beanManager) { 
  if (beanManager != null) {
    for (final Bean<?> bean : this.beans) {
      assert bean != null;
          
      final Set<Annotation> qualifiers = bean.getQualifiers();

      final Map<Object, T> knownObjects = new HashMap<>();
          
      final EventDistributor<T> eventDistributor = new EventDistributor<>(knownObjects);

ljnelson

private static final class CDIEventDistributor<T extends HasMetadata> implements Consumer<AbstractEvent<? extends T>> {

  private static final Annotation[] EMPTY_ANNOTATION_ARRAY = new Annotation[0];
    
  private final Annotation[] qualifiers;

  private final NotificationOptions notificationOptions;

  private final boolean syncNeeded;

ljnelson

private final void stopControllers(@Observes @BeforeDestroyed(ApplicationScoped.class) @Priority(LIBRARY_BEFORE) final Object ignored) throws IOException {

  Exception exception = null;
  for (final Controller<?> controller : this.controllers) {
    assert controller != null;
    try {
      controller.close();
    } catch (final IOException | RuntimeException closeException) {
      if (exception == null) {
        exception = closeException;

ljnelson

<dependencies>
  <dependency>
    <groupId>javax.annotation</groupId>
    <artifactId>javax.annotation-api</artifactId>
    <version>1.3</version>
    <type>jar</type>
    <scope>provided</scope>
  </dependency>
  
  <dependency>