nats

Documentation

Index

• func Connection(host, user, pass string, port int) (*nats.Conn, error)
• func Publish(host, user, pass, subject, msg string, port int) error
• func Unsubscribe(sub *nats.Subscription)
• type ChReceive
  • func (ch ChReceive) Subscribe(subject string)

Functions

func Connection

func Connection(host, user, pass string, port int) (*nats.Conn, error)

Connection is to connect NATS server

func Publish

func Publish(host, user, pass, subject, msg string, port int) error

Publish is not used because of just example.

func Unsubscribe

func Unsubscribe(sub *nats.Subscription)

Unsubscribe is to unsubscribe to subject

Types

type ChReceive

type ChReceive struct {
	Conn   *nats.Conn
	ChWait chan bool
	ChCMsg chan *nats.Msg
	Error  error
}

ChReceive is struct of channel for receiver

func (ChReceive) Subscribe

func (ch ChReceive) Subscribe(subject string)

Subscribe is to subscribe to subject