neutrino

package module

Go to main page

Versions in this module

v0

v0.14.2

Jul 30, 2022

Changes in this version

+ var QueryInvalidTxThreshold float32 = 0.6

+ var QueryRejectTimeout = time.Second

type QueryOption

+ func InvalidTxThreshold(invalidTxThreshold float32) QueryOption

+ func RejectTimeout(rejectTimeout time.Duration) QueryOption

type ServerPeer

+ func (sp *ServerPeer) OnAddrV2(_ *peer.Peer, msg *wire.MsgAddrV2)

v0.13.2

May 10, 2022

v0.12.2

May 8, 2022

v0.12.1

Nov 6, 2021

Changes in this version

+ func VerifyBasicBlockFilter(filter *gcs.Filter, block *btcutil.Block) (int, error)

type Config

+ BlockCache *lru.Cache

+ BroadcastTimeout time.Duration

+ PersistToDisk bool

type RescanOption

+ func ProgressHandler(handler ScanProgressHandler) RescanOption

+ type ScanProgressHandler func(lastProcessedBlock uint32)

type SpendReport

+ BlockHash *chainhash.Hash

+ BlockHeight uint32

+ BlockIndex uint32

v0.12.0

Jul 20, 2020

v0.11.2

Mar 28, 2020

Changes in this version

type QueryOption

+ func MaxBatchSize(maxSize int64) QueryOption

v0.11.1

Feb 5, 2020

v0.11.0

Nov 25, 2019

Changes in this version

type ChainService

+ func (s *ChainService) ConnectedPeers() (<-chan query.Peer, func(), error)

type ServerPeer

+ func (sp *ServerPeer) OnDisconnect() <-chan struct{}

+ func (sp *ServerPeer) SubscribeRecvMsg() (<-chan wire.Message, func())

v0.10.0

Oct 16, 2019

Changes in this version

+ var BanDuration = time.Hour * 24

+ var BanThreshold = uint32(100)

+ var ConnectionRetryInterval = time.Second * 5

+ var DefaultBlockCacheSize uint64 = 4096 * 10 * 1000

+ var DefaultFilterCacheSize uint64 = 3120 * 10 * 1000

+ var DisableDNSSeed = false

+ var ErrFilterFetchFailed = fmt.Errorf("unable to fetch cfilter")

+ var ErrGetUtxoCancelled = errors.New("get utxo request cancelled")

+ var ErrRescanExit = errors.New("rescan exited")

+ var ErrShuttingDown = errors.New("neutrino shutting down")

+ var MaxPeers = 125

+ var QueryBatchTimeout = time.Second * 30

+ var QueryEncoding = wire.WitnessEncoding

+ var QueryNumRetries = 2

+ var QueryPeerConnectTimeout = time.Second * 30

+ var QueryPeerCooldown = time.Second * 5

+ var QueryTimeout = time.Second * 10

+ var RequiredServices = wire.SFNodeNetwork | wire.SFNodeWitness | wire.SFNodeCF

+ var Services = wire.SFNodeWitness | wire.SFNodeCF

+ var TargetOutbound = 8

+ var UserAgentName = "neutrino"

+ var UserAgentVersion = "0.0.4-beta"

+ func DisableLog()

+ func UseLogger(logger btclog.Logger)

+ type ChainService struct

+ BlockCache *lru.Cache

+ BlockHeaders headerfs.BlockHeaderStore

+ FilterCache *lru.Cache

+ FilterDB filterdb.FilterDatabase

+ RegFilterHeaders *headerfs.FilterHeaderStore

+ func NewChainService(cfg Config) (*ChainService, error)

+ func (s *ChainService) AddBytesReceived(bytesReceived uint64)

+ func (s *ChainService) AddBytesSent(bytesSent uint64)

+ func (s *ChainService) AddPeer(sp *ServerPeer)

+ func (s *ChainService) AddedNodeInfo() []*ServerPeer

+ func (s *ChainService) BanPeer(addr string, reason banman.Reason) error

+ func (s *ChainService) BestBlock() (*headerfs.BlockStamp, error)

+ func (s *ChainService) ChainParams() chaincfg.Params

