nats

package
v0.0.0-...-fc26a1d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 14, 2023 License: BSD-2-Clause Imports: 8 Imported by: 0

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.

func (*NatsEmailSubscriber) Stop

func (n *NatsEmailSubscriber) Stop() error

Stop stops the server

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL