File tree Expand file tree Collapse file tree 5 files changed +100
-0
lines changed
operator-framework/src/main/java/io/javaoperatorsdk/operator/processing/experimental Expand file tree Collapse file tree 5 files changed +100
-0
lines changed Original file line number Diff line number Diff line change
1
+ package io .javaoperatorsdk .operator .processing .experimental ;
2
+
3
+ import io .javaoperatorsdk .operator .processing .event .EventSource ;
4
+
5
+ public interface DependentResource <T > extends EventSource {
6
+
7
+ Status getStatus (String ownerResourceId );
8
+
9
+ DependentResource <T > createOrUpdate (String ownerResourceId , T specs );
10
+
11
+
12
+
13
+ }
Original file line number Diff line number Diff line change
1
+ package io .javaoperatorsdk .operator .processing .experimental ;
2
+
3
+ import io .fabric8 .kubernetes .client .CustomResource ;
4
+ import io .javaoperatorsdk .operator .api .Context ;
5
+ import io .javaoperatorsdk .operator .api .DeleteControl ;
6
+ import io .javaoperatorsdk .operator .api .ResourceController ;
7
+ import io .javaoperatorsdk .operator .api .UpdateControl ;
8
+
9
+ public class DependentResourceAwareController <T extends CustomResource > implements ResourceController <T > {
10
+
11
+ @ Override
12
+ final public DeleteControl deleteResource (T resource , Context <T > context ) {
13
+ return null ;
14
+ }
15
+
16
+ @ Override
17
+ final public UpdateControl <T > createOrUpdateResource (T resource , Context <T > context ) {
18
+ return null ;
19
+ }
20
+
21
+ public DeleteControl deleteResource (T resource , DependentResourceContext <T > context ) {
22
+ return null ;
23
+ }
24
+
25
+ public UpdateControl <T > createOrUpdateResource (T resource , DependentResourceContext <T > context ) {
26
+ return null ;
27
+ }
28
+
29
+ }
Original file line number Diff line number Diff line change
1
+ package io .javaoperatorsdk .operator .processing .experimental ;
2
+
3
+ import io .fabric8 .kubernetes .client .CustomResource ;
4
+ import io .javaoperatorsdk .operator .api .Context ;
5
+ import io .javaoperatorsdk .operator .processing .event .Event ;
6
+ import io .javaoperatorsdk .operator .processing .event .EventSourceManager ;
7
+
8
+ import java .util .List ;
9
+
10
+ public class DependentResourceContext <T extends CustomResource > implements Context <T > {
11
+
12
+ @ Override
13
+ public EventSourceManager getEventSourceManager () {
14
+ return null ;
15
+ }
16
+
17
+ @ Override
18
+ public List <Event > getEvents () {
19
+ return null ;
20
+ }
21
+
22
+
23
+ }
Original file line number Diff line number Diff line change
1
+ package io .javaoperatorsdk .operator .processing .experimental ;
2
+
3
+ import java .util .Optional ;
4
+
5
+ public class State <T > {
6
+
7
+ private Status status ;
8
+ private T details ;
9
+
10
+ public State (Status status , T details ) {
11
+ this .status = status ;
12
+ this .details = details ;
13
+ }
14
+
15
+ public State (Status status ) {
16
+ this (status ,null );
17
+ }
18
+
19
+ public Status getStatus () {
20
+ return status ;
21
+ }
22
+
23
+ public Optional <T > getDetails () {
24
+ return Optional .ofNullable (details );
25
+ }
26
+ }
Original file line number Diff line number Diff line change
1
+ package io .javaoperatorsdk .operator .processing .experimental ;
2
+
3
+ public enum Status {
4
+
5
+ CREATING ,
6
+ SUCCESSFULLY_CREATED ,
7
+ FAILED
8
+
9
+ }
You can’t perform that action at this time.
0 commit comments