Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NATSEventBus ¶
type NATSEventBus struct {
// contains filtered or unexported fields
}
func NewNATSEventBus ¶
func NewNATSEventBus(host, port string) *NATSEventBus
func (*NATSEventBus) Close ¶
func (eb *NATSEventBus) Close()
func (*NATSEventBus) Publish ¶
func (eb *NATSEventBus) Publish(events ...domain.IDomainEvent) error
func (*NATSEventBus) RegisterAsyncSubscriber ¶
func (eb *NATSEventBus) RegisterAsyncSubscriber(topic string, subscriber domain.Subscriber) error
Source Files
Click to show internal directories.
Click to hide internal directories.