Versions in this module Expand all Collapse all v0 v0.1.0 Nov 22, 2021 Changes in this version + func Init(cfg *Config) + type Config struct + Addr string + type Consumer struct + 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 struct + var Queue *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()
Go to main page