nats

Documentation

Index

• func Init(cfg *Config)
• type Config
• type Consumer
  • func NewConsumer(addr string) *Consumer
  • func (c *Consumer) Consume(topic string, handler interface{}) error
  • func (c *Consumer) ReConnect()
  • func (c *Consumer) Run() error
  • func (c *Consumer) Start() error
  • func (c *Consumer) Stop()
• type Producer
  • func NewProducer(addr string) *Producer
  • func (p *Producer) Publish(topic string, data interface{}) error
  • func (p *Producer) ReConnect()
  • func (p *Producer) Run() error
  • func (p *Producer) Start() error
  • func (p *Producer) Stop()

Functions

func Init

func Init(cfg *Config)

Init create producer

Types

type Config

type Config struct {
	Addr string `mapstructure:"name"`
}

Config nats config

type Consumer

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

Consumer define a nats consumer

func NewConsumer

func NewConsumer(addr string) *Consumer

NewConsumer create consumer

func (*Consumer) Consume

func (c *Consumer) Consume(topic string, handler interface{}) error

Consume consume data from nats queue

func (*Consumer) ReConnect

func (c *Consumer) ReConnect()

ReConnect .

func (*Consumer) Run

func (c *Consumer) Run() error

Run .

func (*Consumer) Start

func (c *Consumer) Start() error

Start .

func (*Consumer) Stop

func (c *Consumer) Stop()

Stop .

type Producer

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

Producer define a nats producer

var (
	// Queue nats queue
	Queue *Producer
)

func NewProducer

func NewProducer(addr string) *Producer

NewProducer create a producer

func (*Producer) Publish

func (p *Producer) Publish(topic string, data interface{}) error

Publish push data to queue

func (*Producer) ReConnect

func (p *Producer) ReConnect()

ReConnect .

func (*Producer) Run

func (p *Producer) Run() error

Run .

func (*Producer) Start

func (p *Producer) Start() error

Start .

func (*Producer) Stop

func (p *Producer) Stop()

Stop .