gobus/pkg/types/idict_topic.go

package types

import (
	"p78git.ddns.net/svi/gobus/api/netapi"
	"p78git.ddns.net/svi/gobus/pkg/alias"
)

// IDictTopic -- потокобезопасный словарь топиков
type IDictTopic interface {
	// Public -- публикует топик в словрь
	Public(*netapi.TopicMsg) error
	// Get -- возвращает топик по имени
	Get(alias.TopicName) ITopic
	// Len -- возвращает количество топиков
	Len() int
	// Size -- возвращает размер всех топиков
	Size() int
	// Subscribe -- подписывает клиента на топики по шаблону
	Subscribe(IClientProxy) error
	// Unsubscribe -- отписывает клиента от топиков
	Unsubscribe(IClientProxy) error
}