node

package

Versions in this module

v0

v0.9.0

Nov 14, 2023

Changes in this version

+ func GetNodesFromDNSDiscovery(logger *zap.Logger, ctx context.Context, nameServer string, ...) []dnsdisc.DiscoveredNode

type WakuNode

+ func (w *WakuNode) PeerManager() *peermanager.PeerManager

type WakuNodeOption

+ func GetDiscv5Option(dnsDiscoveredNodes []dnsdisc.DiscoveredNode, discv5Nodes []string, port uint, ...) (WakuNodeOption, error)

+ func WithClusterID(clusterID uint16) WakuNodeOption

v0.8.1

Oct 7, 2023

Changes in this version

type WakuNode

+ func (w *WakuNode) PeersByContentTopic(contentTopic string) peer.IDSlice

+ func (w *WakuNode) PeersByStaticShard(cluster uint16, shard uint16) peer.IDSlice

type WakuNodeOption

+ func WithCircuitRelayParams(minInterval time.Duration, bootDelay time.Duration) WakuNodeOption

+ func WithPeerStoreCapacity(capacity int) WakuNodeOption

v0.8.0

Sep 17, 2023

Changes in this version

+ type Metrics interface

+ RecordDial func()

+ RecordPeerConnected func()

+ RecordPeerDisconnected func()

+ RecordVersion func(version string, commit string)

type RLNRelay

+ IsReady func(ctx context.Context) (bool, error)

+ Start func(ctx context.Context) error

+ Validator func(spamHandler SpamHandler) func(ctx context.Context, message *pb.WakuMessage, topic string) bool

+ type SpamHandler = func(message *pb.WakuMessage, topic string) error

type WakuNode

+ func (w *WakuNode) AddDiscoveredPeer(ID peer.ID, addrs []ma.Multiaddr, origin wps.Origin, pubsubTopics []string)

+ func (w *WakuNode) FilterFullNode() *filter.WakuFilterFullNode

+ func (w *WakuNode) PeersByShard(cluster uint16, shard uint16) peer.IDSlice

+ func (w *WakuNode) Rendezvous() *rendezvous.Rendezvous

type WakuNodeOption

+ func WithDNS4Domain(dns4Domain string) WakuNodeOption

+ func WithDynamicRLNRelay(keystorePath string, keystorePassword string, treePath string, ...) WakuNodeOption

+ func WithMaxPeerConnections(maxPeers int) WakuNodeOption

+ func WithPrometheusRegisterer(reg prometheus.Registerer) WakuNodeOption

+ func WithStaticRLNRelay(memberIndex *r.MembershipIndex, spamHandler rln.SpamHandler) WakuNodeOption

v0.7.0

Jun 26, 2023

Changes in this version

type WakuNodeOption

+ func WithPeerStore(ps peerstore.Peerstore) WakuNodeOption

v0.6.0

May 12, 2023

Changes in this version

+ type IdentityCredential = struct

+ IDCommitment byte32

+ IDNullifier byte32

+ IDSecretHash byte32

+ IDTrapdoor byte32

+ type PeerConnection struct

+ Connected bool

+ PeerID peer.ID

type RLNRelay

+ IdentityCredential func() (IdentityCredential, error)

type ReceptorService

+ SetHost func(h host.Host)

+ Start func(context.Context, relay.Subscription) error

+ Stop func()

type Service

+ SetHost func(h host.Host)

type WakuNode

+ func (w *WakuNode) DialPeerWithInfo(ctx context.Context, peerInfo peer.AddrInfo) error

+ func (w *WakuNode) FilterFullnode() *filter.WakuFilterFullNode

+ func (w *WakuNode) FilterLightnode() *filter.WakuFilterLightnode

+ func (w *WakuNode) LegacyFilter() *legacy_filter.WakuFilter

type WakuNodeOption

+ func WithConnectionNotification(ch chan<- PeerConnection) WakuNodeOption

+ func WithExternalIP(ip net.IP) WakuNodeOption

+ func WithLegacyWakuFilter(fullnode bool, filterOpts ...legacy_filter.Option) WakuNodeOption

