Skip to content

Commit

Permalink
TMP
Browse files Browse the repository at this point in the history
  • Loading branch information
hakman committed Sep 20, 2023
1 parent e8be137 commit c606aa8
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions pkg/dump/dumper.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,23 +113,28 @@ func (d *logDumper) DumpAllNodes(ctx context.Context, nodes corev1.NodeList, add
node := &nodes.Items[i]

if _, ok := node.Labels["node-role.kubernetes.io/master"]; ok {
log.Printf("found special node: %s", node.Name)
special = append(special, node)
continue
}
if _, ok := node.Labels["node-role.kubernetes.io/control-plane"]; ok {
log.Printf("found special node: %s", node.Name)
special = append(special, node)
continue
}
if _, ok := node.Labels["node-role.kubernetes.io/api-server"]; ok {
log.Printf("found special node: %s", node.Name)
special = append(special, node)
continue
}

log.Printf("found regular node: %s", node.Name)
regular = append(regular, node)
}

for i := range special {
node := &nodes.Items[i]
log.Printf("dumping special node: %s", node.Name)
err := d.dumpRegistered(ctx, node)
if err != nil {
log.Printf("could not dump node %s: %v", node.Name, err)
Expand All @@ -148,6 +153,7 @@ func (d *logDumper) DumpAllNodes(ctx context.Context, nodes corev1.NodeList, add
return nil
}
node := &nodes.Items[i]
log.Printf("dumping regular node: %s", node.Name)
err := d.dumpRegistered(ctx, node)
if err != nil {
log.Printf("could not dump node %s: %v", node.Name, err)
Expand Down

0 comments on commit c606aa8

Please sign in to comment.