Fields

• msgFrom :: !(Maybe ByteString)

  Original author's Peer ID bytes

• msgData :: !ByteString

  Application payload

• msgSeqNo :: !(Maybe ByteString)

  8-byte big-endian sequence number

• msgTopic :: !Topic

  Topic this message belongs to

• msgSignature :: !(Maybe ByteString)

  Signature over marshalled message

• msgKey :: !(Maybe ByteString)

  Author's public key (protobuf-encoded)

Fields

• subSubscribe :: !Bool

  True = subscribe, False = unsubscribe

• subTopicId :: !Topic

  Topic identifier

Fields

• ctrlIHave :: ![IHave]
   
• ctrlIWant :: ![IWant]
   
• ctrlGraft :: ![Graft]
   
• ctrlPrune :: ![Prune]
   

Fields

• ihaveTopic :: !Topic

  Topic ID

• ihaveMessageIds :: ![MessageId]

  Message IDs available

Fields

• iwantMessageIds :: ![MessageId]

  Requested message IDs

Fields

• graftTopic :: !Topic

  Topic to graft into

Fields

• pruneTopic :: !Topic

  Topic to prune from

• prunePeers :: ![PeerExchangeInfo]

  Peer exchange (v1.1)

• pruneBackoff :: !(Maybe Word64)

  Backoff duration in seconds (v1.1)

Fields

• pxPeerId :: !ByteString

  Peer ID bytes

• pxSignedPeerRecord :: !(Maybe ByteString)

  Optional signed peer record

Fields

• rpcSubscriptions :: ![SubOpts]
   
• rpcPublish :: ![PubSubMessage]
   
• rpcControl :: !(Maybe ControlMessage)
   

Fields

• paramD :: !Int

  Desired mesh degree (default 6)

• paramDlo :: !Int

  Lower bound (default 4)

• paramDhi :: !Int

  Upper bound (default 12)

• paramDlazy :: !Int

  Gossip emission peers (default 6)

• paramDscore :: !Int

  Score-retained peers (default 4)

• paramDout :: !Int

  Minimum outbound (default 2)

• paramHeartbeatInterval :: !NominalDiffTime

  Heartbeat period (default 1s)

• paramFanoutTTL :: !NominalDiffTime

  Fanout expiry (default 60s)

• paramSeenTTL :: !NominalDiffTime

  Seen cache TTL (default 120s)

• paramPruneBackoff :: !NominalDiffTime

  Prune backoff (default 60s)

• paramUnsubBackoff :: !NominalDiffTime

  Unsubscribe backoff (default 10s)

• paramGossipFactor :: !Double

  Gossip target fraction (default 0.25)

• paramFloodPublish :: !Bool

  Flood own messages (default True)

• paramMessageIdFn :: !(PubSubMessage -> MessageId)

  Message ID function (default: from || seqno)

• paramSignaturePolicy :: !SignaturePolicy

  Signing policy (default StrictSign)

• paramMcacheLen :: !Int

  Message cache windows (default 5)

• paramMcacheGossip :: !Int

  Gossip windows (default 3)

Fields

• psProtocol :: !PeerProtocol

  Protocol support

• psTopics :: !(Set Topic)

  Subscribed topics

• psIsOutbound :: !Bool

  True if we dialed this peer

• psConnectedAt :: !UTCTime

  Connection establishment time

• psTopicState :: !(Map Topic TopicPeerState)

  Per-topic scoring state

• psBehaviorPenalty :: !Double

  P7 behavioral penalty counter

• psIPAddress :: !(Maybe ByteString)

  IP address for P6

• psCachedScore :: !Double

  Cached computed score

Fields

• tspTopicWeight :: !Double

  How much this topic contributes

• tspTimeInMeshWeight :: !Double

  P1 weight (small positive)

• tspTimeInMeshQuantum :: !NominalDiffTime

  P1 time unit

• tspTimeInMeshCap :: !Double

  P1 maximum value

• tspFirstMessageDeliveriesWeight :: !Double

  P2 weight (positive)

• tspFirstMessageDeliveriesDecay :: !Double

  P2 decay factor

• tspFirstMessageDeliveriesCap :: !Double

  P2 maximum counter

• tspMeshMessageDeliveriesWeight :: !Double

  P3 weight (negative)

