subscriber

Documentation

Index

• type INATSConn
  • func NewNATSConn(conn *nats.Conn) INATSConn
• type NATSConn
  • func (c *NATSConn) SubscribeSync(subject string) (*nats.Subscription, error)
• type NATSSubscriber
  • func NewSubscriber(conn INATSConn, logger logrus.FieldLogger) *NATSSubscriber
  • func (s *NATSSubscriber) SubscribeToSubject(subject string) error
• type Subscriber

Types

type INATSConn

type INATSConn interface {
	SubscribeSync(subject string) (*nats.Subscription, error)
}

func NewNATSConn

func NewNATSConn(conn *nats.Conn) INATSConn

type NATSConn

type NATSConn struct {
	// contains filtered or unexported fields
}

func (*NATSConn) SubscribeSync

func (c *NATSConn) SubscribeSync(subject string) (*nats.Subscription, error)

type NATSSubscriber

type NATSSubscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(conn INATSConn, logger logrus.FieldLogger) *NATSSubscriber

func (*NATSSubscriber) SubscribeToSubject

func (s *NATSSubscriber) SubscribeToSubject(subject string) error

type Subscriber

type Subscriber interface {
	SubscribeToSubject(subject string) error
}