Method PushUpdate

base/database/controller.go:197–205

PushUpdate pushes a record update to subscribers. The caller must hold the record's lock when calling PushUpdate.

(r record.Record)

// The caller must hold the record's lock when calling
// PushUpdate.
func (c *Controller) PushUpdate(r record.Record) {
	if c != nil {
		if shuttingDown.IsSet() {
			return
		}

		c.notifySubscribers(r)
	}
}

func (c *Controller) addSubscription(sub *Subscription) {
	if shuttingDown.IsSet() {