pubsub

Documentation

Index

• Constants
• func AddPeer(id peer.ID)
• func Get() *pubsub.PubSub
• func GetOrCreateTopic(topicName string) (*p2ppubsub.Topic, error)
• func New(ctx context.Context, h host.Host) (*pubsub.PubSub, error)
• func RemovePeer(id peer.ID)
• func SetEoughPeers(t string, peerno int)

Constants

const PUBSUB_PROTOCOL = "/meshsub/1.1.0"

Functions

func AddPeer

func AddPeer(id peer.ID)

Adds a peer ID to the GossipSubRouter

func Get

func Get() *pubsub.PubSub

func GetOrCreateTopic

func GetOrCreateTopic(topicName string) (*p2ppubsub.Topic, error)

func New

func New(ctx context.Context, h host.Host) (*pubsub.PubSub, error)

Start the pubsub service. If ctx is nil a background context is used. n is the libp2p host.

func RemovePeer

func RemovePeer(id peer.ID)

Removes a peer ID from the GossipSubRouter

func SetEoughPeers

func SetEoughPeers(t string, peerno int)