proxy.golang.org : github.com/testjulianpascalau/go-libp2p-pubsub : v0.3.0
The pubsub package provides facilities for the Publish/Subscribe pattern of message propagation, also known as overlay multicast. The implementation provides topic-based pubsub, with pluggable routing algorithms. The main interface to the library is the PubSub object. You can construct this object with the following constructors: - NewFloodSub creates an instance that uses the floodsub routing algorithm. - NewGossipSub creates an instance that uses the gossipsub routing algorithm. - NewRandomSub creates an instance that uses the randomsub routing algorithm. In addition, there is a generic constructor that creates a pubsub instance with a custom PubSubRouter interface. This procedure is currently reserved for internal use within the package. Once you have constructed a PubSub instance, you need to establish some connections to your peers; the implementation relies on ambient peer discovery, leaving bootstrap and active peer discovery up to the client. To publish a message to some topic, use Publish; you don't need to be subscribed to the topic in order to publish. To subscribe to a topic, use Subscribe; this will give you a subscription interface from which new messages can be pumped.
Registry -
Documentation -
Download -
JSON
purl: pkg:golang/github.com/testjulianpascalau/[email protected]
Published:
Indexed:
- github.com/benbjohnson/clock v1.0.1
- github.com/gogo/protobuf v1.3.1
- github.com/ipfs/go-log v1.0.4
- github.com/libp2p/go-libp2p-blankhost v0.1.6
- github.com/libp2p/go-libp2p-connmgr v0.2.3
- github.com/libp2p/go-libp2p-core v0.5.6
- github.com/libp2p/go-libp2p-discovery v0.4.0
- github.com/libp2p/go-libp2p-swarm v0.2.4
- github.com/multiformats/go-multiaddr v0.2.2
- github.com/multiformats/go-multiaddr-net v0.1.5
- github.com/multiformats/go-multibase v0.0.2
- github.com/multiformats/go-multistream v0.1.1
- github.com/whyrusleeping/timecache v0.0.0-20160911033111-cfcb2f1abfee
- go.uber.org/zap v1.15.0
- golang.org/x/crypto v0.0.0-20200510223506-06a226fb4e37
- golang.org/x/sys v0.0.0-20200509044756-6aff5f38e54f