Skip to content

Commit afbaab0

Browse files
author
datacore-bolt-ci
committed
ci(stability): merge the develop branch
2 parents 6e9c15c + 247aac7 commit afbaab0

File tree

4 files changed

+17
-13
lines changed

4 files changed

+17
-13
lines changed

call-home/src/bin/callhome/collector/k8s_client.rs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,10 @@ impl K8sClient {
3333
nodes_count += node_list.items.len();
3434

3535
match node_list.metadata.continue_ {
36-
Some(ref token) => list_params = list_params.continue_token(token),
37-
None => break,
36+
Some(ref token) if !token.is_empty() => {
37+
list_params = list_params.continue_token(token)
38+
}
39+
_ => break,
3840
}
3941
}
4042

k8s/supportability/src/collect/k8s_resources/client.rs

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -198,8 +198,10 @@ impl ClientSet {
198198
let mut result = pods_api.list(&list_params).await?;
199199
pods.append(&mut result.items);
200200
match result.metadata.continue_ {
201-
None => break,
202-
Some(token) => list_params = list_params.continue_token(token.as_str()),
201+
Some(ref token) if !token.is_empty() => {
202+
list_params = list_params.continue_token(token)
203+
}
204+
_ => break,
203205
};
204206
}
205207
Ok(pods)
@@ -352,8 +354,8 @@ impl ClientSet {
352354
.collect(),
353355
);
354356
match vscs.metadata.continue_ {
355-
Some(token) if !token.is_empty() => {
356-
list_params = list_params.continue_token(token.as_str())
357+
Some(ref token) if !token.is_empty() => {
358+
list_params = list_params.continue_token(token)
357359
}
358360
_ => break,
359361
};
@@ -380,8 +382,8 @@ impl ClientSet {
380382
let mut result = events_api.list(&list_params).await?;
381383
events.append(&mut result.items);
382384
match result.metadata.continue_ {
383-
Some(token) if !token.is_empty() => {
384-
list_params = list_params.continue_token(token.as_str())
385+
Some(ref token) if !token.is_empty() => {
386+
list_params = list_params.continue_token(token)
385387
}
386388
_ => break,
387389
};

k8s/upgrade/src/common/kube/client.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -323,10 +323,10 @@ where
323323
resources.extend(resource_list);
324324

325325
match maybe_token {
326-
Some(ref token) => {
326+
Some(ref token) if !token.is_empty() => {
327327
list_params = list_params.continue_token(token);
328328
}
329-
None => break,
329+
_ => break,
330330
}
331331
}
332332

@@ -355,10 +355,10 @@ where
355355
resources.extend(resource_list);
356356

357357
match maybe_token {
358-
Some(ref token) => {
358+
Some(ref token) if !token.is_empty() => {
359359
list_params = list_params.continue_token(token);
360360
}
361-
None => break,
361+
_ => break,
362362
}
363363
}
364364

0 commit comments

Comments
 (0)