TopicUpdateSubCnt refreshes denormalized topic subscriber count.
(topic string)
| 123 | TopicUpdateOnMessage(topic string, msg *t.Message) error |
| 124 | // TopicUpdateSubCnt refreshes denormalized topic subscriber count. |
| 125 | TopicUpdateSubCnt(topic string) error |
| 126 | // TopicUpdate updates topic record. |
| 127 | TopicUpdate(topic string, update map[string]any) error |
| 128 | // TopicOwnerChange updates topic's owner |
no outgoing calls