Base interface for pubsub protocols
You can subscribe to a topic, publish something on it, and eventually unsubscribe from it.
Types
InitializationError = object of LPError
- Source Edit
libp2p_pubsub_broadcast_graft = IgnoredCollector
- Source Edit
libp2p_pubsub_broadcast_ihave = IgnoredCollector
- Source Edit
libp2p_pubsub_broadcast_iwant = IgnoredCollector
- Source Edit
libp2p_pubsub_broadcast_messages = IgnoredCollector
- Source Edit
libp2p_pubsub_broadcast_prune = IgnoredCollector
- Source Edit
libp2p_pubsub_broadcast_subscriptions = IgnoredCollector
- Source Edit
libp2p_pubsub_broadcast_unsubscriptions = IgnoredCollector
- Source Edit
libp2p_pubsub_messages_published = IgnoredCollector
- Source Edit
libp2p_pubsub_messages_rebroadcasted = IgnoredCollector
- Source Edit
libp2p_pubsub_received_graft = IgnoredCollector
- Source Edit
libp2p_pubsub_received_ihave = IgnoredCollector
- Source Edit
libp2p_pubsub_received_iwant = IgnoredCollector
- Source Edit
libp2p_pubsub_received_messages = IgnoredCollector
- Source Edit
libp2p_pubsub_received_prune = IgnoredCollector
- Source Edit
libp2p_pubsub_received_subscriptions = IgnoredCollector
- Source Edit
libp2p_pubsub_received_unsubscriptions = IgnoredCollector
- Source Edit
MsgIdProvider {.public.} = proc (m: Message): Result[MessageID, ValidationResult] {. noSideEffect, ...raises: [Defect], gcsafe.}
- Source Edit
SubscriptionValidator {.public.}
- Source Edit
TopicHandler {.public.} = proc (topic: string; data: seq[byte]): Future[void] {. ...gcsafe, raises: [Defect].}
- Source Edit
TopicPair = tuple[topic: string, handler: TopicHandler]
- Source Edit
ValidatorHandler {.public.} = proc (topic: string; message: Message): Future[ ValidationResult] {....gcsafe, raises: [Defect].}
- Source Edit
Consts
KnownLibP2PTopics = ""
- Source Edit
KnownLibP2PTopicsSeq = [""]
- Source Edit