From 124d1262b7bf3bbbdc3c3d3ccd0bfdd6041fdf01 Mon Sep 17 00:00:00 2001 From: Jon Ayers Date: Tue, 26 May 2026 20:17:15 +0000 Subject: [PATCH] fix(enterprise/coderd): rename setNATSPeers and escalate to Critical --- enterprise/coderd/coderd.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/enterprise/coderd/coderd.go b/enterprise/coderd/coderd.go index 41d851b56c..0070556a11 100644 --- a/enterprise/coderd/coderd.go +++ b/enterprise/coderd/coderd.go @@ -67,7 +67,7 @@ import ( "github.com/coder/quartz" ) -func registerReplicaNATSPeerCallback(ctx context.Context, logger slog.Logger, rm *replicasync.Manager, ps *natspubsub.Pubsub) { +func setNATSPeers(ctx context.Context, logger slog.Logger, rm *replicasync.Manager, ps *natspubsub.Pubsub) { rm.AddCallback(func() { addresses := make([]string, 0) for _, replica := range rm.AllPrimary() { @@ -675,11 +675,10 @@ func New(ctx context.Context, options *Options) (_ *API, err error) { } replicaManagerPtr.Store(api.replicaManager) if api.AGPL.Experiments.Enabled(codersdk.ExperimentNATSPubsub) { - natsPubsub, ok := api.Pubsub.(*natspubsub.Pubsub) - if !ok { - api.Logger.Warn(ctx, "nats pubsub experiment enabled but pubsub is not *nats.Pubsub") + if natsPubsub, ok := api.Pubsub.(*natspubsub.Pubsub); ok { + setNATSPeers(api.ctx, api.Logger, api.replicaManager, natsPubsub) } else { - registerReplicaNATSPeerCallback(api.ctx, api.Logger, api.replicaManager, natsPubsub) + api.Logger.Critical(ctx, "nats pubsub experiment enabled but pubsub is not *nats.Pubsub") } } if api.DERPServer != nil {