pubsub

package

v0.5.166 Latest Latest Go to latest Published: Dec 27, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Warp-net/warpnet

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func PrefollowHandlers(userIds ...string) (handlers []pubsub.TopicHandler)
type MemberPubSub
- func NewPubSub(ctx context.Context, handlers ...pubsub.TopicHandler) *MemberPubSub
type PubsubServerNodeConnector

Constants ¶

This section is empty.

Variables ¶

View Source

var NewBootstrapDiscoveryTopicHandler = pubsub.NewDiscoveryTopicHandler

Functions ¶

func PrefollowHandlers ¶ added in v0.5.85

func PrefollowHandlers(userIds ...string) (handlers []pubsub.TopicHandler)

Types ¶

type MemberPubSub ¶ added in v0.5.158

type MemberPubSub struct {
	// contains filtered or unexported fields
}

MemberPubSub provides pubsub functionality for member nodes

func NewPubSub ¶

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

func (*MemberPubSub) Close ¶ added in v0.5.158

func (g *MemberPubSub) Close() (err error)

func (*MemberPubSub) Gossip ¶ added in v0.5.158

func (g *MemberPubSub) Gossip() *pubsub.Gossip

Gossip returns the underlying Gossip instance for CRDT integration

func (*MemberPubSub) NodeID ¶ added in v0.5.158

func (g *MemberPubSub) NodeID() string

func (*MemberPubSub) OwnerID ¶ added in v0.5.158

func (g *MemberPubSub) OwnerID() string

func (*MemberPubSub) PublishUpdateToFollowers ¶ added in v0.5.158

func (g *MemberPubSub) PublishUpdateToFollowers(ownerId, dest string, bt []byte) (err error)

PublishUpdateToFollowers - Publish for followers

func (*MemberPubSub) Run ¶ added in v0.5.158

func (g *MemberPubSub) Run(node PubsubServerNodeConnector)

func (*MemberPubSub) SubscribeUserUpdate ¶ added in v0.5.158

func (g *MemberPubSub) SubscribeUserUpdate(userId string) (err error)

SubscribeUserUpdate - follow someone

func (*MemberPubSub) UnsubscribeUserUpdate ¶ added in v0.5.158

func (g *MemberPubSub) UnsubscribeUserUpdate(userId string) (err error)

UnsubscribeUserUpdate - unfollow someone

type PubsubServerNodeConnector ¶

type PubsubServerNodeConnector interface {
	Node() warpnet.P2PNode
	NodeInfo() warpnet.NodeInfo
	SelfStream(path stream.WarpRoute, data any) (_ []byte, err error)
	GenericStream(nodeIdStr string, path stream.WarpRoute, data any) (_ []byte, err error)
}

Source Files ¶

View all Source files

member-pubsub.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL