pubsub

func ExtractPeers(peers string) ([]peer.AddrInfo, error)

func GetHost(hostPrivateKey crypto.PrivKey, hostAddress string) (host.Host, error)

func JoinTopic(pubSub *pubsub.PubSub, topicName string) (*pubsub.Topic, func(), error)

func Run(
	ctx context.Context,
	chainID protocol.ID,
	protocolID protocol.ID,
	host host.Host,
	pubSubQueueSize int,
	bootstrapPeersFn func() []peer.AddrInfo,
) (*pubsub.PubSub, error)