pubsub

Oct 20, 2025

Changes in this version

type PubsubServerNodeConnector

+ RoutingDiscovery func() warpnet.Discovery

Aug 10, 2025

Changes in this version

+ func NewPubSub(ctx context.Context, handlers ...pubsub.TopicHandler) *memberPubSub

Aug 5, 2025

Changes in this version

+ func NewPubSubModerator(ctx context.Context) *moderatorPubSub

+ type PubsubServerNodeConnector interface

+ GenericStream func(nodeIdStr string, path stream.WarpRoute, data any) (_ []byte, err error)

+ Node func() warpnet.P2PNode

+ NodeInfo func() warpnet.NodeInfo

+ SelfStream func(path stream.WarpRoute, data any) (_ []byte, err error)