pubsub

package

v0.6.0-dev Latest Latest Go to latest Published: Dec 27, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 19 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 ¶

Constants
type Gossip
- func NewGossip(ctx context.Context, handlers ...TopicHandler) *Gossip
type GossipNodeConnector
type TopicHandler
- func NewDiscoveryRelayTopicHandler() TopicHandler
- func NewDiscoveryTopicHandler(discHandler discovery.DiscoveryHandler) TopicHandler

Constants ¶

View Source

const (
	ErrPubsubNotInit      warpnet.WarpError = "gossip: service not initialized"
	ErrAlreadyRunning     warpnet.WarpError = "gossip: pubsub is already running"
	ErrListenerMalformed  warpnet.WarpError = "gossip: pubsub listener not initialized properly"
	ErrPubsubEmptyTopic   warpnet.WarpError = "gossip: topic name is empty"
	ErrPubsubNoPathFound  warpnet.WarpError = "gossip: user update message has no path"
	ErrPubsubEmptyMessage warpnet.WarpError = "gossip: empty message"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Gossip ¶ added in v0.5.8

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

func NewGossip ¶ added in v0.5.8

func NewGossip(
	ctx context.Context,
	handlers ...TopicHandler,
) *Gossip

func (*Gossip) Close ¶ added in v0.5.8

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

func (*Gossip) IsGossipRunning ¶ added in v0.5.8

func (g *Gossip) IsGossipRunning() bool

func (*Gossip) NodeInfo ¶ added in v0.5.8

func (g *Gossip) NodeInfo() warpnet.NodeInfo

func (*Gossip) NotSubscribers ¶ added in v0.5.8

func (g *Gossip) NotSubscribers(topicName string) []warpnet.WarpAddrInfo

func (*Gossip) Publish ¶ added in v0.5.8

func (g *Gossip) Publish(msg event.Message, topics ...string) (err error)

func (*Gossip) PublishRaw ¶ added in v0.5.159

func (g *Gossip) PublishRaw(topicName string, data []byte) (err error)

func (*Gossip) Run ¶ added in v0.5.8

func (g *Gossip) Run(node GossipNodeConnector) (err error)

func (*Gossip) SelfPublish ¶ added in v0.5.8

func (g *Gossip) SelfPublish(data []byte) error

func (g *Gossip) Subscribe(handlers ...TopicHandler) (err error)

func (*Gossip) SubscribeRaw ¶ added in v0.5.159

func (g *Gossip) SubscribeRaw(topicName string, h func([]byte) error) (err error)

func (*Gossip) Subscribers ¶ added in v0.5.8

func (g *Gossip) Subscribers(topicName string) []warpnet.WarpAddrInfo

func (*Gossip) Unsubscribe ¶ added in v0.5.8

func (g *Gossip) Unsubscribe(topics ...string) (err error)

type GossipNodeConnector ¶ added in v0.3.112

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

type TopicHandler ¶ added in v0.3.112

type TopicHandler struct {
	TopicName string
	Handler   topicHandler
}

func NewDiscoveryRelayTopicHandler ¶ added in v0.5.134

func NewDiscoveryRelayTopicHandler() TopicHandler

NewDiscoveryRelayTopicHandler acts only as relay

func NewDiscoveryTopicHandler ¶ added in v0.3.113

func NewDiscoveryTopicHandler(discHandler discovery.DiscoveryHandler) TopicHandler

Source Files ¶

View all Source files

gossip.go

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