easynats

README

EasyNats

EasyNats is a library written in Go, to make manging NATS connection hassle-free. It's not an official NATS library.

Installation

The library can be installed using the following command:

go get github.com/therealriteshkudalkar/easynats

Features

• Manages required contexts on its own

Documentation

Index

• type NATSStore
  • func NewNATSStore() *NATSStore
  • func (natsStore *NATSStore) CancelContext()
  • func (natsStore *NATSStore) CloseConnection()
  • func (natsStore *NATSStore) ConnectAndInitializeJetstream(natsURL string)
  • func (natsStore *NATSStore) CreateContext()
  • func (natsStore *NATSStore) CreateDurableConsumerIfNotPresent(streamName string, consumerName string)
  • func (natsStore *NATSStore) CreateDurableWithConsumerWithConfigIfNotPresent(streamName string, config jetstream.ConsumerConfig)
  • func (natsStore *NATSStore) CreatePublisherWithChannel(messageCh chan *nats_store.NATSMessage)
  • func (natsStore *NATSStore) CreateStreamIfNotPresent(streamName string, subjects []string)
  • func (natsStore *NATSStore) PublishMessage(subject string, message []byte)
  • func (natsStore *NATSStore) ReadMessageContinuouslyAndPostThemOnChannel(streamName string, messageChan chan *jetstream.Msg)
  • func (natsStore *NATSStore) ReadNextMessage(streamName string, maxWaitTime time.Duration) (*jetstream.Msg, error)

Types

type NATSStore

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

func NewNATSStore

func NewNATSStore() *NATSStore

func (*NATSStore) CancelContext

func (natsStore *NATSStore) CancelContext()

func (*NATSStore) CloseConnection

func (natsStore *NATSStore) CloseConnection()

func (*NATSStore) ConnectAndInitializeJetstream

func (natsStore *NATSStore) ConnectAndInitializeJetstream(natsURL string)

func (*NATSStore) CreateContext

func (natsStore *NATSStore) CreateContext()

func (*NATSStore) CreateDurableConsumerIfNotPresent

func (natsStore *NATSStore) CreateDurableConsumerIfNotPresent(streamName string, consumerName string)

func (*NATSStore) CreateDurableWithConsumerWithConfigIfNotPresent

func (natsStore *NATSStore) CreateDurableWithConsumerWithConfigIfNotPresent(streamName string,
	config jetstream.ConsumerConfig)

func (*NATSStore) CreatePublisherWithChannel

func (natsStore *NATSStore) CreatePublisherWithChannel(messageCh chan *nats_store.NATSMessage)

CreatePublisherWithChannel to create a publisher with a channel. Publish messages to the channel to publish them to NATS server.

func (*NATSStore) CreateStreamIfNotPresent

func (natsStore *NATSStore) CreateStreamIfNotPresent(streamName string, subjects []string)

func (*NATSStore) PublishMessage

func (natsStore *NATSStore) PublishMessage(subject string, message []byte)

PublishMessage publishes the message bytes on the subject

func (*NATSStore) ReadMessageContinuouslyAndPostThemOnChannel

func (natsStore *NATSStore) ReadMessageContinuouslyAndPostThemOnChannel(streamName string,
	messageChan chan *jetstream.Msg)

func (*NATSStore) ReadNextMessage

func (natsStore *NATSStore) ReadNextMessage(streamName string, maxWaitTime time.Duration) (*jetstream.Msg, error)