Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

discovery

package

Go to main page

Versions in this module

v0

v0.15.10001

Jan 16, 2023

v0.15.101

Jan 16, 2023

Changes in this version

+ const DefaultChannelUpdateInterval

+ const DefaultDelayedQueryReplyInterval

+ const DefaultHistoricalSyncInterval

+ const DefaultMaxChannelUpdateBurst

+ const DefaultMaxUndelayedQueryReplies

+ const DefaultSyncerRotationInterval

+ var ErrCorruptedMessageStore = errors.New(...)

+ var ErrGossipSyncerExiting = errors.New("gossip syncer exiting")

+ var ErrGossipSyncerNotFound = errors.New("gossip syncer not found")

+ var ErrGossiperShuttingDown = errors.New("gossiper is shutting down")

+ var ErrSyncManagerExiting = errors.New("sync manager exiting")

+ var ErrSyncTransitionTimeout = errors.New(...)

+ var ErrUnsupportedMessage = errors.New("unsupported message type")

+ func DisableLog()

+ func IsKeepAliveUpdate(update *lnwire.ChannelUpdate, prev *channeldb.ChannelEdgePolicy) bool

+ func MultiSourceBootstrap(ignore map[autopilot.NodeID]struct{}, numAddrs uint32, ...) ([]*lnwire.NetAddress, error)

+ func UseLogger(logger btclog.Logger)

+ type AuthenticatedGossiper struct

+ func New(cfg Config, selfKeyDesc *keychain.KeyDescriptor) *AuthenticatedGossiper

+ func (d *AuthenticatedGossiper) InitSyncState(syncPeer lnpeer.Peer)

+ func (d *AuthenticatedGossiper) ProcessLocalAnnouncement(msg lnwire.Message, optionalFields ...OptionalMsgField) chan error

+ func (d *AuthenticatedGossiper) ProcessRemoteAnnouncement(msg lnwire.Message, peer lnpeer.Peer) chan error

+ func (d *AuthenticatedGossiper) PropagateChanPolicyUpdate(edgesToUpdate []EdgeWithInfo) error

+ func (d *AuthenticatedGossiper) PruneSyncState(peer route.Vertex)

+ func (d *AuthenticatedGossiper) Start() error

+ func (d *AuthenticatedGossiper) Stop() error

+ func (d *AuthenticatedGossiper) SyncManager() *SyncManager

+ type ChanSeries struct

+ func NewChanSeries(graph *channeldb.ChannelGraph) *ChanSeries

+ func (c *ChanSeries) FetchChanAnns(chain chainhash.Hash, shortChanIDs []lnwire.ShortChannelID) ([]lnwire.Message, error)

+ func (c *ChanSeries) FetchChanUpdates(chain chainhash.Hash, shortChanID lnwire.ShortChannelID) ([]*lnwire.ChannelUpdate, error)

+ func (c *ChanSeries) FilterChannelRange(chain chainhash.Hash, startHeight, endHeight uint32) ([]channeldb.BlockChannelRange, error)

+ func (c *ChanSeries) FilterKnownChanIDs(chain chainhash.Hash, superSet []lnwire.ShortChannelID) ([]lnwire.ShortChannelID, error)

+ func (c *ChanSeries) HighestChanID(chain chainhash.Hash) (*lnwire.ShortChannelID, error)

+ func (c *ChanSeries) UpdatesInHorizon(chain chainhash.Hash, startTime time.Time, endTime time.Time) ([]lnwire.Message, error)

+ type ChannelGraphBootstrapper struct

+ func (c *ChannelGraphBootstrapper) Name() string

+ func (c *ChannelGraphBootstrapper) SampleNodeAddrs(numAddrs uint32, ignore map[autopilot.NodeID]struct{}) ([]*lnwire.NetAddress, error)

+ type ChannelGraphTimeSeries interface

+ FetchChanAnns func(chain chainhash.Hash, shortChanIDs []lnwire.ShortChannelID) ([]lnwire.Message, error)

+ FetchChanUpdates func(chain chainhash.Hash, shortChanID lnwire.ShortChannelID) ([]*lnwire.ChannelUpdate, error)

+ FilterChannelRange func(chain chainhash.Hash, startHeight, endHeight uint32) ([]channeldb.BlockChannelRange, error)

+ FilterKnownChanIDs func(chain chainhash.Hash, superSet []lnwire.ShortChannelID) ([]lnwire.ShortChannelID, error)

+ HighestChanID func(chain chainhash.Hash) (*lnwire.ShortChannelID, error)

+ UpdatesInHorizon func(chain chainhash.Hash, startTime time.Time, endTime time.Time) ([]lnwire.Message, error)

+ type Config struct

+ ActiveSyncerTimeoutTicker ticker.Ticker

+ AnnSigner lnwallet.MessageSigner

+ Broadcast func(skips map[route.Vertex]struct{}, msg ...lnwire.Message) error

+ ChainHash chainhash.Hash

+ ChanSeries ChannelGraphTimeSeries

+ ChannelUpdateInterval time.Duration

+ FindBaseByAlias func(alias lnwire.ShortChannelID) (lnwire.ShortChannelID, error)

+ GetAlias func(lnwire.ChannelID) (lnwire.ShortChannelID, error)

+ HistoricalSyncTicker ticker.Ticker