+ func (s *ChainService) ConnectNode(addr string, permanent bool) error

+ func (s *ChainService) ConnectedCount() int32

+ func (s *ChainService) DisconnectNodeByAddr(addr string) error

+ func (s *ChainService) DisconnectNodeByID(id int32) error

+ func (s *ChainService) ForAllPeers(closure func(sp *ServerPeer))

+ func (s *ChainService) GetBlock(blockHash chainhash.Hash, options ...QueryOption) (*btcutil.Block, error)

+ func (s *ChainService) GetBlockHash(height int64) (*chainhash.Hash, error)

+ func (s *ChainService) GetBlockHeader(blockHash *chainhash.Hash) (*wire.BlockHeader, error)

+ func (s *ChainService) GetBlockHeight(hash *chainhash.Hash) (int32, error)

+ func (s *ChainService) GetCFilter(blockHash chainhash.Hash, filterType wire.FilterType, options ...QueryOption) (*gcs.Filter, error)

+ func (s *ChainService) GetUtxo(options ...RescanOption) (*SpendReport, error)

+ func (s *ChainService) IsBanned(addr string) bool

+ func (s *ChainService) IsCurrent() bool

+ func (s *ChainService) NetTotals() (uint64, uint64)

+ func (s *ChainService) OutboundGroupCount(key string) int

+ func (s *ChainService) PeerByAddr(addr string) *ServerPeer

+ func (s *ChainService) Peers() []*ServerPeer

+ func (s *ChainService) RemoveNodeByAddr(addr string) error

+ func (s *ChainService) RemoveNodeByID(id int32) error

+ func (s *ChainService) SendTransaction(tx *wire.MsgTx) error

+ func (s *ChainService) Start() error

+ func (s *ChainService) Stop() error

+ func (s *ChainService) UpdatePeerHeights(latestBlkHash *chainhash.Hash, latestHeight int32, updateSource *ServerPeer)

+ type ChainSource interface

+ BestBlock func() (*headerfs.BlockStamp, error)

+ ChainParams func() chaincfg.Params

+ GetBlock func(chainhash.Hash, ...QueryOption) (*btcutil.Block, error)

+ GetBlockHeader func(*chainhash.Hash) (*wire.BlockHeader, uint32, error)

+ GetBlockHeaderByHeight func(uint32) (*wire.BlockHeader, error)

+ GetCFilter func(chainhash.Hash, wire.FilterType, ...QueryOption) (*gcs.Filter, error)

+ GetFilterHeaderByHeight func(uint32) (*chainhash.Hash, error)

+ Subscribe func(bestHeight uint32) (*blockntfns.Subscription, error)

+ type Config struct

+ AddPeers []string

+ AssertFilterHeader *headerfs.FilterHeader

+ BlockCacheSize uint64

+ ChainParams chaincfg.Params

+ ConnectPeers []string

+ DataDir string

+ Database walletdb.DB

+ Dialer func(addr net.Addr) (net.Conn, error)

+ FilterCacheSize uint64

+ NameResolver func(host string) ([]net.IP, error)

+ type GetUtxoRequest struct

+ BirthHeight uint32

+ Input *InputWithScript

+ func (r *GetUtxoRequest) Result(cancel <-chan struct{}) (*SpendReport, error)

+ type GetUtxoRequestPQ []*GetUtxoRequest

+ func (pq *GetUtxoRequestPQ) IsEmpty() bool

+ func (pq *GetUtxoRequestPQ) Peek() *GetUtxoRequest

+ func (pq *GetUtxoRequestPQ) Pop() interface{}

+ func (pq *GetUtxoRequestPQ) Push(x interface{})

+ func (pq GetUtxoRequestPQ) Len() int

+ func (pq GetUtxoRequestPQ) Less(i, j int) bool

+ func (pq GetUtxoRequestPQ) Swap(i, j int)

+ type InputWithScript struct

+ OutPoint wire.OutPoint

+ PkScript []byte

+ type QueryAccess interface

+ type QueryOption func(*queryOptions)

+ func DoneChan(doneChan chan<- struct{}) QueryOption

+ func Encoding(encoding wire.MessageEncoding) QueryOption

