p2p

Documentation

Index

• func NewPeer(cfg PeerConfig, lggr logger.Logger) (*peer, error)
• type InMemoryDiscovererDatabase
  • func NewInMemoryDiscovererDatabase() *InMemoryDiscovererDatabase
  • func (d *InMemoryDiscovererDatabase) ReadAnnouncements(ctx context.Context, peerIDs []string) (map[string][]byte, error)
  • func (d *InMemoryDiscovererDatabase) StoreAnnouncement(ctx context.Context, peerID string, ann []byte) error
• type PeerConfig

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
}