idict_topic.go 789 B

12345678910111213141516171819202122
  1. package types
  2. import (
  3. "p78git.ddns.net/svi/gobus/api/netapi"
  4. "p78git.ddns.net/svi/gobus/pkg/alias"
  5. )
  6. // IDictTopic -- потокобезопасный словарь топиков
  7. type IDictTopic interface {
  8. // Public -- публикует топик в словрь
  9. Public(*netapi.TopicMsg) error
  10. // Get -- возвращает топик по имени
  11. Get(alias.TopicName) ITopic
  12. // Len -- возвращает количество топиков
  13. Len() int
  14. // Size -- возвращает размер всех топиков
  15. Size() int
  16. // Subscribe -- подписывает клиента на топики по шаблону
  17. Subscribe(IClientProxy) error
  18. // Unsubscribe -- отписывает клиента от топиков
  19. Unsubscribe(IClientProxy) error
  20. }