From 1cd96e496b2db50d1eb2c574ba85a78da7f1fdd8 Mon Sep 17 00:00:00 2001 From: fmterrors Date: Tue, 6 Oct 2026 23:26:03 +0800 Subject: [PATCH] chore: fix some function names in comment (#12517) Signed-off-by: fmterrors --- core/services/jobs/sse.go | 2 +- core/services/messaging/subjects.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/services/jobs/sse.go b/core/services/jobs/sse.go index f66d5ea33..fe2981ec2 100644 --- a/core/services/jobs/sse.go +++ b/core/services/jobs/sse.go @@ -10,7 +10,7 @@ import ( "github.com/labstack/echo/v4" ) -// SSEBridge provides an HTTP handler that bridges NATS progress events to SSE. +// SSEHandler provides an HTTP handler that bridges NATS progress events to SSE. // This follows the notetaker pattern: subscribe to NATS, forward to SSE client. func (d *Dispatcher) SSEHandler() echo.HandlerFunc { return func(c echo.Context) error { diff --git a/core/services/messaging/subjects.go b/core/services/messaging/subjects.go index 89fab4b6b..e72222fc2 100644 --- a/core/services/messaging/subjects.go +++ b/core/services/messaging/subjects.go @@ -292,7 +292,7 @@ func SubjectCacheInvalidateCollection(name string) string { return "cache.invalidate.collections." + sanitizeSubjectToken(name) } -// SyncedMap State Sync (Pub/Sub — broadcast to all frontends) +// SubjectSyncStateDelta returns the SyncedMap state sync subject (Pub/Sub — broadcast to all frontends). // // The reusable syncstate.SyncedMap component publishes a {op,key,value} delta on // this subject whenever a replica mutates a piece of cross-replica in-memory