Documentation ¶
Overview ¶
*
* * @author nghiatc * @since Dec 6, 2019
*
* * @author nghiatc * @since Dec 17, 2019
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NSubscriber ¶
type NSubscriber struct { Name string Subject string Url string Auth string Opts []nats.Option Conn *nats.Conn Subt *nats.Subscription }
func NewNSubscriber ¶
func NewNSubscriber(name string) *NSubscriber
func (*NSubscriber) Start ¶
func (ns *NSubscriber) Start(processChan chan *nats.Msg) error
Click to show internal directories.
Click to hide internal directories.