+ func WithRendezvous(rendezvousPoints []multiaddr.Multiaddr) WakuNodeOption

+ func WithWakuFilterFullNode(filterOpts ...filter.Option) WakuNodeOption

+ func WithWakuFilterLightNode() WakuNodeOption

v0.5.2

Mar 14, 2023

Changes in this version

type WakuNodeOption

+ func WithRendezvousServer(db *rendezvous.DB) WakuNodeOption

v0.5.1

Feb 20, 2023

v0.5.0

Feb 17, 2023

Changes in this version

type WakuNode

+ func (w *WakuNode) FilterV2() *filterv2.WakuFilterLightnode

type WakuNodeOption

+ func NoDefaultWakuTopic() WakuNodeOption

+ func WithAdvertiseAddresses(advertiseAddrs ...ma.Multiaddr) WakuNodeOption

+ func WithLogLevel(lvl zapcore.Level) WakuNodeOption

+ func WithWakuFilterV2FullNode(filterOpts ...filter.Option) WakuNodeOption

+ func WithWakuFilterV2LightNode() WakuNodeOption

v0.4.0

Jan 23, 2023

Changes in this version

+ type PeerConnectorService interface

+ PeerChannel func() chan<- peer.AddrInfo

+ type ReceptorService interface

+ MessageChannel func() chan *protocol.Envelope

+ type Service interface

+ Start func(ctx context.Context) error

+ Stop func()

type WakuNodeOption

+ func WithDiscoverParams(minPeers int) WakuNodeOption

v0.3.1

Jan 3, 2023

v0.3.0

Dec 21, 2022

Changes in this version

+ var DefaultLibP2POptions = []libp2p.Option

+ var DefaultWakuNodeOptions = []WakuNodeOption

+ var GitCommit string

+ var Version string

+ type ConnStatus struct

+ HasHistory bool

+ IsOnline bool

+ Peers PeerStats

+ type ConnectionNotifier struct

+ DisconnectChan chan peer.ID

+ func NewConnectionNotifier(ctx context.Context, h host.Host, log *zap.Logger) ConnectionNotifier

+ func (c ConnectionNotifier) Close()

+ func (c ConnectionNotifier) ClosedStream(n network.Network, s network.Stream)

+ func (c ConnectionNotifier) Connected(n network.Network, cc network.Conn)

+ func (c ConnectionNotifier) Disconnected(n network.Network, cc network.Conn)

+ func (c ConnectionNotifier) Listen(n network.Network, m multiaddr.Multiaddr)

+ func (c ConnectionNotifier) ListenClose(n network.Network, m multiaddr.Multiaddr)

+ func (c ConnectionNotifier) OpenedStream(n network.Network, s network.Stream)

+ type MembershipKeyPair = struct

+ IDCommitment [32]byte

+ IDKey [32]byte

+ type Peer struct

+ Addrs []ma.Multiaddr

+ Connected bool

+ ID peer.ID

+ Protocols []string

+ type PeerStats map[peer.ID][]string

+ type RLNRelay interface

+ AppendRLNProof func(msg *pb.WakuMessage, senderEpochTime time.Time) error

+ MembershipContractAddress func() common.Address

+ MembershipIndex func() uint

+ MembershipKeyPair func() *MembershipKeyPair

+ Stop func()

+ type VersionInfo struct

+ Commit string

+ Golang string

+ System string

+ Version string

+ func GetVersionInfo() VersionInfo

+ func (v VersionInfo) String() string

+ type WakuNode struct

+ func New(ctx context.Context, opts ...WakuNodeOption) (*WakuNode, error)

+ func (w *WakuNode) AddPeer(address ma.Multiaddr, protocols ...string) (peer.ID, error)

+ func (w *WakuNode) Broadcaster() v2.Broadcaster

+ func (w *WakuNode) ClosePeerByAddress(address string) error

+ func (w *WakuNode) ClosePeerById(id peer.ID) error

+ func (w *WakuNode) DialPeer(ctx context.Context, address string) error

