Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NatsEmailSubscriber ¶
type NatsEmailSubscriber struct {
// contains filtered or unexported fields
}
func NewEmailSubscriber ¶
func NewEmailSubscriber( host, port string, logger *logrus.Entry, options ...gnats.Option, ) (*NatsEmailSubscriber, error)
NewEmailSubscriber connects to nats
func (*NatsEmailSubscriber) Start ¶
func (n *NatsEmailSubscriber) Start( sub string, client email.EmailHandler, ) error
Start starts the subscription server and handles the incoming stock order data.
type NatsGithubSubscriber ¶
type NatsGithubSubscriber struct {
// contains filtered or unexported fields
}
func NewGithubSubscriber ¶
func NewGithubSubscriber( host, port string, logger *logrus.Entry, options ...gnats.Option, ) (*NatsGithubSubscriber, error)
NewGithubSubscriber connects to nats
func (*NatsGithubSubscriber) Start ¶
func (n *NatsGithubSubscriber) Start( sub string, client issue.IssueTracker, ) error
Start starts the subscription server and handles the incoming stock order data.
func (*NatsGithubSubscriber) Stop ¶
func (n *NatsGithubSubscriber) Stop() error
Stop stops the server
Click to show internal directories.
Click to hide internal directories.