PubSubRouter

[knowhunger]

Protocols: 프로토콜 관리 Attach: pubsub 관리 AddPeer: pubsub 피어 관리 RemovePeer: pubsub 피어 관리 EnoughPeers: pubsub 피어 관리 AcceptFrom : RPC 관리 HandleRPC : RPC 관리 Publish: Gossip 보내기 Join : 토픽 Leave : 토픽

[knowhunger]

• struct PubSub belongs to(<<) struct GossipSubRouter
• interface PubSubRouter implemented (->) struct GossipSubRouter

[knowhunger]

PubSub (가장 low level 구현체)

• processLoop: 메인 컨트롤 루프

• 피어=호스트(물리적), PubSub(layer7), Topic[],

• 피어관리:

  • notifyPeerDead
  • handleNewPeer
  • handleNewStream
  • handlePeerEOF
  • getHelloPacket
  • handlePendingPeers
  • handleDeadPeers ListPeers BlacklistPeer

• 토픽관리:

  • handleAddTopic
  • handleRemoveTopic
  • RegisterTopicValidator
  • GetTopics
  • UnregisterTopicValidator

• PubSub 관리:

  • addSub
  • handleRemoveSubscription
  • handleAddSubscription
  • notifySubs
  • Join (deprecated)
  • tryJoin
  • notifyLeave
  • Subscribe (deprecated)

• RPC 관리

  • handleSendingMessages
  • publishMessage
  • seenMessage
  • markSeen
  • handleIncomingRPC
  • subscribedToMsg
  • pushMsg
  • checkSigningPolicy
  • Publish (deprecated)

• 불명

  • handleAddRelay
  • handleRemoveRelay
  • announce
  • announceRetry
  • doAnnounceRetry
  • canRelayMsg
  • nextSeqno

[knowhunger]

• handleIncomingRPC
• publishMessage subscription == topic

mySubs : 현재 pubSub이 가입하고 있는 토픽 myRelays myTopics: 현재 pubSub이 관심있는 토픽

mySub=> 특정 토픽에 대한 피어정보

• map[string]map[*Subscription]struct{}
• topicID -> map[*Subscription]struct{} (피어들)
• Subscription = Topic N:1관계인데 피어의 endpoint 역할을 한다.
• 토픽을 가입하고 있는 피어들을 알기 위한 변수(모든 피어는 아님)

myTopics

• map[string]*Topic
• topicID -> *Topic
• Topic struct는 토픽에 관한 처리를 한다.
• pubSub(low level 기능)을 사용

topics: 내가 알고 있는 peer들의 가입 토픽 정보

• map[string]map[peer.ID]struct{}
• topicID -> map[peer.ID]struct{}