Skip to content

Commit 0b19cff

Browse files
author
Kubernetes Prow Robot
committed
Automated openapi generation from release-1.25
Signed-off-by: Kubernetes Prow Robot <k8s.ci.robot@gmail.com>
1 parent 0fe1169 commit 0b19cff

2,352 files changed

Lines changed: 128629 additions & 244212 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎fluent/src/main/java/io/kubernetes/client/fluent/BaseFluent.java‎

Lines changed: 46 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -12,17 +12,18 @@
1212
*/
1313
package io.kubernetes.client.fluent;
1414

15+
import java.util.AbstractMap;
1516
import java.util.ArrayList;
1617
import java.util.Arrays;
1718
import java.util.Collections;
1819
import java.util.LinkedHashSet;
1920
import java.util.List;
21+
import java.util.Map.Entry;
2022
import java.util.Objects;
2123
import java.util.Set;
2224
import java.util.stream.Collectors;
2325

24-
public class BaseFluent<F extends Fluent<F>>
25-
implements io.kubernetes.client.fluent.Fluent<F>, Visitable<F> {
26+
public class BaseFluent<F extends Fluent<F>> implements Fluent<F>, Visitable<F> {
2627
public static final String VISIT = "visit";
2728
public final VisitableMap _visitables = new VisitableMap();
2829

@@ -45,34 +46,34 @@ public class BaseFluent<F extends Fluent<F>>
4546
}
4647

4748
public static <T> List<T> build(
48-
java.util.List<? extends io.kubernetes.client.fluent.Builder<? extends T>> list) {
49+
List<? extends io.kubernetes.client.fluent.Builder<? extends T>> list) {
4950
return list == null
5051
? null
5152
: new ArrayList<T>(list.stream().map(Builder::build).collect(Collectors.toList()));
5253
}
5354

5455
public static <T> Set<T> build(
55-
java.util.Set<? extends io.kubernetes.client.fluent.Builder<? extends T>> set) {
56+
Set<? extends io.kubernetes.client.fluent.Builder<? extends T>> set) {
5657
return set == null
5758
? null
5859
: new LinkedHashSet<T>(set.stream().map(Builder::build).collect(Collectors.toSet()));
5960
}
6061

61-
public static <T> java.util.List<T> aggregate(java.util.List<? extends T>... lists) {
62+
public static <T> List<T> aggregate(List<? extends T>... lists) {
6263
return new ArrayList(
6364
Arrays.stream(lists).filter(Objects::nonNull).collect(Collectors.toList()));
6465
}
6566

66-
public static <T> java.util.Set<T> aggregate(java.util.Set<? extends T>... sets) {
67+
public static <T> Set<T> aggregate(Set<? extends T>... sets) {
6768
return new LinkedHashSet(
6869
Arrays.stream(sets).filter(Objects::nonNull).collect(Collectors.toSet()));
6970
}
7071

71-
public F accept(Visitor... visitors) {
72+
public F accept(io.kubernetes.client.fluent.Visitor... visitors) {
7273
return accept(Collections.emptyList(), visitors);
7374
}
7475

75-
public <V> F accept(Class<V> type, io.kubernetes.client.fluent.Visitor<V> visitor) {
76+
public <V> F accept(Class<V> type, Visitor<V> visitor) {
7677
return accept(
7778
Collections.emptyList(),
7879
new Visitor<V>() {
@@ -82,7 +83,7 @@ public Class<V> getType() {
8283
}
8384

8485
@Override
85-
public void visit(List<Object> path, V element) {
86+
public void visit(List<Entry<String, Object>> path, V element) {
8687
visitor.visit(path, element);
8788
}
8889

@@ -93,7 +94,15 @@ public void visit(V element) {
9394
});
9495
}
9596

96-
public F accept(java.util.List<Object> path, io.kubernetes.client.fluent.Visitor... visitors) {
97+
public F accept(
98+
List<Entry<String, Object>> path, io.kubernetes.client.fluent.Visitor... visitors) {
99+
return accept(path, "", visitors);
100+
}
101+
102+
public F accept(
103+
List<Entry<String, Object>> path,
104+
String currentKey,
105+
io.kubernetes.client.fluent.Visitor... visitors) {
97106
Arrays.stream(visitors)
98107
.map(v -> VisitorListener.wrap(v))
99108
.filter(v -> ((Visitor) v).canVisit(path, this))
@@ -103,18 +112,32 @@ public F accept(java.util.List<Object> path, io.kubernetes.client.fluent.Visitor
103112
((Visitor) v).visit(path, this);
104113
});
105114

106-
List<Object> copyOfPath = path != null ? new ArrayList(path) : new ArrayList<>();
107-
copyOfPath.add(this);
108-
List<Object> newPath = Collections.unmodifiableList(copyOfPath);
109-
110-
for (Visitable visitable : _visitables) {
111-
Arrays.stream(visitors)
112-
.filter(v -> v.getType() != null && v.getType().isAssignableFrom(visitable.getClass()))
113-
.forEach(v -> visitable.accept(newPath, v));
114-
Arrays.stream(visitors)
115-
.filter(v -> v.getType() == null || !v.getType().isAssignableFrom(visitable.getClass()))
116-
.forEach(v -> visitable.accept(newPath, v));
117-
}
115+
List<Entry<String, Object>> copyOfPath = path != null ? new ArrayList(path) : new ArrayList<>();
116+
copyOfPath.add(new AbstractMap.SimpleEntry<String, Object>(currentKey, this));
117+
118+
_visitables.forEach(
119+
(key, visitables) -> {
120+
List<Entry<String, Object>> newPath = Collections.unmodifiableList(copyOfPath);
121+
// Copy visitables to avoid ConcurrrentModificationException when Visitors add/remove
122+
// Visitables
123+
new ArrayList<>(visitables)
124+
.forEach(
125+
visitable -> {
126+
Arrays.stream(visitors)
127+
.filter(
128+
v ->
129+
v.getType() != null
130+
&& v.getType().isAssignableFrom(visitable.getClass()))
131+
.forEach(v -> visitable.accept(newPath, key, v));
132+
133+
Arrays.stream(visitors)
134+
.filter(
135+
v ->
136+
v.getType() == null
137+
|| !v.getType().isAssignableFrom(visitable.getClass()))
138+
.forEach(v -> visitable.accept(newPath, key, v));
139+
});
140+
});
118141
return (F) this;
119142
}
120143

@@ -125,7 +148,7 @@ public int hashCode() {
125148
return result;
126149
}
127150

128-
public boolean equals(java.lang.Object obj) {
151+
public boolean equals(Object obj) {
129152
if (this == obj) return true;
130153
if (obj == null) return false;
131154
if (getClass() != obj.getClass()) return false;

‎fluent/src/main/java/io/kubernetes/client/fluent/DelegatingVisitor.java‎

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,18 +13,19 @@
1313
package io.kubernetes.client.fluent;
1414

1515
import java.util.List;
16+
import java.util.Map.Entry;
1617
import java.util.function.Predicate;
1718

1819
public class DelegatingVisitor<T> implements Visitor<T> {
19-
DelegatingVisitor(Class<T> type, io.kubernetes.client.fluent.Visitor<T> delegate) {
20+
DelegatingVisitor(Class<T> type, Visitor<T> delegate) {
2021
this.type = type;
2122
this.delegate = delegate;
2223
}
2324

24-
private final java.lang.Class<T> type;
25-
private final io.kubernetes.client.fluent.Visitor<T> delegate;
25+
private final Class<T> type;
26+
private final Visitor<T> delegate;
2627

27-
public java.lang.Class<T> getType() {
28+
public Class<T> getType() {
2829
return type;
2930
}
3031

@@ -36,11 +37,11 @@ public int order() {
3637
return delegate.order();
3738
}
3839

39-
public void visit(List<Object> path, T target) {
40+
public void visit(List<Entry<String, Object>> path, T target) {
4041
delegate.visit(path, target);
4142
}
4243

43-
public <F> Predicate<java.util.List<java.lang.Object>> getRequirement() {
44+
public <F> Predicate<List<Entry<String, Object>>> getRequirement() {
4445
return delegate.getRequirement();
4546
}
4647
}

‎fluent/src/main/java/io/kubernetes/client/fluent/PathAwareTypedVisitor.java‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
package io.kubernetes.client.fluent;
1414

1515
import java.util.List;
16+
import java.util.Map.Entry;
1617

1718
public class PathAwareTypedVisitor<V, P> extends TypedVisitor<V> {
1819
PathAwareTypedVisitor() {
@@ -26,19 +27,19 @@ public class PathAwareTypedVisitor<V, P> extends TypedVisitor<V> {
2627
}
2728

2829
private final Class<V> type;
29-
private final java.lang.Class<P> parentType;
30+
private final Class<P> parentType;
3031

3132
public void visit(V element) {}
3233

33-
public void visit(List<Object> path, V element) {
34+
public void visit(List<Entry<String, Object>> path, V element) {
3435
visit(element);
3536
}
3637

37-
public P getParent(java.util.List<java.lang.Object> path) {
38+
public P getParent(List<Entry<String, Object>> path) {
3839
return path.size() - 1 >= 0 ? (P) path.get(path.size() - 1) : null;
3940
}
4041

41-
public java.lang.Class<P> getParentType() {
42+
public Class<P> getParentType() {
4243
return parentType;
4344
}
4445
}

‎fluent/src/main/java/io/kubernetes/client/fluent/Visitable.java‎

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414

1515
import java.util.Collections;
1616
import java.util.List;
17+
import java.util.Map.Entry;
1718

1819
public interface Visitable<T> {
1920
default <V> T accept(Class<V> type, Visitor<V> visitor) {
@@ -40,7 +41,15 @@ default T accept(io.kubernetes.client.fluent.Visitor... visitors) {
4041
return getTarget(this);
4142
}
4243

43-
default T accept(List<Object> path, io.kubernetes.client.fluent.Visitor... visitors) {
44+
default T accept(
45+
List<Entry<String, Object>> path, io.kubernetes.client.fluent.Visitor... visitors) {
46+
return accept(path, "", visitors);
47+
}
48+
49+
default T accept(
50+
List<Entry<String, Object>> path,
51+
String currentKey,
52+
io.kubernetes.client.fluent.Visitor... visitors) {
4453
for (Visitor visitor : visitors) {
4554
if (visitor.canVisit(path, this)) {
4655
visitor.visit(path, this);

‎fluent/src/main/java/io/kubernetes/client/fluent/VisitableMap.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,23 +21,23 @@
2121
import java.util.stream.Collectors;
2222

2323
public class VisitableMap extends HashMap<String, List<Visitable<?>>>
24-
implements Iterable<io.kubernetes.client.fluent.Visitable<?>> {
25-
public java.util.List<io.kubernetes.client.fluent.Visitable<?>> get(Object key) {
24+
implements Iterable<Visitable<?>> {
25+
public List<Visitable<?>> get(Object key) {
2626
if (!containsKey(key)) {
2727
put(String.valueOf(key), new ArrayList());
2828
}
2929
return super.get(key);
3030
}
3131

32-
public java.util.List<io.kubernetes.client.fluent.Visitable<?>> aggregate() {
32+
public List<Visitable<?>> aggregate() {
3333
return values().stream().flatMap(l -> l.stream()).collect(Collectors.toList());
3434
}
3535

36-
public Iterator<io.kubernetes.client.fluent.Visitable<?>> iterator() {
36+
public Iterator<Visitable<?>> iterator() {
3737
return aggregate().iterator();
3838
}
3939

40-
public void forEach(Consumer<? super io.kubernetes.client.fluent.Visitable<?>> action) {
40+
public void forEach(Consumer<? super Visitable<?>> action) {
4141
aggregate().forEach(action);
4242
}
4343

‎fluent/src/main/java/io/kubernetes/client/fluent/Visitor.java‎

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414

1515
import java.lang.reflect.Method;
1616
import java.util.List;
17+
import java.util.Map.Entry;
1718
import java.util.function.Predicate;
1819

1920
@FunctionalInterface
@@ -32,11 +33,11 @@ default int order() {
3233
return 0;
3334
}
3435

35-
default void visit(List<Object> path, T element) {
36+
default void visit(List<Entry<String, Object>> path, T element) {
3637
visit(element);
3738
}
3839

39-
default <F> Boolean canVisit(java.util.List<java.lang.Object> path, F target) {
40+
default <F> Boolean canVisit(List<Entry<String, Object>> path, F target) {
4041
if (target == null) {
4142
return false;
4243
}
@@ -56,7 +57,7 @@ default <F> Boolean canVisit(java.util.List<java.lang.Object> path, F target) {
5657
}
5758
}
5859

59-
default <F> java.lang.Boolean hasVisitMethodMatching(F target) {
60+
default <F> Boolean hasVisitMethodMatching(F target) {
6061
for (Method method : getClass().getMethods()) {
6162
if (!method.getName().equals("visit") || method.getParameterTypes().length != 1) {
6263
continue;
@@ -71,24 +72,27 @@ default <F> java.lang.Boolean hasVisitMethodMatching(F target) {
7172
return false;
7273
}
7374

74-
default <T> Predicate<java.util.List<java.lang.Object>> getRequirement() {
75+
default <T> Predicate<List<Entry<String, Object>>> getRequirement() {
7576
return p -> true;
7677
}
7778

78-
default <I> java.util.function.Predicate<java.util.List<java.lang.Object>> hasItem(
79-
java.lang.Class<I> type, java.util.function.Predicate<I> predicate) {
80-
Predicate<List<Object>> result =
81-
l -> l.stream().filter(i -> type.isInstance(i)).map(i -> type.cast(i)).anyMatch(predicate);
79+
default <I> Predicate<List<Entry<String, Object>>> hasItem(
80+
Class<I> type, Predicate<I> predicate) {
81+
Predicate<List<Entry<String, Object>>> result =
82+
l ->
83+
l.stream()
84+
.map(Entry::getValue)
85+
.filter(i -> type.isInstance(i))
86+
.map(i -> type.cast(i))
87+
.anyMatch(predicate);
8288
return result;
8389
}
8490

85-
default <P> Visitor<T> addRequirement(
86-
java.lang.Class<P> type, java.util.function.Predicate<P> predicate) {
91+
default <P> Visitor<T> addRequirement(Class<P> type, Predicate<P> predicate) {
8792
return addRequirement(predicate);
8893
}
8994

90-
default io.kubernetes.client.fluent.Visitor<T> addRequirement(
91-
java.util.function.Predicate predicate) {
95+
default Visitor<T> addRequirement(Predicate predicate) {
9296
return new DelegatingVisitor(getType(), this) {
9397
@Override
9498
public Predicate<List<Object>> getRequirement() {

‎fluent/src/main/java/io/kubernetes/client/fluent/VisitorListener.java‎

Lines changed: 8 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@
1414

1515
import java.util.HashSet;
1616
import java.util.List;
17+
import java.util.Map.Entry;
1718
import java.util.ServiceLoader;
1819
import java.util.Set;
1920
import java.util.concurrent.atomic.AtomicBoolean;
@@ -22,7 +23,7 @@ public interface VisitorListener {
2223
static AtomicBoolean loaded = new AtomicBoolean();
2324
static Set<VisitorListener> listeners = new HashSet<>();
2425

25-
public static java.util.Set<VisitorListener> getListeners() {
26+
public static Set<VisitorListener> getListeners() {
2627
if (loaded.get()) {
2728
return listeners;
2829
}
@@ -44,25 +45,21 @@ public static java.util.Set<VisitorListener> getListeners() {
4445
return listeners;
4546
}
4647

47-
public static <T> io.kubernetes.client.fluent.Visitor<T> wrap(
48-
io.kubernetes.client.fluent.Visitor<T> visitor) {
48+
public static <T> Visitor<T> wrap(Visitor<T> visitor) {
4949
return VisitorWiretap.create(visitor, getListeners());
5050
}
5151

52-
public static void register(io.kubernetes.client.fluent.VisitorListener listener) {
52+
public static void register(VisitorListener listener) {
5353
listeners.add(listener);
5454
}
5555

56-
public static void unregister(io.kubernetes.client.fluent.VisitorListener listener) {
56+
public static void unregister(VisitorListener listener) {
5757
listeners.add(listener);
5858
}
5959

60-
default <T> void beforeVisit(
61-
io.kubernetes.client.fluent.Visitor<T> v, List<Object> path, T target) {}
60+
default <T> void beforeVisit(Visitor<T> v, List<Entry<String, Object>> path, T target) {}
6261

63-
default <T> void afterVisit(
64-
io.kubernetes.client.fluent.Visitor<T> v, java.util.List<java.lang.Object> path, T target) {}
62+
default <T> void afterVisit(Visitor<T> v, List<Entry<String, Object>> path, T target) {}
6563

66-
default <V, T> void onCheck(
67-
io.kubernetes.client.fluent.Visitor<V> v, boolean canVisit, T target) {}
64+
default <V, T> void onCheck(Visitor<V> v, boolean canVisit, T target) {}
6865
}

0 commit comments

Comments
 (0)