pubsub

Documentation

Index

• Variables
• func GetTopics() []string
• func ListPeers(topicname string) []peer.ID
• func SendRaw(topicname string, data []byte)
• type PubsubTopic
  • func Subscribe(topicname string) (*PubsubTopic, error)

Variables

var Pubsub *pubsub.PubSub

var PubsubTopicPool = make(map[string]*PubsubTopic, 0)

Functions

func GetTopics

func GetTopics() []string

func ListPeers

func ListPeers(topicname string) []peer.ID

func SendRaw

func SendRaw(topicname string, data []byte)

Types

type PubsubTopic

type PubsubTopic struct {
	Topic *pubsub.Topic
	Sub   *pubsub.Subscription
}

* 订阅主题和订阅者

func Subscribe

func Subscribe(topicname string) (*PubsubTopic, error)

* 订阅主题，可以接收发给这个主题的消息