|
37 | 37 | ) |
38 | 38 |
|
39 | 39 | const ( |
40 | | - adminPort = 19000 // TODO: make this configurable until EG support |
41 | | - rateLimitDebugPort = 6070 // TODO: make this configurable until EG support |
42 | | - containerName = "envoy" // TODO: make this configurable until EG support |
| 40 | + adminPort = 19000 // TODO: make this configurable until EG support |
| 41 | + rateLimitDebugPort = 6070 // TODO: make this configurable until EG support |
43 | 42 | ) |
44 | 43 |
|
45 | 44 | type aggregatedConfigDump map[string]map[string]protoreflect.ProtoMessage |
@@ -67,7 +66,8 @@ func retrieveConfigDump(args []string, includeEds bool, configType envoyConfigTy |
67 | 66 | return nil, err |
68 | 67 | } |
69 | 68 |
|
70 | | - podConfigDumps := make(aggregatedConfigDump, 0) |
| 69 | + podConfigDumps := make(aggregatedConfigDump) |
| 70 | + mu := sync.Mutex{} |
71 | 71 | // Initialize the map with namespaces |
72 | 72 | for _, pod := range pods { |
73 | 73 | if _, ok := podConfigDumps[pod.Namespace]; !ok { |
@@ -99,7 +99,9 @@ func retrieveConfigDump(args []string, includeEds bool, configType envoyConfigTy |
99 | 99 | return |
100 | 100 | } |
101 | 101 |
|
| 102 | + mu.Lock() |
102 | 103 | podConfigDumps[pod.Namespace][pod.Name] = configDump |
| 104 | + mu.Unlock() |
103 | 105 | }() |
104 | 106 | } |
105 | 107 |
|
@@ -167,7 +169,7 @@ func fetchRunningEnvoyPods(c kube.CLIClient, nn types.NamespacedName, labelSelec |
167 | 169 | pods = podList.Items |
168 | 170 | } |
169 | 171 |
|
170 | | - podsNamespacedNames := []types.NamespacedName{} |
| 172 | + podsNamespacedNames := make([]types.NamespacedName, 0, len(pods)) |
171 | 173 | for _, pod := range pods { |
172 | 174 | podNsName := utils.NamespacedName(&pod) |
173 | 175 | if pod.Status.Phase != "Running" { |
|
0 commit comments