4
4
5
5
package oracle .kubernetes .operator .helpers ;
6
6
7
+ import static oracle .kubernetes .operator .LabelConstants .CLUSTERNAME_LABEL ;
7
8
import static oracle .kubernetes .operator .LabelConstants .DOMAINUID_LABEL ;
8
9
import static oracle .kubernetes .operator .LabelConstants .SERVERNAME_LABEL ;
9
10
import static oracle .kubernetes .operator .ProcessingConstants .CLUSTER_NAME ;
@@ -237,6 +238,17 @@ public void onDeleteEventWithNewerClusterService_removeIt() {
237
238
assertThat (info .getClusterService (CLUSTER ), nullValue ());
238
239
}
239
240
241
+ @ Test
242
+ public void whenEventContainsServiceWithClusterNameAndNoTypeLabel_addAsClusterService () {
243
+ V1Service service =
244
+ new V1Service ().metadata (createMetadata ().putLabelsItem (CLUSTERNAME_LABEL , CLUSTER ));
245
+ Watch .Response <V1Service > event = WatchEvent .createAddedEvent (service ).toWatchResponse ();
246
+
247
+ processor .dispatchServiceWatch (event );
248
+
249
+ assertThat (info .getClusterService (CLUSTER ), sameInstance (service ));
250
+ }
251
+
240
252
@ Test
241
253
public void onAddEventWithNoRecordedServerService_addIt () {
242
254
V1Service newService = createServerService ();
@@ -351,6 +363,21 @@ public void onDeleteEventWithNewerServerService_removeIt() {
351
363
assertThat (info .getServerService (SERVER ), nullValue ());
352
364
}
353
365
366
+ @ Test
367
+ public void whenEventContainsServiceWithServerNameAndNoTypeLabel_addAsServerService () {
368
+ V1Service service =
369
+ new V1Service ()
370
+ .metadata (
371
+ createMetadata ()
372
+ .putLabelsItem (CLUSTERNAME_LABEL , CLUSTER )
373
+ .putLabelsItem (SERVERNAME_LABEL , SERVER ));
374
+ Watch .Response <V1Service > event = WatchEvent .createAddedEvent (service ).toWatchResponse ();
375
+
376
+ processor .dispatchServiceWatch (event );
377
+
378
+ assertThat (info .getServerService (SERVER ), sameInstance (service ));
379
+ }
380
+
354
381
@ Test
355
382
public void onAddEventWithNoRecordedExternalService_addIt () {
356
383
V1Service newService = createExternalService ();
@@ -482,6 +509,10 @@ private V1Service withTimeAndVersion(V1Service service) {
482
509
return service ;
483
510
}
484
511
512
+ private DateTime getDateTime () {
513
+ return new DateTime (++clock );
514
+ }
515
+
485
516
private V1ObjectMeta createMetadata () {
486
517
return new V1ObjectMeta ()
487
518
.namespace (NS )
@@ -490,7 +521,30 @@ private V1ObjectMeta createMetadata() {
490
521
.resourceVersion (RESOURCE_VERSION );
491
522
}
492
523
493
- private DateTime getDateTime () {
494
- return new DateTime (++clock );
524
+ @ Test
525
+ public void whenClusterServiceAdded_recordforCluster () {
526
+ V1Service clusterService = createClusterService ();
527
+
528
+ ServiceHelper .addToPresence (info , clusterService );
529
+
530
+ assertThat (info .getClusterService (CLUSTER ), sameInstance (clusterService ));
531
+ }
532
+
533
+ @ Test
534
+ public void whenServerServiceAdded_recordforServer () {
535
+ V1Service serverService = createServerService ();
536
+
537
+ ServiceHelper .addToPresence (info , serverService );
538
+
539
+ assertThat (info .getServerService (SERVER ), sameInstance (serverService ));
540
+ }
541
+
542
+ @ Test
543
+ public void whenExternalServiceAdded_recordforServer () {
544
+ V1Service externalService = createExternalService ();
545
+
546
+ ServiceHelper .addToPresence (info , externalService );
547
+
548
+ assertThat (info .getExternalService (SERVER ), sameInstance (externalService ));
495
549
}
496
550
}
0 commit comments