The highest tagged major version is v2.

nats

package

v0.1.0 Latest Latest Go to latest Published: Jul 29, 2019 License: Apache-2.0 Imports: 4 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Stream struct {
	subscriber.Base
	// contains filtered or unexported fields
}

Stream for NATS queue

func MustNewStream(topics []string, url string, options ...nats.Option) *Stream

MustNewStream object

func NewStream(topics []string, url string, options ...nats.Option) (*Stream, error)

NewStream object

func (s *Stream) Close() error

Close nats client

func (s *Stream) Send(messages ...interface{}) (err error)

Send message

func (s *Stream) Write(data []byte) (err error)

Write binary message

type Subscriber struct {
	subscriber.Base
	// contains filtered or unexported fields
}

Subscriber for NATS queue

func MustNewSubscriber(url, group string, topics []string, options ...nats.Option) *Subscriber

MustNewSubscriber object

func NewSubscriber(url, group string, topics []string, options ...nats.Option) (*Subscriber, error)

NewSubscriber object

func (s *Subscriber) Close() error

Close nats client

func (s *Subscriber) Listen() (_ error)

Listen kafka consumer