7
7
import java .util .function .Predicate ;
8
8
import java .util .stream .Stream ;
9
9
10
+ import org .slf4j .Logger ;
11
+ import org .slf4j .LoggerFactory ;
12
+
10
13
import io .fabric8 .kubernetes .api .model .HasMetadata ;
11
14
import io .fabric8 .kubernetes .client .informers .ResourceEventHandler ;
12
15
import io .fabric8 .kubernetes .client .informers .SharedIndexInformer ;
21
24
class InformerWrapper <T extends HasMetadata >
22
25
implements LifecycleAware , IndexerResourceCache <T > {
23
26
27
+ private static final Logger log = LoggerFactory .getLogger (InformerWrapper .class );
28
+
24
29
private final SharedIndexInformer <T > informer ;
25
30
private final Cache <T > cache ;
26
31
@@ -45,8 +50,7 @@ public void start() throws OperatorException {
45
50
});
46
51
} else {
47
52
final var apiTypeClass = informer .getApiTypeClass ();
48
- final var fullResourceName =
49
- HasMetadata .getFullResourceName (apiTypeClass );
53
+ final var fullResourceName = HasMetadata .getFullResourceName (apiTypeClass );
50
54
final var version = HasMetadata .getVersion (apiTypeClass );
51
55
throw new IllegalStateException (
52
56
"Cannot retrieve 'stopped' callback to listen to informer stopping for informer for "
@@ -55,8 +59,12 @@ public void start() throws OperatorException {
55
59
});
56
60
57
61
} catch (Exception e ) {
58
- ReconcilerUtils .handleKubernetesClientException (e ,
59
- HasMetadata .getFullResourceName (informer .getApiTypeClass ()));
62
+ final var apiTypeClass = informer .getApiTypeClass ();
63
+ final var fullResourceName = HasMetadata .getFullResourceName (apiTypeClass );
64
+ final var version = HasMetadata .getVersion (apiTypeClass );
65
+ log .error ("Couldn't start informer for " + fullResourceName + "/" + version + " resources" ,
66
+ e );
67
+ ReconcilerUtils .handleKubernetesClientException (e , fullResourceName );
60
68
throw e ;
61
69
}
62
70
}
0 commit comments