gobus/pkg/types/itopic.go

package types

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

// ITopic -- интерфейс топика шины данных
type ITopic interface {
	// Name -- возвращает имя топика
	Name() alias.TopicName
	// Set -- устанавливает содержимое топика
	Set(*netapi.TopicMsg) error
	// Get -- возвращает содержимое топика
	Get() *netapi.TopicMsg
	// Stat -- возвращает статистику топика
	Stat() ITopicStat
	// Subscribe -- подписывает клиента
	Subscribe(IClientProxy) error
	// Unsubscribe -- отписывает клиента
	Unsubscribe(alias.ClientName)
}