p2p

package

v0.0.0-...-6721946 Latest Latest Go to latest Published: Feb 19, 2024 License: LGPL-2.1 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mlayerprotocol/go-mlayer

Documentation ¶

Index ¶

Constants
func Discover(ctx context.Context, h host.Host, kdht *dht.IpfsDHT, rendezvous string)
func ProcessEventsReceivedFromOtherNodes[PayloadData any](payload *PayloadData, fromPubSubChannel *Channel, mainCtx *context.Context, ...)
func PublishChannelEventToNetwork(channelPool chan *entities.Event, pubsubChannel *Channel, ...)
func Run(mainCtx *context.Context)
type Channel
- func JoinChannel(ctx context.Context, ps *pubsub.PubSub, selfID peer.ID, walletAddress string, ...) (*Channel, error)
- func (cr *Channel) ListPeers() []peer.ID
- func (cr *Channel) Publish(m entities.PubSubMessage) error

Constants ¶

View Source

const (
	AuthorizationChannel       string = "ml-authorization-channel"
	TopicChannel               string = "ml-topic-channel"
	MessageChannel             string = "ml-message-channel"
	SubscriptionChannel               = "ml-subscription-channel"
	UnSubscribeChannel                = "ml-unsubscribe-channel"
	ApproveSubscriptionChannel        = "ml-approve-subscription-channel"
	BatchChannel                      = "ml-batch-channel"
	DeliveryProofChannel              = "ml-delivery-proof"
)

View Source

const DiscoveryServiceTag = "ml-network"

Variables ¶

This section is empty.

Functions ¶

func Discover ¶

func Discover(ctx context.Context, h host.Host, kdht *dht.IpfsDHT, rendezvous string)

func ProcessEventsReceivedFromOtherNodes ¶

func ProcessEventsReceivedFromOtherNodes[PayloadData any](payload *PayloadData, fromPubSubChannel *Channel, mainCtx *context.Context, process func(event *entities.Event, ctx *context.Context))

func PublishChannelEventToNetwork ¶

func PublishChannelEventToNetwork(channelPool chan *entities.Event, pubsubChannel *Channel, mainCtx *context.Context)

** Publish Events to a specified p2p broadcast channel ****

func Run ¶

func Run(mainCtx *context.Context)

Types ¶

type Channel ¶

type Channel struct {
	// Messages is a channel of messages received from other peers in the chat channel
	Messages chan entities.PubSubMessage

	Ctx context.Context

	Topic *pubsub.Topic

	ChannelName string
	ID          peer.ID
	Wallet      string
	// contains filtered or unexported fields
}

func JoinChannel ¶

func JoinChannel(ctx context.Context, ps *pubsub.PubSub, selfID peer.ID, walletAddress string, channelName string, channelBufferSize uint) (*Channel, error)

func (*Channel) ListPeers ¶

func (cr *Channel) ListPeers() []peer.ID

func (*Channel) Publish ¶

func (cr *Channel) Publish(m entities.PubSubMessage) error

Publish sends a message to the pubsub topic.

Source Files ¶

View all Source files

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