p2p

Documentation

Index

• Constants
• Variables
• 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

const (
	AuthorizationChannel string = "ml-authorization-channel"
	TopicChannel         string = "ml-topic-channel"
	SubnetChannel        string = "ml-sub-network-channel"
	WalletChannel        string = "ml-wallet-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"
)

const DiscoveryServiceTag = "ml-network"

Variables

var PeerPubKeys = make(map[peer.ID][]byte)

var PeerStreams = make(map[string]peer.ID)

Functions

func Discover

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

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.