spv

Documentation

Index

• func UseLogger(logger slog.Logger)
• type Notifications
• type Syncer
  • func NewSyncer(w *wallet.Wallet, lp *p2p.LocalPeer) *Syncer
  • func (s *Syncer) GetBlocks(ctx context.Context, blockHashes []*chainhash.Hash) ([]*wire.MsgBlock, error)
  • func (s *Syncer) GetCFilters(ctx context.Context, blockHashes []*chainhash.Hash) ([]*gcs.Filter, error)
  • func (s *Syncer) GetHeaders(ctx context.Context, blockLocators []*chainhash.Hash, hashStop *chainhash.Hash) ([]*wire.BlockHeader, error)
  • func (s *Syncer) LoadTxFilter(ctx context.Context, reload bool, addrs []dcrutil.Address, ...) error
  • func (s *Syncer) PublishTransactions(ctx context.Context, txs ...*wire.MsgTx) error
  • func (s *Syncer) Rescan(ctx context.Context, blockHashes []chainhash.Hash, r wallet.RescanSaver) error
  • func (s *Syncer) Run(ctx context.Context) error
  • func (s *Syncer) SetNotifications(ntfns *Notifications)
  • func (s *Syncer) SetPersistantPeers(peers []string)
  • func (s *Syncer) StakeDifficulty(ctx context.Context) (dcrutil.Amount, error)
  • func (s *Syncer) String() string

Functions

func UseLogger

func UseLogger(logger slog.Logger)

UseLogger uses a specified Logger to output package logging info.

Types

type Notifications

type Notifications struct {
	Synced                       func(sync bool)
	PeerConnected                func(peerCount int32, addr string)
	PeerDisconnected             func(peerCount int32, addr string)
	FetchMissingCFiltersStarted  func()
	FetchMissingCFiltersProgress func(startCFiltersHeight, endCFiltersHeight int32)
	FetchMissingCFiltersFinished func()
	FetchHeadersStarted          func()
	FetchHeadersProgress         func(lastHeaderHeight int32, lastHeaderTime int64)
	FetchHeadersFinished         func()
	DiscoverAddressesStarted     func()
	DiscoverAddressesFinished    func()
	RescanStarted                func()
	RescanProgress               func(rescannedThrough int32)
	RescanFinished               func()
}

Notifications struct to contain all of the upcoming callbacks that will be used to update the rpc streams for syncing.

type Syncer

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

Syncer implements wallet synchronization services by over the Decred wire protocol using Simplified Payment Verification (SPV) with compact filters.

func NewSyncer

func NewSyncer(w *wallet.Wallet, lp *p2p.LocalPeer) *Syncer

NewSyncer creates a Syncer that will sync the wallet using SPV.

func (*Syncer) GetBlocks

func (s *Syncer) GetBlocks(ctx context.Context, blockHashes []*chainhash.Hash) ([]*wire.MsgBlock, error)

GetBlocks implements the GetBlocks method of the wallet.Peer interface.

func (*Syncer) GetCFilters

func (s *Syncer) GetCFilters(ctx context.Context, blockHashes []*chainhash.Hash) ([]*gcs.Filter, error)

GetCFilters implements the GetCFilters method of the wallet.Peer interface.

func (*Syncer) GetHeaders

func (s *Syncer) GetHeaders(ctx context.Context, blockLocators []*chainhash.Hash, hashStop *chainhash.Hash) ([]*wire.BlockHeader, error)

GetHeaders implements the GetHeaders method of the wallet.Peer interface.

func (*Syncer) LoadTxFilter

func (s *Syncer) LoadTxFilter(ctx context.Context, reload bool, addrs []dcrutil.Address, outpoints []wire.OutPoint) error

LoadTxFilter implements the LoadTxFilter method of the wallet.NetworkBackend interface.

func (*Syncer) PublishTransactions

func (s *Syncer) PublishTransactions(ctx context.Context, txs ...*wire.MsgTx) error

PublishTransactions implements the PublishTransaction method of the wallet.Peer interface.

func (*Syncer) Rescan

func (s *Syncer) Rescan(ctx context.Context, blockHashes []chainhash.Hash, r wallet.RescanSaver) error

Rescan implements the Rescan method of the wallet.NetworkBackend interface.

func (*Syncer) Run

func (s *Syncer) Run(ctx context.Context) error

Run synchronizes the wallet, returning when synchronization fails or the context is cancelled.

func (*Syncer) SetNotifications

func (s *Syncer) SetNotifications(ntfns *Notifications)

SetNotifications sets the possible various callbacks that are used to notify interested parties to the syncing progress.

func (*Syncer) SetPersistantPeers

func (s *Syncer) SetPersistantPeers(peers []string)

SetPersistantPeers sets each peer as a persistant peer and disables DNS seeding and peer discovery.

func (*Syncer) StakeDifficulty

func (s *Syncer) StakeDifficulty(ctx context.Context) (dcrutil.Amount, error)

StakeDifficulty implements the StakeDifficulty method of the wallet.NetworkBackend interface.

This implementation of the method will always error as the stake difficulty is not queryable over wire protocol, and when the next stake difficulty is available in a header commitment, the wallet will be able to determine this itself without requiring the NetworkBackend.

func (*Syncer) String

func (s *Syncer) String() string