The highest tagged major version is v2.

natstream

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/geniusrabbit/notificationcenter

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Stream
- func MustNewStream(url, clusterID, clientID, topic string, options ...nstream.Option) *Stream
- func NewStream(url, clusterID, clientID, topic string, options ...nstream.Option) (*Stream, error)
type Subscriber
- func MustNewSubscriber(url, clusterID, clientID, group string, topics []string, ...) *Subscriber
- func NewSubscriber(url, clusterID, clientID, group string, topics []string, ...) (*Subscriber, error)
- func (s *Subscriber) Close() error
- func (s *Subscriber) Listen() (_ error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrConnectionIsClosed = errors.New("[notificationcenter:natstream] connection is closed")
)

Error set

Functions ¶

This section is empty.

Types ¶

type Stream ¶

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

Stream for NATS queue

func MustNewStream ¶

func MustNewStream(url, clusterID, clientID, topic string, options ...nstream.Option) *Stream

MustNewStream of the NATS stream server

func NewStream ¶

func NewStream(url, clusterID, clientID, topic string, options ...nstream.Option) (*Stream, error)

NewStream of the NATS stream server

func (*Stream) Close ¶

func (s *Stream) Close() error

Close nats-stream client

func (*Stream) Send ¶

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

Send messages into the stream

func (*Stream) Write ¶

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

Write binary message

type Subscriber ¶

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

Subscriber for NATS queue

func MustNewSubscriber ¶

func MustNewSubscriber(url, clusterID, clientID, group string, topics []string, subOptions []nstream.SubscriptionOption, options ...nstream.Option) *Subscriber

MustNewSubscriber object

func NewSubscriber ¶

func NewSubscriber(url, clusterID, clientID, group string, topics []string, subOptions []nstream.SubscriptionOption, options ...nstream.Option) (*Subscriber, error)

NewSubscriber object

func (*Subscriber) Close ¶

func (s *Subscriber) Close() error

Close nstream client

func (*Subscriber) Listen ¶

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

Listen kafka consumer

Source Files ¶

View all Source files

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