feat: Additional admin API cleanup to remove unnecessary outputs, add…

… transport types to lieceners, and add max queue size
driskell · Mar 1, 2025 · 788e098 · 788e098
1 parent 1f97a54
commit 788e098
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/lc-lib/receiver/api.go b/lc-lib/receiver/api.go
@@ -33,6 +33,7 @@ func (a *apiStatus) Update() error {
 	a.SetEntry("activeConnections", api.Number(len(a.r.connectionStatus)))
 	a.SetEntry("queuePayloads", api.Number(len(a.r.spool)))
 	a.SetEntry("queueSize", api.Number(a.r.spoolSize))
+	a.SetEntry("maxQueueSize", api.Number(a.r.generalConfig.MaxQueueSize))
 	a.r.connectionLock.RUnlock()
 
 	return nil

diff --git a/lc-lib/receiver/pool.go b/lc-lib/receiver/pool.go
@@ -420,6 +420,8 @@ func (r *Pool) updateReceivers(newConfig *config.Config) {
 				newReceivers[newReceiversByListen[listen]] = &poolReceiverStatus{config: cfgEntry, listen: listen, active: true}
 				receiverApi := &api.KeyValue{}
 				receiverApi.SetEntry("listen", api.String(listen))
+				receiverApi.SetEntry("transport", api.String(cfgEntry.Transport))
+				receiverApi.SetEntry("name", api.String(cfgEntry.Name))
 				if newReceiversByListen[listen].SupportsAck() {
 					// Only applies if supports ack
 					receiverApi.SetEntry("maxPendingPayloads", api.Number(cfgEntry.MaxPendingPayloads))