Skip to content

Commit

Permalink
feat: endpoints and endpont slice updatematcher (#1990)
Browse files Browse the repository at this point in the history
  • Loading branch information
csviri authored Aug 1, 2023
1 parent d4201fe commit 2d11852
Show file tree
Hide file tree
Showing 3 changed files with 50 additions and 5 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
package io.javaoperatorsdk.operator.processing.dependent.kubernetes.updatermatcher;

import java.util.Objects;

import io.fabric8.kubernetes.api.model.discovery.v1.EndpointSlice;
import io.javaoperatorsdk.operator.api.reconciler.Context;

public class EndpointSliceResourceUpdateMatcher
extends GenericResourceUpdaterMatcher<EndpointSlice> {

@Override
protected void updateClonedActual(EndpointSlice actual, EndpointSlice desired) {
actual.setEndpoints(desired.getEndpoints());
actual.setAddressType(desired.getAddressType());
actual.setPorts(desired.getPorts());
}

@Override
public boolean matches(EndpointSlice actual, EndpointSlice desired, Context<?> context) {
return Objects.equals(actual.getEndpoints(), desired.getEndpoints()) &&
Objects.equals(actual.getAddressType(), desired.getAddressType()) &&
Objects.equals(actual.getPorts(), desired.getPorts());
}

}
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
package io.javaoperatorsdk.operator.processing.dependent.kubernetes.updatermatcher;

import java.util.Objects;

import io.fabric8.kubernetes.api.model.Endpoints;
import io.javaoperatorsdk.operator.api.reconciler.Context;

public class EndpointsResourceUpdaterMatcher extends GenericResourceUpdaterMatcher<Endpoints> {

@Override
protected void updateClonedActual(Endpoints actual, Endpoints desired) {
actual.setSubsets(desired.getSubsets());
}

@Override
public boolean matches(Endpoints actual, Endpoints desired, Context<?> context) {
return Objects.equals(actual.getSubsets(), desired.getSubsets());
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,8 @@

import java.util.Map;

import io.fabric8.kubernetes.api.model.ConfigMap;
import io.fabric8.kubernetes.api.model.HasMetadata;
import io.fabric8.kubernetes.api.model.Secret;
import io.fabric8.kubernetes.api.model.ServiceAccount;
import io.fabric8.kubernetes.api.model.*;
import io.fabric8.kubernetes.api.model.discovery.v1.EndpointSlice;
import io.fabric8.kubernetes.api.model.rbac.ClusterRole;
import io.fabric8.kubernetes.api.model.rbac.ClusterRoleBinding;
import io.fabric8.kubernetes.api.model.rbac.Role;
Expand All @@ -28,7 +26,9 @@ ServiceAccount.class, new ServiceAccountResourceUpdaterMatcher(),
Role.class, new RoleResourceUpdaterMatcher(),
ClusterRole.class, new ClusterRoleResourceUpdaterMatcher(),
RoleBinding.class, new RoleBindingResourceUpdaterMatcher(),
ClusterRoleBinding.class, new ClusterRoleBindingResourceUpdaterMatcher());
ClusterRoleBinding.class, new ClusterRoleBindingResourceUpdaterMatcher(),
Endpoints.class, new EndpointsResourceUpdaterMatcher(),
EndpointSlice.class, new EndpointSliceResourceUpdateMatcher());

protected GenericResourceUpdaterMatcher() {}

Expand Down

0 comments on commit 2d11852

Please sign in to comment.