shishantbiswas/coder
1
0
Fork 0
mirror of https://github.com/coder/coder.git synced 2026-06-02 20:48:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(enterprise/coderd): rename setNATSPeers and escalate to Critical

Browse Source
This commit is contained in:
Jon Ayers
2026-05-26 20:17:15 +00:00
parent 74c38d7baa
commit 124d1262b7
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
enterprise/coderd/coderd.go
+4 -5
View File
@@ -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 {