Forgot queue bound

Signed-off-by: Matei David <[email protected]>
linkerd · Jan 10, 2024 · 55c7185 · 55c7185
1 parent 498ef33
commit 55c7185
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/controller/api/destination/external-workload/endpoints_controller.go b/controller/api/destination/external-workload/endpoints_controller.go
@@ -98,7 +98,7 @@ func NewEndpointsController(k8sAPI *k8s.API, hostname, controllerNs string, stop
 	ec := &EndpointsController{
 		k8sAPI: k8sAPI,
 		updates: updateQueue{
-			queue: make(chan queueUpdate),
+			queue: make(chan queueUpdate, updateQueueCapacity),
 			queueMetrics: queueMetrics{
 				queueLength:  queueLengthGauge,
 				queueUpdates: queueUpdateCounter,