Versions in this module Expand all Collapse all v1 v1.0.0 Nov 18, 2023 Changes in this version + type Consumer struct + func (c *Consumer) Run() + func (c *Consumer) Stop() + type Engine struct + func NewEngine(logger *slog.Logger) *Engine + func (e *Engine) GetConsumer(topicName string, handler func(interface{})) (*Consumer, error) + func (e *Engine) GetProducer(topicName string) (*Producer, error) + func (e *Engine) RegisterTopic(topicName string, bufferSize int) error + func (e *Engine) Stop() + func (e *Engine) TopicExists(topicName string) bool + type Producer struct + func (p *Producer) Publish(message interface{}) error + func (p *Producer) Stop() + type TopicClosedError struct + func (e TopicClosedError) Error() string + type TopicExistsError struct + func (e TopicExistsError) Error() string