+ IgnoreHistoricalFilters bool

+ IsAlias func(scid lnwire.ShortChannelID) bool

+ MaxChannelUpdateBurst int

+ MessageStore GossipMessageStore

+ MinimumBatchSize int

+ Notifier chainntnfs.ChainNotifier

+ NotifyWhenOffline func(peerPubKey [33]byte) <-chan struct{}

+ NotifyWhenOnline func(peerPubKey [33]byte, peerChan chan<- lnpeer.Peer)

+ NumActiveSyncers int

+ PinnedSyncers PinnedSyncers

+ ProofMatureDelta uint32

+ RebroadcastInterval time.Duration

+ RetransmitTicker ticker.Ticker

+ RotateTicker ticker.Ticker

+ Router routing.ChannelGraphSource

+ SelfNodeAnnouncement func(refresh bool) (lnwire.NodeAnnouncement, error)

+ SignAliasUpdate func(u *lnwire.ChannelUpdate) (*ecdsa.Signature, error)

+ SubBatchDelay time.Duration

+ TrickleDelay time.Duration

+ WaitingProofStore *channeldb.WaitingProofStore

+ type DNSSeedBootstrapper struct

+ func (d *DNSSeedBootstrapper) Name() string

+ func (d *DNSSeedBootstrapper) SampleNodeAddrs(numAddrs uint32, ignore map[autopilot.NodeID]struct{}) ([]*lnwire.NetAddress, error)

+ type EdgeWithInfo struct

+ Edge *channeldb.ChannelEdgePolicy

+ Info *channeldb.ChannelEdgeInfo

+ type GossipMessageStore interface

+ AddMessage func(lnwire.Message, [33]byte) error

+ DeleteMessage func(lnwire.Message, [33]byte) error

+ Messages func() (map[[33]byte][]lnwire.Message, error)

+ MessagesForPeer func([33]byte) ([]lnwire.Message, error)

+ Peers func() (map[[33]byte]struct{}, error)

+ type GossipSyncer struct

+ func (g *GossipSyncer) ApplyGossipFilter(filter *lnwire.GossipTimestampRange) error

+ func (g *GossipSyncer) FilterGossipMsgs(msgs ...msgWithSenders)

+ func (g *GossipSyncer) ProcessQueryMsg(msg lnwire.Message, peerQuit <-chan struct{}) error

+ func (g *GossipSyncer) ProcessSyncTransition(newSyncType SyncerType) error

+ func (g *GossipSyncer) ResetSyncedSignal() chan struct{}

+ func (g *GossipSyncer) Start()

+ func (g *GossipSyncer) Stop()

+ func (g *GossipSyncer) SyncType() SyncerType

+ type MessageStore struct

+ func NewMessageStore(db kvdb.Backend) (*MessageStore, error)

+ func (s *MessageStore) AddMessage(msg lnwire.Message, peerPubKey [33]byte) error

+ func (s *MessageStore) DeleteMessage(msg lnwire.Message, peerPubKey [33]byte) error

+ func (s *MessageStore) Messages() (map[[33]byte][]lnwire.Message, error)

+ func (s *MessageStore) MessagesForPeer(peerPubKey [33]byte) ([]lnwire.Message, error)

+ func (s *MessageStore) Peers() (map[[33]byte]struct{}, error)

+ type NetworkPeerBootstrapper interface

+ Name func() string

+ SampleNodeAddrs func(numAddrs uint32, ignore map[autopilot.NodeID]struct{}) ([]*lnwire.NetAddress, error)

+ func NewDNSSeedBootstrapper(seeds [][2]string, net tor.Net, timeout time.Duration) NetworkPeerBootstrapper

+ func NewGraphBootstrapper(cg autopilot.ChannelGraph) (NetworkPeerBootstrapper, error)

+ type OptionalMsgField func(*optionalMsgFields)

+ func ChannelCapacity(capacity btcutil.Amount) OptionalMsgField

+ func ChannelPoint(op wire.OutPoint) OptionalMsgField

+ func RemoteAlias(alias *lnwire.ShortChannelID) OptionalMsgField

+ type PinnedSyncers map[route.Vertex]struct

+ type SyncManager struct

+ func (m *SyncManager) GossipSyncer(peer route.Vertex) (*GossipSyncer, bool)

+ func (m *SyncManager) GossipSyncers() map[route.Vertex]*GossipSyncer

+ func (m *SyncManager) InitSyncState(peer lnpeer.Peer) error

+ func (m *SyncManager) IsGraphSynced() bool

+ func (m *SyncManager) PruneSyncState(peer route.Vertex)

+ func (m *SyncManager) Start()

+ func (m *SyncManager) Stop()

+ type SyncManagerCfg struct

+ BestHeight func() uint32

+ ChainHash chainhash.Hash

+ ChanSeries ChannelGraphTimeSeries

+ HistoricalSyncTicker ticker.Ticker

+ IgnoreHistoricalFilters bool

+ NumActiveSyncers int

+ PinnedSyncers PinnedSyncers

+ RotateTicker ticker.Ticker

+ type SyncerType uint8

+ const ActiveSync

+ const PassiveSync

+ const PinnedSync

+ func (t SyncerType) IsActiveSync() bool

+ func (t SyncerType) String() string

v0.5.1-beta

Nov 28, 2018