Versions in this module Expand all Collapse all v1 v1.0.0 Dec 8, 2024 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