Documentation ¶
Overview ¶
Package nats contains NATS-specific message repository implementation.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMessageRepository ¶
func NewMessageRepository(nc *broker.Conn) writer.MessageRepository
NewMessageRepository instantiates NATS message repository. Note that the repository will not truly persist messages, but instead they will be published to the topic and made available for persisting by all interested parties, i.e. the message-writer service.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.