Versions in this module Expand all Collapse all v0 v0.0.3 Dec 27, 2020 Changes in this version + type Broker struct + Consumer *client.Consumer + Logger logger.Logger + Producers map[string]client.Producer + func (b *Broker) Call(producerName string, funName string, data *[]byte) (*[]byte, error) + func (b *Broker) LogErr(err error) + func (b *Broker) New(args ...interface{})