p2p

package
v2.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 1, 2024 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPeer

func NewPeer(cfg PeerConfig, lggr logger.Logger) (*peer, error)

Types

type InMemoryDiscovererDatabase

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

func NewInMemoryDiscovererDatabase

func NewInMemoryDiscovererDatabase() *InMemoryDiscovererDatabase

func (*InMemoryDiscovererDatabase) ReadAnnouncements

func (d *InMemoryDiscovererDatabase) ReadAnnouncements(ctx context.Context, peerIDs []string) (map[string][]byte, error)

func (*InMemoryDiscovererDatabase) StoreAnnouncement

func (d *InMemoryDiscovererDatabase) StoreAnnouncement(ctx context.Context, peerID string, ann []byte) error

type PeerConfig

type PeerConfig struct {
	PrivateKey ed25519.PrivateKey
	// List of <ip>:<port> addresses.
	ListenAddresses []string
	// List of <host>:<port> addresses. If empty, defaults to ListenAddresses.
	AnnounceAddresses []string
	Bootstrappers     []ragetypes.PeerInfo
	// Every DeltaReconcile a Reconcile message is sent to every peer.
	DeltaReconcile time.Duration
	// Dial attempts will be at least DeltaDial apart.
	DeltaDial          time.Duration
	DiscovererDatabase nettypes.DiscovererDatabase
	MetricsRegisterer  prometheus.Registerer
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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