nres

Documentation

Overview

*

*
* @author nghiatc
* @since Dec 6, 2019

*

*
* @author nghiatc
* @since Dec 17, 2019

Index

• type NResponse
  • func NewNResponse(name string) *NResponse
  • func (nrs *NResponse) Start(processChan chan *nats.Msg) error
  • func (nrs *NResponse) Stop()

Types

type NResponse

type NResponse struct {
	Name    string
	Subject string
	Group   string
	Url     string
	Auth    string
	Opts    []nats.Option
	Conn    *nats.Conn
	Subt    *nats.Subscription
}

func NewNResponse

func NewNResponse(name string) *NResponse

func (*NResponse) Start

func (nrs *NResponse) Start(processChan chan *nats.Msg) error

func (*NResponse) Stop

func (nrs *NResponse) Stop()

Disconnect safe