Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessagingService ¶
type MessagingService struct {
// contains filtered or unexported fields
}
MessagingService implements the core pub/sub service.
func NewMessagingService ¶
func NewMessagingService(config config.Config, logger *zap.Logger) *MessagingService
func (*MessagingService) Close ¶
func (s *MessagingService) Close()
Close stops the server and wait for them to exit.
func (*MessagingService) Serve ¶
func (s *MessagingService) Serve() (string, error)
Serve starts the service and returns the server address.
Note this won't always be the same as the configured address, such as if port 0 used the system will assign a free port.
Click to show internal directories.
Click to hide internal directories.