• tspMeshMessageDeliveriesDecay :: !Double

  P3 decay factor

• tspMeshMessageDeliveriesThreshold :: !Double

  P3 expected threshold

• tspMeshMessageDeliveriesCap :: !Double

  P3 maximum counter

• tspMeshMessageDeliveriesActivation :: !NominalDiffTime

  P3 grace period

• tspMeshMessageDeliveryWindow :: !NominalDiffTime

  P3 near-first window

• tspMeshFailurePenaltyWeight :: !Double

  P3b weight (negative)

• tspMeshFailurePenaltyDecay :: !Double

  P3b decay factor

• tspInvalidMessageDeliveriesWeight :: !Double

  P4 weight (negative)

• tspInvalidMessageDeliveriesDecay :: !Double

  P4 decay factor

Fields

• pspTopicParams :: !(Map Topic TopicScoreParams)
   
• pspAppSpecificWeight :: !Double

  w5 weight

• pspAppSpecificScore :: !(PeerId -> Double)

  P5 callback

• pspIPColocationFactorWeight :: !Double

  w6 weight (negative)

• pspIPColocationFactorThreshold :: !Int

  P6 threshold

• pspBehaviorPenaltyWeight :: !Double

  w7 weight (negative)

• pspBehaviorPenaltyDecay :: !Double

  w7 decay factor

• pspDecayInterval :: !NominalDiffTime

  How often to decay

• pspDecayToZero :: !Double

  Zero-out threshold

• pspRetainScore :: !NominalDiffTime

  Keep score after disconnect

• pspTopicScoreCap :: !Double

  Cap for topic score sum

Fields

• tpsMeshTime :: !NominalDiffTime

  P1: time in mesh

• tpsFirstMessageDeliveries :: !Double

  P2 counter

• tpsMeshMessageDeliveries :: !Double

  P3 counter

• tpsMeshFailurePenalty :: !Double

  P3b counter

• tpsInvalidMessages :: !Double

  P4 counter

• tpsGraftTime :: !(Maybe UTCTime)

  When grafted

• tpsInMesh :: !Bool

  Currently in mesh?

Fields

• stGossipThreshold :: !Double

  Below: no gossip

• stPublishThreshold :: !Double

  Below: no flood publish

• stGraylistThreshold :: !Double

  Below: ignore all RPCs

• stAcceptPXThreshold :: !Double

  Above: accept PX from PRUNE

• stOpportunisticGraftThreshold :: !Double

  Below: trigger opportunistic graft

Fields

• ceMessageId :: !MessageId
   
• ceMessage :: !PubSubMessage
   
• ceTopic :: !Topic
   

Fields

• mcWindows :: !(Seq [CacheEntry])

  Circular windows, newest first (index 0)

• mcIndex :: !(Map MessageId CacheEntry)

  Fast lookup by message ID

• mcLen :: !Int

  Total number of windows

• mcGossip :: !Int

  Number of windows for gossip (IHAVE)

Fields

• gsParams :: !GossipSubParams
   
• gsLocalPeerId :: !PeerId
   
• gsMesh :: !(TVar (Map Topic (Set PeerId)))
   
• gsFanout :: !(TVar (Map Topic (Set PeerId)))
   
• gsFanoutPub :: !(TVar (Map Topic UTCTime))
   
• gsPeers :: !(TVar (Map PeerId PeerState))
   
• gsSeen :: !(TVar (Map MessageId UTCTime))
   
• gsBackoff :: !(TVar (Map (PeerId, Topic) UTCTime))
   
• gsScoreParams :: !PeerScoreParams
   
• gsThresholds :: !ScoreThresholds
   
• gsIPPeerCount :: !(TVar (Map ByteString (Set PeerId)))

  IP address → peers sharing that IP (for P6) Message cache (Phase 9c)

• gsMessageCache :: !(TVar MessageCache)

  Sliding-window message cache for IWANT and IHAVE

• gsHeartbeatCount :: !(TVar Int)

  Heartbeat counter (for opportunistic graft timing) Injectable functions for testability

• gsSendRPC :: !(PeerId -> RPC -> IO ())

  Fire-and-forget RPC sender

• gsGetTime :: !(IO UTCTime)

  Time source (injectable for deterministic tests)

• gsOnMessage :: !(TVar (Topic -> PubSubMessage -> IO ()))

  Application message callback