) args.get(0);
this.parentType = (Class) args.get(1);
}
-
private final Class type;
private final Class parentType;
-
- public void visit(V element) {}
-
- public void visit(List> path, V element) {
+ public void visit(V element) {
+
+ }
+ public void visit(List> path,V element) {
visit(element);
}
-
- public P getParent(List> path) {
+ public P getParent(List> path) {
return path.size() - 1 >= 0 ? (P) path.get(path.size() - 1) : null;
}
-
public Class getParentType() {
return parentType;
}
-}
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/TypedVisitor.java b/fluent/src/main/java/io/kubernetes/client/fluent/TypedVisitor.java
index 3996b39920..b8e8257f0e 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/TypedVisitor.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/TypedVisitor.java
@@ -1,19 +1,9 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-public abstract class TypedVisitor implements Visitor {
+import java.lang.Class;
+public abstract class TypedVisitor implements Visitor{
public Class getType() {
return (Class) Visitors.getTypeArguments(TypedVisitor.class, getClass()).get(0);
}
-}
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/Visitable.java b/fluent/src/main/java/io/kubernetes/client/fluent/Visitable.java
index 353b6a30cc..328092d661 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/Visitable.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/Visitable.java
@@ -1,37 +1,25 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-import java.util.Collections;
-import java.util.List;
import java.util.Map.Entry;
+import java.lang.Class;
+import java.lang.Object;
+import java.util.List;
+import java.lang.String;
+import java.util.Collections;
+public interface Visitable{
+ default T accept(Class type,Visitor visitor) {
+ return accept(new Visitor() {
+ @Override
+ public Class getType() {
+ return type;
+ }
-public interface Visitable {
- default T accept(Class type, Visitor visitor) {
- return accept(
- new Visitor() {
- @Override
- public Class getType() {
- return type;
- }
-
- @Override
- public void visit(V element) {
- visitor.visit(element);
- }
- });
+ @Override
+ public void visit(V element) {
+ visitor.visit(element);
+ }
+ });
}
-
default T accept(io.kubernetes.client.fluent.Visitor... visitors) {
for (Visitor visitor : visitors) {
if (visitor.canVisit(Collections.emptyList(), this)) {
@@ -40,16 +28,10 @@ default T accept(io.kubernetes.client.fluent.Visitor... visitors) {
}
return getTarget(this);
}
-
- default T accept(
- List> path, io.kubernetes.client.fluent.Visitor... visitors) {
+ default T accept(List> path,io.kubernetes.client.fluent.Visitor... visitors) {
return accept(path, "", visitors);
}
-
- default T accept(
- List> path,
- String currentKey,
- io.kubernetes.client.fluent.Visitor... visitors) {
+ default T accept(List> path,String currentKey,io.kubernetes.client.fluent.Visitor... visitors) {
for (Visitor visitor : visitors) {
if (visitor.canVisit(path, this)) {
visitor.visit(path, this);
@@ -57,8 +39,8 @@ default T accept(
}
return getTarget(this);
}
-
default T getTarget(Visitable visitable) {
return (T) visitable;
}
-}
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/VisitableBuilder.java b/fluent/src/main/java/io/kubernetes/client/fluent/VisitableBuilder.java
index 15d2a8b262..6c5172906b 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/VisitableBuilder.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/VisitableBuilder.java
@@ -1,16 +1,5 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-public interface VisitableBuilder>
- extends Builder, Visitable {}
+public interface VisitableBuilder> extends Builder,Visitable{
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/VisitableMap.java b/fluent/src/main/java/io/kubernetes/client/fluent/VisitableMap.java
index b1f43452ac..d889f05d2b 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/VisitableMap.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/VisitableMap.java
@@ -1,47 +1,33 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-import java.util.ArrayList;
+import java.util.stream.Collectors;
+import java.lang.Iterable;
+import java.util.function.Consumer;
import java.util.HashMap;
+import java.util.ArrayList;
import java.util.Iterator;
+import java.lang.Object;
import java.util.List;
+import java.lang.String;
import java.util.Spliterator;
-import java.util.function.Consumer;
-import java.util.stream.Collectors;
-
-public class VisitableMap extends HashMap>>
- implements Iterable> {
+public class VisitableMap extends HashMap>> implements Iterable>{
public List> get(Object key) {
if (!containsKey(key)) {
put(String.valueOf(key), new ArrayList());
}
return super.get(key);
}
-
public List> aggregate() {
return values().stream().flatMap(l -> l.stream()).collect(Collectors.toList());
}
-
public Iterator> iterator() {
return aggregate().iterator();
}
-
public void forEach(Consumer> action) {
aggregate().forEach(action);
}
-
public Spliterator spliterator() {
return aggregate().spliterator();
}
-}
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/Visitor.java b/fluent/src/main/java/io/kubernetes/client/fluent/Visitor.java
index 720d808bc6..1070725dfe 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/Visitor.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/Visitor.java
@@ -1,24 +1,16 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-import java.lang.reflect.Method;
-import java.util.List;
import java.util.Map.Entry;
+import java.lang.Class;
+import java.lang.FunctionalInterface;
+import java.lang.Object;
+import java.util.List;
+import java.lang.String;
+import java.lang.reflect.Method;
+import java.lang.Boolean;
import java.util.function.Predicate;
-
-@FunctionalInterface
-public interface Visitor {
+ @FunctionalInterface
+ public interface Visitor{
default Class getType() {
List args = Visitors.getTypeArguments(Visitor.class, getClass());
if (args == null || args.isEmpty()) {
@@ -26,18 +18,14 @@ default Class getType() {
}
return (Class) args.get(0);
}
-
void visit(T element);
-
default int order() {
return 0;
}
-
- default void visit(List> path, T element) {
+ default void visit(List> path,T element) {
visit(element);
}
-
- default Boolean canVisit(List> path, F target) {
+ default Boolean canVisit(List> path,F target) {
if (target == null) {
return false;
}
@@ -56,8 +44,7 @@ default Boolean canVisit(List> path, F target) {
return false;
}
}
-
- default Boolean hasVisitMethodMatching(F target) {
+ default Boolean hasVisitMethodMatching(F target) {
for (Method method : getClass().getMethods()) {
if (!method.getName().equals("visit") || method.getParameterTypes().length != 1) {
continue;
@@ -71,27 +58,17 @@ default Boolean hasVisitMethodMatching(F target) {
}
return false;
}
-
- default Predicate>> getRequirement() {
+ default Predicate>> getRequirement() {
return p -> true;
}
-
- default Predicate>> hasItem(
- Class type, Predicate predicate) {
- Predicate>> result =
- l ->
- l.stream()
- .map(Entry::getValue)
- .filter(i -> type.isInstance(i))
- .map(i -> type.cast(i))
- .anyMatch(predicate);
+ default Predicate>> hasItem(Class type,Predicate predicate) {
+ Predicate>> result = l -> l.stream().map(Entry::getValue).filter(i -> type.isInstance(i))
+ .map(i -> type.cast(i)).anyMatch(predicate);
return result;
}
-
- default Visitor addRequirement(Class type, Predicate
predicate) {
+ default
Visitor addRequirement(Class type,Predicate
predicate) {
return addRequirement(predicate);
}
-
default Visitor addRequirement(Predicate predicate) {
return new DelegatingVisitor(getType(), this) {
@Override
@@ -100,4 +77,5 @@ public Predicate> getRequirement() {
}
};
}
-}
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/VisitorListener.java b/fluent/src/main/java/io/kubernetes/client/fluent/VisitorListener.java
index df65cbae4d..c977b940ce 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/VisitorListener.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/VisitorListener.java
@@ -1,42 +1,30 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-import java.util.HashSet;
-import java.util.List;
import java.util.Map.Entry;
import java.util.ServiceLoader;
-import java.util.Set;
import java.util.concurrent.atomic.AtomicBoolean;
-
-public interface VisitorListener {
+import java.util.Set;
+import java.lang.Object;
+import java.util.List;
+import java.lang.String;
+import java.util.HashSet;
+public interface VisitorListener{
static AtomicBoolean loaded = new AtomicBoolean();
static Set listeners = new HashSet<>();
-
public static Set getListeners() {
if (loaded.get()) {
return listeners;
}
synchronized (loaded) {
- listeners.add(new VisitorListener() {});
- for (VisitorListener listener :
- ServiceLoader.load(VisitorListener.class, VisitorListener.class.getClassLoader())) {
+ listeners.add(new VisitorListener() {
+ });
+ for (VisitorListener listener : ServiceLoader.load(VisitorListener.class,
+ VisitorListener.class.getClassLoader())) {
listeners.add(listener);
}
if (Thread.currentThread().getContextClassLoader() != null) {
- for (VisitorListener listener :
- ServiceLoader.load(
- VisitorListener.class, Thread.currentThread().getContextClassLoader())) {
+ for (VisitorListener listener : ServiceLoader.load(VisitorListener.class,
+ Thread.currentThread().getContextClassLoader())) {
listeners.add(listener);
}
}
@@ -44,22 +32,23 @@ public static Set getListeners() {
}
return listeners;
}
-
- public static Visitor wrap(Visitor visitor) {
+ public static Visitor wrap(Visitor visitor) {
return VisitorWiretap.create(visitor, getListeners());
}
-
public static void register(VisitorListener listener) {
listeners.add(listener);
}
-
public static void unregister(VisitorListener listener) {
listeners.add(listener);
}
-
- default void beforeVisit(Visitor v, List> path, T target) {}
-
- default void afterVisit(Visitor v, List> path, T target) {}
-
- default void onCheck(Visitor v, boolean canVisit, T target) {}
-}
+ default void beforeVisit(Visitor v,List> path,T target) {
+
+ }
+ default void afterVisit(Visitor v,List> path,T target) {
+
+ }
+ default void onCheck(Visitor v,boolean canVisit,T target) {
+
+ }
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/VisitorWiretap.java b/fluent/src/main/java/io/kubernetes/client/fluent/VisitorWiretap.java
index e3761ec320..9193e40630 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/VisitorWiretap.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/VisitorWiretap.java
@@ -1,62 +1,47 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
+import java.util.Map.Entry;
import java.util.Collection;
-import java.util.Collections;
+import java.lang.Class;
+import java.lang.Object;
import java.util.List;
-import java.util.Map.Entry;
-
-public final class VisitorWiretap implements Visitor {
- private VisitorWiretap(Visitor delegate, Collection listeners) {
+import java.lang.String;
+import java.lang.Boolean;
+import java.util.Collections;
+import java.util.function.Predicate;
+public final class VisitorWiretap implements Visitor{
+ private VisitorWiretap(Visitor delegate,Collection listeners) {
this.delegate = delegate;
this.listeners = listeners;
}
-
private final Collection listeners;
private final Visitor delegate;
-
- public static VisitorWiretap create(
- Visitor visitor, Collection listeners) {
+ public static VisitorWiretap create(Visitor visitor,Collection listeners) {
if (visitor instanceof VisitorWiretap) {
return (VisitorWiretap) visitor;
}
return new VisitorWiretap(visitor, listeners);
}
-
public Class getType() {
return delegate.getType();
}
-
public void visit(T target) {
listeners.forEach(l -> l.beforeVisit(delegate, Collections.emptyList(), target));
delegate.visit(target);
listeners.forEach(l -> l.afterVisit(delegate, Collections.emptyList(), target));
}
-
public int order() {
return delegate.order();
}
-
- public void visit(List> path, T target) {
+ public void visit(List> path,T target) {
listeners.forEach(l -> l.beforeVisit(delegate, path, target));
delegate.visit(path, target);
listeners.forEach(l -> l.afterVisit(delegate, path, target));
}
-
- public Boolean canVisit(List> path, F target) {
+ public Boolean canVisit(List> path,F target) {
boolean canVisit = delegate.canVisit(path, target);
listeners.forEach(l -> l.onCheck(delegate, canVisit, target));
return canVisit;
}
-}
+
+}
\ No newline at end of file
diff --git a/fluent/src/main/java/io/kubernetes/client/fluent/Visitors.java b/fluent/src/main/java/io/kubernetes/client/fluent/Visitors.java
index 48db76be17..7a2a53d475 100644
--- a/fluent/src/main/java/io/kubernetes/client/fluent/Visitors.java
+++ b/fluent/src/main/java/io/kubernetes/client/fluent/Visitors.java
@@ -1,52 +1,35 @@
-/*
-Copyright 2022 The Kubernetes Authors.
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-http://www.apache.org/licenses/LICENSE-2.0
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
package io.kubernetes.client.fluent;
-import java.lang.reflect.Array;
+import java.util.Optional;
+import java.util.ArrayList;
+import java.lang.String;
import java.lang.reflect.GenericArrayType;
+import java.util.LinkedHashMap;
+import java.lang.reflect.Array;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.lang.reflect.TypeVariable;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.LinkedHashMap;
+import java.lang.Class;
import java.util.List;
+import java.util.Arrays;
import java.util.Map;
-import java.util.Optional;
-
-public final class Visitors {
+public final class Visitors{
private Visitors() {
- // Utility Class
+ //Utility Class
}
-
- public static Visitor newVisitor(Class type, Visitor visitor) {
+ public static Visitor newVisitor(Class type,Visitor visitor) {
return new DelegatingVisitor(type, visitor);
}
-
- protected static List getTypeArguments(
- Class baseClass, Class childClass) {
+ protected static List getTypeArguments(Class baseClass,Class childClass) {
Map resolvedTypes = new LinkedHashMap();
Type type = childClass;
// start walking up the inheritance hierarchy until we hit baseClass
- for (Class cl = getClass(type);
- cl != null && cl != Object.class && !baseClass.getName().equals(cl.getName());
- cl = getClass(type)) {
+ for (Class cl = getClass(type); cl != null && cl != Object.class
+ && !baseClass.getName().equals(cl.getName()); cl = getClass(type)) {
if (type instanceof Class) {
Class c = (Class) type;
- Optional nextInterface =
- baseClass.isInterface()
- ? getMatchingInterface(baseClass, c.getGenericInterfaces())
- : Optional.empty();
+ Optional nextInterface = baseClass.isInterface() ? getMatchingInterface(baseClass, c.getGenericInterfaces())
+ : Optional.empty();
if (nextInterface.isPresent()) {
type = nextInterface.get();
} else {
@@ -92,13 +75,9 @@ protected static List getTypeArguments(
}
return typeArgumentsAsClasses;
}
-
private static String getRawName(Type type) {
- return type instanceof ParameterizedType
- ? ((ParameterizedType) type).getRawType().getTypeName()
- : type.getTypeName();
+ return type instanceof ParameterizedType ? ((ParameterizedType) type).getRawType().getTypeName() : type.getTypeName();
}
-
private static Class getClass(Type type) {
if (type instanceof Class) {
return (Class) type;
@@ -116,16 +95,12 @@ private static Class getClass(Type type) {
return null;
}
}
-
- private static Optional getMatchingInterface(
- Class targetInterface, java.lang.reflect.Type... candidates) {
+ private static Optional getMatchingInterface(Class targetInterface,java.lang.reflect.Type... candidates) {
if (candidates == null || candidates.length == 0) {
return Optional.empty();
}
- Optional match =
- Arrays.stream(candidates)
- .filter(c -> getRawName(c).equals(targetInterface.getTypeName()))
- .findFirst();
+ Optional match = Arrays.stream(candidates).filter(c -> getRawName(c).equals(targetInterface.getTypeName()))
+ .findFirst();
if (match.isPresent()) {
return match;
} else {
@@ -141,4 +116,5 @@ private static Optional