kern/v4/d2/lti/bus_spec/ikernel_bus.go

// package bus_spec -- спецификации для работы с шиной
package bus_spec

import (
	"gitp78su.ipnodns.ru/svi/kern/v4/d0"
	"gitp78su.ipnodns.ru/svi/kern/v4/d1"
	"gitp78su.ipnodns.ru/svi/kern/v4/d2/lti/bus_ent/topic"
)

// IKernelBus -- шина сообщений ядра.
//
//	Публикация и запрос требуют параметров на _передачу_.
//	Подписка и обслуживание входящих запросов требует _обработчиков_.
type IKernelBus interface {
	// Publish -- публикует сообщение в шину
	Publish(topic *topic.LTopic, binMsg []byte) *d0.Result[d0.Bool]
	// SendRequest -- выполняет запрос по указанному топику
	SendRequest(topic *topic.LTopic, binReq []byte) *d0.Result[[]byte]

	// Subscribe -- подписывает обработчик на топик
	Subscribe(IBusHandlerSubscribe) *d0.Result[d0.Bool]
	// Unsubscribe -- отписывается от топика
	Unsubscribe(IBusHandlerSubscribe)
	// RegisterServe -- Регистрирует обработчик на обслуживание входящих запросов
	RegisterServe(IBusHandlerServe) *d0.Result[d0.Bool]

	// IsWork -- возвращает признак работы шины
	IsWork() d0.Bool
	// Log -- возвращает буферный лог
	Log() *d1.LogBuf
}

// IBusClient -- интерфейс клиента к шину.
type IBusClient interface {
	IKernelBus
}