pubsub

package

v0.3.7 Latest Latest Go to latest Published: May 28, 2025 License: GPL-2.0, GPL-3.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

func NewPubSub(
	ctx context.Context,
	followRepo PubsubFollowingStorer,
	ownerId string,
	discoveryHandler discovery.DiscoveryHandler,
) *warpPubSub

func NewPubSubBootstrap(
	ctx context.Context,
	discoveryHandler discovery.DiscoveryHandler,
) *warpPubSub

type PubsubClientNodeStreamer interface {
	ClientStream(nodeId string, path string, data any) (_ []byte, err error)
}

type PubsubFollowingStorer interface {
	GetFollowees(userId string, limit *uint64, cursor *string) ([]domain.Following, string, error)
}

type PubsubServerNodeConnector interface {
	Node() warpnet.P2PNode
	NodeInfo() warpnet.NodeInfo
}