pubsub

Documentation

Index

• func CreateTopic(topic misc.TopicId)
• func DeleteTopic(topic misc.TopicId)
• func SendMessage(msg Message)
• func TopicExists(topic misc.TopicId) bool
• type Consumer
  • func NewConsumer(log *slog.Logger, groupID string, topic misc.TopicId, ...) *Consumer
  • func (c *Consumer) AddTopic(topic misc.TopicId)
  • func (c *Consumer) RemoveTopic(topic misc.TopicId)
  • func (c *Consumer) StartConsumer(v Message)
• type Message
• type TopicMessageHandler

Functions

func CreateTopic

func CreateTopic(topic misc.TopicId)

func DeleteTopic

func DeleteTopic(topic misc.TopicId)

func SendMessage

func SendMessage(msg Message)

func TopicExists

func TopicExists(topic misc.TopicId) bool

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(log *slog.Logger, groupID string, topic misc.TopicId, msgHandler TopicMessageHandler) *Consumer

func (*Consumer) AddTopic

func (c *Consumer) AddTopic(topic misc.TopicId)

func (*Consumer) RemoveTopic

func (c *Consumer) RemoveTopic(topic misc.TopicId)

func (*Consumer) StartConsumer

func (c *Consumer) StartConsumer(v Message)

type Message

type Message interface {
	String() string
	Topic() misc.TopicId
	Unmarshal([]byte)
}

type TopicMessageHandler

type TopicMessageHandler interface {
	OnMessageFromTopic(msg Message)
}