nats

Documentation

Index

• Variables
• func Close()
• func Init(url string, subject string) error
• type Subscription
  • func NewSub(sessionID string) *Subscription
  • func (s *Subscription) Close()
  • func (s *Subscription) Subscribe(subscribeTo ...string)
  • func (s *Subscription) Unsubscribe(unsubscribeFrom ...string)

Variables

var (
	ErrSubNotFound = errors.New("subscription not found")
)

Functions

func Close

func Close()

func Init

func Init(url string, subject string) error

Types

type Subscription

type Subscription struct {
	Ch chan []byte
	// contains filtered or unexported fields
}

func NewSub

func NewSub(sessionID string) *Subscription

func (*Subscription) Close

func (s *Subscription) Close()

func (*Subscription) Subscribe

func (s *Subscription) Subscribe(subscribeTo ...string)

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe(unsubscribeFrom ...string)