+ func NumRetries(numRetries uint8) QueryOption

+ func OptimisticBatch() QueryOption

+ func OptimisticReverseBatch() QueryOption

+ func PeerConnectTimeout(timeout time.Duration) QueryOption

+ func PersistToDisk() QueryOption

+ func Timeout(timeout time.Duration) QueryOption

+ type Rescan struct

+ func NewRescan(chain ChainSource, options ...RescanOption) *Rescan

+ func (r *Rescan) Start() <-chan error

+ func (r *Rescan) Update(options ...UpdateOption) error

+ func (r *Rescan) WaitForShutdown()

+ type RescanChainSource struct

+ func (s *RescanChainSource) GetBlockHeader(hash *chainhash.Hash) (*wire.BlockHeader, uint32, error)

+ func (s *RescanChainSource) GetBlockHeaderByHeight(height uint32) (*wire.BlockHeader, error)

+ func (s *RescanChainSource) GetFilterHeaderByHeight(height uint32) (*chainhash.Hash, error)

+ func (s *RescanChainSource) Subscribe(bestHeight uint32) (*blockntfns.Subscription, error)

+ type RescanOption func(ro *rescanOptions)

+ func EndBlock(endBlock *headerfs.BlockStamp) RescanOption

+ func NotificationHandlers(ntfn rpcclient.NotificationHandlers) RescanOption

+ func QueryOptions(options ...QueryOption) RescanOption

+ func QuitChan(quit <-chan struct{}) RescanOption

+ func StartBlock(startBlock *headerfs.BlockStamp) RescanOption

+ func StartTime(startTime time.Time) RescanOption

+ func TxIdx(txIdx uint32) RescanOption

+ func WatchAddrs(watchAddrs ...btcutil.Address) RescanOption

+ func WatchInputs(watchInputs ...InputWithScript) RescanOption

+ type ServerPeer struct

+ func (sp *ServerPeer) OnAddr(_ *peer.Peer, msg *wire.MsgAddr)

+ func (sp *ServerPeer) OnFeeFilter(_ *peer.Peer, msg *wire.MsgFeeFilter)

+ func (sp *ServerPeer) OnHeaders(p *peer.Peer, msg *wire.MsgHeaders)

+ func (sp *ServerPeer) OnInv(p *peer.Peer, msg *wire.MsgInv)

+ func (sp *ServerPeer) OnRead(_ *peer.Peer, bytesRead int, msg wire.Message, err error)

+ func (sp *ServerPeer) OnReject(_ *peer.Peer, msg *wire.MsgReject)

+ func (sp *ServerPeer) OnVerAck(_ *peer.Peer, msg *wire.MsgVerAck)

+ func (sp *ServerPeer) OnVersion(_ *peer.Peer, msg *wire.MsgVersion) *wire.MsgReject

+ func (sp *ServerPeer) OnWrite(_ *peer.Peer, bytesWritten int, msg wire.Message, err error)

+ type SpendReport struct

+ Output *wire.TxOut

+ SpendingInputIndex uint32

+ SpendingTx *wire.MsgTx

+ SpendingTxHeight uint32

+ type UpdateOption func(uo *updateOptions)

+ func AddAddrs(addrs ...btcutil.Address) UpdateOption

+ func AddInputs(inputs ...InputWithScript) UpdateOption

+ func DisableDisconnectedNtfns(disabled bool) UpdateOption

+ func Rewind(height uint32) UpdateOption

+ type UtxoScanner struct

+ func NewUtxoScanner(cfg *UtxoScannerConfig) *UtxoScanner

+ func (s *UtxoScanner) Enqueue(input *InputWithScript, birthHeight uint32) (*GetUtxoRequest, error)

+ func (s *UtxoScanner) Start() error

+ func (s *UtxoScanner) Stop() error

+ type UtxoScannerConfig struct

+ BestSnapshot func() (*headerfs.BlockStamp, error)

+ BlockFilterMatches func(ro *rescanOptions, blockHash *chainhash.Hash) (bool, error)

+ GetBlock func(chainhash.Hash, ...QueryOption) (*btcutil.Block, error)

+ GetBlockHash func(height int64) (*chainhash.Hash, error)

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