PublishUpdate notifies all other replicas to update.
()
| 139 | |
| 140 | // PublishUpdate notifies all other replicas to update. |
| 141 | func (m *Manager) PublishUpdate() error { |
| 142 | return m.pubsub.Publish(PubsubEvent, []byte(m.id.String())) |
| 143 | } |
| 144 | |
| 145 | // updateInterval is used to determine a replicas state. |
| 146 | // If the replica was updated > the time, it's considered healthy. |