publisher

Documentation

Index

• type NATSPublisher
  • func NewNATSPublisher(nc *nats.Conn, topic string) *NATSPublisher
  • func NewPublisher(host string, topic string) *NATSPublisher
  • func (p *NATSPublisher) Close()
  • func (p *NATSPublisher) Publish(subject string, msg interface{}) error

Types

type NATSPublisher

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

func NewNATSPublisher

func NewNATSPublisher(nc *nats.Conn, topic string) *NATSPublisher

NewNATSPublisher creates a new NATSPublisher.

func NewPublisher

func NewPublisher(host string, topic string) *NATSPublisher

func (*NATSPublisher) Close

func (p *NATSPublisher) Close()

Close closes the NATS connection (optional).

func (*NATSPublisher) Publish

func (p *NATSPublisher) Publish(subject string, msg interface{}) error

Publish publishes a message to a given subject.