Versions in this module Expand all Collapse all v0 v0.2.3 Mar 10, 2020 Changes in this version + func Create(broker *moleculer.BrokerDelegates) transit.Transit + type ActionError interface + Error func() string + Stack func() string + type PubSub struct + func (pubsub *PubSub) Connect() chan error + func (pubsub *PubSub) Disconnect() chan error + func (pubsub *PubSub) DiscoverNode(nodeID string) + func (pubsub *PubSub) DiscoverNodes() chan bool + func (pubsub *PubSub) Emit(context moleculer.BrokerContext) + func (pubsub *PubSub) Ready() + func (pubsub *PubSub) Request(context moleculer.BrokerContext) chan moleculer.Payload + func (pubsub *PubSub) SendHeartbeat() + func (pubsub *PubSub) SendPing()