+ func (w *WakuNode) DialPeerByID(ctx context.Context, peerID peer.ID) error

+ func (w *WakuNode) DialPeerWithMultiAddress(ctx context.Context, address ma.Multiaddr) error

+ func (w *WakuNode) DiscV5() *discv5.DiscoveryV5

+ func (w *WakuNode) ENR() *enode.Node

+ func (w *WakuNode) Filter() *filter.WakuFilter

+ func (w *WakuNode) Host() host.Host

+ func (w *WakuNode) ID() string

+ func (w *WakuNode) Lightpush() *lightpush.WakuLightPush

+ func (w *WakuNode) ListenAddresses() []ma.Multiaddr

+ func (w *WakuNode) PeerCount() int

+ func (w *WakuNode) PeerExchange() *peer_exchange.WakuPeerExchange

+ func (w *WakuNode) PeerStats() PeerStats

+ func (w *WakuNode) Peers() ([]*Peer, error)

+ func (w *WakuNode) Publish(ctx context.Context, msg *pb.WakuMessage) error

+ func (w *WakuNode) RLNRelay() RLNRelay

+ func (w *WakuNode) Relay() *relay.WakuRelay

+ func (w *WakuNode) SetDiscV5Bootnodes(nodes []*enode.Node) error

+ func (w *WakuNode) Start() error

+ func (w *WakuNode) Status() (isOnline bool, hasHistory bool)

+ func (w *WakuNode) Stop()

+ func (w *WakuNode) Store() store.Store

+ func (w *WakuNode) Timesource() timesource.Timesource

+ type WakuNodeOption func(*WakuNodeParameters) error

+ func WithAdvertiseAddress(address *net.TCPAddr) WakuNodeOption

+ func WithConnectionStatusChannel(connStatus chan ConnStatus) WakuNodeOption

+ func WithDiscoveryV5(udpPort int, bootnodes []*enode.Node, autoUpdate bool, ...) WakuNodeOption

+ func WithDns4Domain(dns4Domain string) WakuNodeOption

+ func WithHostAddress(hostAddr *net.TCPAddr) WakuNodeOption

+ func WithKeepAlive(t time.Duration) WakuNodeOption

+ func WithLibP2POptions(opts ...libp2p.Option) WakuNodeOption

+ func WithLightPush() WakuNodeOption

+ func WithLogger(l *zap.Logger) WakuNodeOption

+ func WithMessageProvider(s store.MessageProvider) WakuNodeOption

+ func WithMultiaddress(addresses []multiaddr.Multiaddr) WakuNodeOption

+ func WithNTP(ntpURLs ...string) WakuNodeOption

+ func WithPeerExchange() WakuNodeOption

+ func WithPrivateKey(privKey *ecdsa.PrivateKey) WakuNodeOption

+ func WithSecureWebsockets(address string, port int, certPath string, keyPath string) WakuNodeOption

+ func WithWakuFilter(fullNode bool, filterOpts ...filter.Option) WakuNodeOption

+ func WithWakuRelay(opts ...pubsub.Option) WakuNodeOption

+ func WithWakuRelayAndMinPeers(minRelayPeersToPublish int, opts ...pubsub.Option) WakuNodeOption

+ func WithWakuStore(shouldStoreMessages bool, resumeNodes ...multiaddr.Multiaddr) WakuNodeOption

+ func WithWakuStoreFactory(factory storeFactory) WakuNodeOption

+ func WithWakuSwap(mode int, disconnectThreshold, paymentThreshold int) WakuNodeOption

+ func WithWebsockets(address string, port int) WakuNodeOption

+ type WakuNodeParameters struct

+ func (w *WakuNodeParameters) GetPrivKey() *crypto.PrivKey

+ func (w WakuNodeParameters) AddressFactory() basichost.AddrsFactory

+ func (w WakuNodeParameters) Identity() config.Option

+ func (w WakuNodeParameters) MultiAddresses() []multiaddr.Multiaddr

+ func (w WakuNodeParameters) TLSConfig() *tls.Config

v0.2.3-test

Dec 6, 2022

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