File tree Expand file tree Collapse file tree 4 files changed +11
-11
lines changed
operator-framework-core/src
main/java/io/javaoperatorsdk/operator/processing/event
test/java/io/javaoperatorsdk/operator/processing Expand file tree Collapse file tree 4 files changed +11
-11
lines changed Original file line number Diff line number Diff line change 4
4
import java .util .function .Predicate ;
5
5
6
6
@ SuppressWarnings ("rawtypes" )
7
- public abstract class AbstractEvent implements Event {
7
+ public class DefaultEvent implements Event {
8
8
9
9
private final String relatedCustomResourceUid ;
10
10
private final Predicate <CustomResource > customResourcesSelector ;
11
11
private final EventSource eventSource ;
12
12
13
- public AbstractEvent (String relatedCustomResourceUid , EventSource eventSource ) {
13
+ public DefaultEvent (String relatedCustomResourceUid , EventSource eventSource ) {
14
14
this .relatedCustomResourceUid = relatedCustomResourceUid ;
15
15
this .customResourcesSelector = null ;
16
16
this .eventSource = eventSource ;
17
17
}
18
18
19
- public AbstractEvent (Predicate <CustomResource > customResourcesSelector , EventSource eventSource ) {
19
+ public DefaultEvent (Predicate <CustomResource > customResourcesSelector , EventSource eventSource ) {
20
20
this .relatedCustomResourceUid = null ;
21
21
this .customResourcesSelector = customResourcesSelector ;
22
22
this .eventSource = eventSource ;
Original file line number Diff line number Diff line change 5
5
import io .fabric8 .kubernetes .client .CustomResource ;
6
6
import io .fabric8 .kubernetes .client .Watcher ;
7
7
import io .javaoperatorsdk .operator .processing .KubernetesResourceUtils ;
8
- import io .javaoperatorsdk .operator .processing .event .AbstractEvent ;
8
+ import io .javaoperatorsdk .operator .processing .event .DefaultEvent ;
9
9
10
- public class CustomResourceEvent extends AbstractEvent {
10
+ public class CustomResourceEvent extends DefaultEvent {
11
11
12
12
private final Watcher .Action action ;
13
13
private final CustomResource customResource ;
Original file line number Diff line number Diff line change 1
1
package io .javaoperatorsdk .operator .processing .event .internal ;
2
2
3
- import io .javaoperatorsdk .operator .processing .event .AbstractEvent ;
3
+ import io .javaoperatorsdk .operator .processing .event .DefaultEvent ;
4
4
5
- public class TimerEvent extends AbstractEvent {
5
+ public class TimerEvent extends DefaultEvent {
6
6
7
7
public TimerEvent (String relatedCustomResourceUid , TimerEventSource eventSource ) {
8
8
super (relatedCustomResourceUid , eventSource );
Original file line number Diff line number Diff line change 12
12
13
13
import io .fabric8 .kubernetes .client .Watcher ;
14
14
import io .javaoperatorsdk .operator .api .config .ConfigurationService ;
15
- import io .javaoperatorsdk .operator .processing .event .AbstractEvent ;
15
+ import io .javaoperatorsdk .operator .processing .event .DefaultEvent ;
16
16
import io .javaoperatorsdk .operator .processing .event .DefaultEventSourceManager ;
17
17
import io .javaoperatorsdk .operator .processing .event .internal .CustomResourceEvent ;
18
18
import io .javaoperatorsdk .operator .sample .simple .TestCustomResource ;
@@ -74,13 +74,13 @@ public void dispatchEventsWithPredicate() {
74
74
customResourceCache .cacheResource (cr3 );
75
75
76
76
defaultEventHandler .handleEvent (
77
- new AbstractEvent (
77
+ new DefaultEvent (
78
78
c -> {
79
79
var tcr = ((TestCustomResource ) c );
80
80
return Objects .equals ("1" , tcr .getSpec ().getValue ())
81
81
|| Objects .equals ("3" , tcr .getSpec ().getValue ());
82
82
},
83
- null ) {} );
83
+ null ));
84
84
85
85
verify (eventDispatcherMock , timeout (SEPARATE_EXECUTION_TIMEOUT ).times (2 ))
86
86
.handleExecution (any ());
@@ -97,7 +97,7 @@ public void dispatchEventsWithPredicate() {
97
97
.hasSize (2 )
98
98
.allSatisfy (
99
99
s -> {
100
- assertThat (s .getEvents ()).isNotEmpty ().hasOnlyElementsOfType (AbstractEvent .class );
100
+ assertThat (s .getEvents ()).isNotEmpty ().hasOnlyElementsOfType (DefaultEvent .class );
101
101
assertThat (s )
102
102
.satisfiesAnyOf (
103
103
e -> Objects .equals (cr1 .getMetadata ().getUid (), e .getCustomResourceUid ()),
You can’t perform that action at this time.
0 commit comments