network

package

v0.0.11-alpha Latest Latest Go to latest Published: Apr 11, 2024 License: MIT Imports: 21 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/masa-finance/masa-oracle

Documentation ¶

Index ¶

Constants
func Discover(ctx context.Context, host host.Host, dht *dht.IpfsDHT, protocol protocol.ID)
func GetBootNodesMultiAddress(bootstrapNodes []string) ([]multiaddr.Multiaddr, error)
func GetMultiAddressesForHost(host host.Host) ([]multiaddr.Multiaddr, error)
func GetMultiAddressesForHostQuiet(host host.Host) []multiaddr.Multiaddr
func GetPriorityAddress(addrs []multiaddr.Multiaddr) multiaddr.Multiaddr
func WithDht(ctx context.Context, host host.Host, bootstrapNodes []multiaddr.Multiaddr, ...) (*dht.IpfsDHT, error)
func WithMDNS(host host.Host, rendezvous string, peerChan chan PeerEvent) error
type PeerEvent

Constants ¶

View Source

const (
	PeerAdded   = "PeerAdded"
	PeerRemoved = "PeerRemoved"
)

View Source

const PeerFound = "PeerFound"

Variables ¶

This section is empty.

Functions ¶

func Discover ¶

func Discover(ctx context.Context, host host.Host, dht *dht.IpfsDHT, protocol protocol.ID)

Discover searches for and connects to peers that support the given protocol ID. It initializes discovery via the DHT and advertises this node. It runs discovery in a loop with a ticker, re-advertising and finding new peers. For each discovered peer, it checks if already connected, and if not, dials them.

func GetBootNodesMultiAddress ¶

func GetBootNodesMultiAddress(bootstrapNodes []string) ([]multiaddr.Multiaddr, error)

func GetMultiAddressesForHost ¶

func GetMultiAddressesForHost(host host.Host) ([]multiaddr.Multiaddr, error)

func GetMultiAddressesForHostQuiet ¶

func GetMultiAddressesForHostQuiet(host host.Host) []multiaddr.Multiaddr

func GetPriorityAddress ¶

func GetPriorityAddress(addrs []multiaddr.Multiaddr) multiaddr.Multiaddr

func WithDht ¶

func WithDht(ctx context.Context, host host.Host, bootstrapNodes []multiaddr.Multiaddr,
	protocolId, prefix protocol.ID, peerChan chan PeerEvent, isStaked bool) (*dht.IpfsDHT, error)

func WithMDNS ¶

func WithMDNS(host host.Host, rendezvous string, peerChan chan PeerEvent) error

Types ¶

type PeerEvent ¶

type PeerEvent struct {
	AddrInfo   peer.AddrInfo
	Action     string
	Source     string
	Rendezvous string
}

Source Files ¶

View all Source files

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