Method publishCacheInvalidate

core/services/galleryop/service.go:192–202

publishCacheInvalidate broadcasts a cache invalidation event so peer replicas refresh whatever in-memory state mirrors disk. No-op when natsClient is not wired (standalone mode).

(subject string, evt messaging.CacheInvalidateEvent)

// replicas refresh whatever in-memory state mirrors disk. No-op when
// natsClient is not wired (standalone mode).
func (g *GalleryService) publishCacheInvalidate(subject string, evt messaging.CacheInvalidateEvent) {
	g.Lock()
	nc := g.natsClient
	g.Unlock()
	if nc == nil {
		return
	}
	if err := nc.Publish(subject, evt); err != nil {
		xlog.Warn("Failed to broadcast cache invalidation", "subject", subject, "error", err)
	}
}

// BroadcastModelsChanged notifies peer replicas that a model config was
// created, edited, or removed out-of-band of the gallery install/delete