chain

Sep 16, 2025

Changes in this version

type RPCErr

+ const ErrBIP125ReplacementDisallowed

+ const ErrBadWitnessNonStandard

+ const ErrMaxFeeRateExceeded

+ const ErrMempoolChainTooLong

+ const ErrMempoolFull

+ const ErrMinRelayFeeNotMet

+ const ErrNoMemPool

+ const ErrNonStandardInputs

+ const ErrTRUCViolation

Mar 20, 2025

Changes in this version

+ type LogClosure func() string

+ func NewLogClosure(c func() string) LogClosure

+ func (c LogClosure) String() string

Mar 10, 2025

Changes in this version

+ const DefaultBatchWaitInterval

+ const DefaultGetRawTxBatchSize

+ var Bitcoind28ErrMap = map[string]error

+ var BtcdErrMap = map[string]error

+ var BtcdErrMapPre2402 = map[string]error

+ var ErrBackendVersion = errors.New("backend version too low")

+ var ErrBitcoindStartTimeout = errors.New("bitcoind start timeout")

+ var ErrInvalidParam = errors.New("invalid param")

+ var ErrUndefined = errors.New("undefined")

+ var ErrUnimplemented = errors.New("unimplemented")

type BitcoindClient

+ func (c *BitcoindClient) LookupInputMempoolSpend(op wire.OutPoint) (chainhash.Hash, bool)

+ func (c *BitcoindClient) MapRPCErr(rpcErr error) error

+ func (c *BitcoindClient) TestMempoolAccept(txns []*wire.MsgTx, maxFeeRate float64) ([]*btcjson.TestMempoolAcceptResult, error)

type Interface

+ MapRPCErr func(err error) error

+ TestMempoolAccept func([]*wire.MsgTx, float64) ([]*btcjson.TestMempoolAcceptResult, error)

+ type NeutrinoChainService interface

+ AddBytesReceived func(uint64)

+ AddBytesSent func(uint64)

+ AddPeer func(*neutrino.ServerPeer)

+ BanPeer func(string, banman.Reason) error

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

+ ChainParams func() chaincfg.Params

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

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

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

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

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

+ GetUtxo func(...neutrino.RescanOption) (*neutrino.SpendReport, error)

+ IsBanned func(addr string) bool

+ IsCurrent func() bool

+ NetTotals func() (uint64, uint64)

+ PeerByAddr func(string) *neutrino.ServerPeer

+ SendTransaction func(*wire.MsgTx) error

+ Start func() error

+ Stop func() error

+ UpdatePeerHeights func(*chainhash.Hash, int32, *neutrino.ServerPeer)

type NeutrinoClient

+ func (s *NeutrinoClient) MapRPCErr(rpcErr error) error

+ func (s *NeutrinoClient) TestMempoolAccept(txns []*wire.MsgTx, maxFeeRate float64) ([]*btcjson.TestMempoolAcceptResult, error)

type PollingConfig

+ RPCBatchInterval time.Duration

+ RPCBatchSize uint32

type PrunedBlockDispatcher

+ func (d *PrunedBlockDispatcher) CancelRequest(blockHash chainhash.Hash, err error)

type RPCClient

+ func NewRPCClientWithConfig(cfg *RPCClientConfig) (*RPCClient, error)

+ func (c *RPCClient) LookupInputMempoolSpend(op wire.OutPoint) (chainhash.Hash, bool)

+ func (c *RPCClient) MapRPCErr(rpcErr error) error

+ func (c *RPCClient) SendRawTransaction(tx *wire.MsgTx, allowHighFees bool) (*chainhash.Hash, error)

+ type RPCClientConfig struct

+ Chain *chaincfg.Params

+ Conn *rpcclient.ConnConfig

+ NotificationHandlers *rpcclient.NotificationHandlers

+ ReconnectAttempts int

+ type RPCErr uint32

+ const ErrBareMultiSig

+ const ErrBelowOutValue

+ const ErrCoinbaseTx

+ const ErrConflictingTx

+ const ErrDuplicateInput

+ const ErrDust

+ const ErrEmptyInput

+ const ErrEmptyOutput

+ const ErrEmptyPrevOut

+ const ErrInsufficientFee

+ const ErrInvalidOpcode

+ const ErrLargeOutput

+ const ErrLargeTotalOutput

+ const ErrMaxBurnExceeded

+ const ErrMaxFeeExceeded

+ const ErrMempoolConflict

+ const ErrMempoolMinFeeNotMet

+ const ErrMissingInputs

+ const ErrMissingInputsOrSpent

+ const ErrMultiOpReturn

+ const ErrNegativeOutput

+ const ErrNonBIP68Final

+ const ErrNonFinal

+ const ErrNonMandatoryScriptVerifyFlag

+ const ErrNonStandardScript

+ const ErrNonStandardVersion

+ const ErrOversizeTx

+ const ErrReplacementAddsUnconfirmed

+ const ErrSameNonWitnessData

+ const ErrScriptSigNotPushOnly

+ const ErrScriptSigSize

+ const ErrScriptVerifyFlag

+ const ErrTooManyReplacements

+ const ErrTooManySigOps

+ const ErrTxAlreadyConfirmed

+ const ErrTxAlreadyInMempool

+ const ErrTxAlreadyKnown

+ const ErrTxTooLarge

+ const ErrTxTooSmall

+ func (r RPCErr) Error() string

type ZMQConfig

+ RPCBatchInterval time.Duration

+ RPCBatchSize uint32

Apr 17, 2023

Changes in this version

type BitcoindClient

+ func (c *BitcoindClient) GetRawMempool() ([]*chainhash.Hash, error)

+ func (c *BitcoindClient) GetRawTransaction(hash *chainhash.Hash) (*btcutil.Tx, error)

type BitcoindEvents

+ LookupInputSpend func(op wire.OutPoint) (chainhash.Hash, bool)

+ type JitterTicker struct

+ C <-chan time.Time

+ func NewJitterTicker(d time.Duration, jitter float64) *JitterTicker

+ func (jt *JitterTicker) Stop()

type PollingConfig

+ TxPollingIntervalJitter float64

type ZMQConfig

+ MempoolPollingInterval time.Duration

+ PollingIntervalJitter float64

Apr 27, 2022

Changes in this version

type BitcoindConfig

+ PollingConfig *PollingConfig

+ ZMQConfig *ZMQConfig

+ type BitcoindEvents interface

+ BlockNotifications func() <-chan *wire.MsgBlock

+ Start func() error

+ Stop func() error

+ TxNotifications func() <-chan *wire.MsgTx

+ func NewBitcoindEventSubscriber(cfg *BitcoindConfig, client *rpcclient.Client) (BitcoindEvents, error)

+ type PollingConfig struct

+ BlockPollingInterval time.Duration

+ TxPollingInterval time.Duration

+ type ZMQConfig struct

+ ZMQBlockHost string

+ ZMQReadDeadline time.Duration

+ ZMQTxHost string

May 14, 2021

Changes in this version

+ type BitcoindConfig struct

+ ChainParams *chaincfg.Params

+ Dialer Dialer

+ Host string

+ Pass string

+ PrunedModeMaxPeers int

+ User string

+ ZMQBlockHost string

+ ZMQReadDeadline time.Duration

+ ZMQTxHost string

type BitcoindConn

+ func (c *BitcoindConn) GetBlock(hash *chainhash.Hash) (*wire.MsgBlock, error)

+ type Dialer = func(string) (net.Conn, error)

+ type PrunedBlockDispatcher struct

+ func NewPrunedBlockDispatcher(cfg *PrunedBlockDispatcherConfig) (*PrunedBlockDispatcher, error)

+ func (d *PrunedBlockDispatcher) Query(blocks []*chainhash.Hash, opts ...query.QueryOption) (<-chan *wire.MsgBlock, <-chan error)

+ func (d *PrunedBlockDispatcher) Start() error

+ func (d *PrunedBlockDispatcher) Stop()

+ type PrunedBlockDispatcherConfig struct

+ AllowSelfPeerConns bool

+ ChainParams *chaincfg.Params

+ Dial func(string) (net.Conn, error)

+ GetNodeAddresses func(*int32) ([]btcjson.GetNodeAddressesResult, error)

+ GetPeers func() ([]btcjson.GetPeerInfoResult, error)

+ MaxRequestInvs int

+ NumTargetPeers int

+ PeerReadyTimeout time.Duration

+ RefreshPeersTicker ticker.Ticker

Oct 14, 2019

Changes in this version

+ var ErrBitcoindClientShuttingDown = errors.New("client is shutting down")

+ func BackEnds() []string

+ func DisableLog()

+ func UseLogger(logger btclog.Logger)

+ type BitcoindClient struct

+ func (c *BitcoindClient) BackEnd() string

+ func (c *BitcoindClient) BlockStamp() (*waddrmgr.BlockStamp, error)

+ func (c *BitcoindClient) FilterBlocks(req *FilterBlocksRequest) (*FilterBlocksResponse, error)

+ func (c *BitcoindClient) GetBestBlock() (*chainhash.Hash, int32, error)

+ func (c *BitcoindClient) GetBlock(hash *chainhash.Hash) (*wire.MsgBlock, error)

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

+ func (c *BitcoindClient) GetBlockHeader(hash *chainhash.Hash) (*wire.BlockHeader, error)

+ func (c *BitcoindClient) GetBlockHeaderVerbose(hash *chainhash.Hash) (*btcjson.GetBlockHeaderVerboseResult, error)

+ func (c *BitcoindClient) GetBlockHeight(hash *chainhash.Hash) (int32, error)

+ func (c *BitcoindClient) GetBlockVerbose(hash *chainhash.Hash) (*btcjson.GetBlockVerboseResult, error)

+ func (c *BitcoindClient) GetRawTransactionVerbose(hash *chainhash.Hash) (*btcjson.TxRawResult, error)

+ func (c *BitcoindClient) GetTxOut(txHash *chainhash.Hash, index uint32, mempool bool) (*btcjson.GetTxOutResult, error)

+ func (c *BitcoindClient) IsCurrent() bool

+ func (c *BitcoindClient) LoadTxFilter(reset bool, filters ...interface{}) error

+ func (c *BitcoindClient) Notifications() <-chan interface{}

+ func (c *BitcoindClient) NotifyBlocks() error

+ func (c *BitcoindClient) NotifyReceived(addrs []btcutil.Address) error

+ func (c *BitcoindClient) NotifySpent(outPoints []*wire.OutPoint) error

+ func (c *BitcoindClient) NotifyTx(txids []chainhash.Hash) error

+ func (c *BitcoindClient) Rescan(blockHash *chainhash.Hash, addresses []btcutil.Address, ...) error

+ func (c *BitcoindClient) RescanBlocks(blockHashes []chainhash.Hash) ([]btcjson.RescannedBlock, error)

+ func (c *BitcoindClient) SendRawTransaction(tx *wire.MsgTx, allowHighFees bool) (*chainhash.Hash, error)

+ func (c *BitcoindClient) SetBirthday(t time.Time)

+ func (c *BitcoindClient) Start() error

+ func (c *BitcoindClient) Stop()

+ func (c *BitcoindClient) WaitForShutdown()

+ type BitcoindConn struct

+ func NewBitcoindConn(chainParams *chaincfg.Params, host, user, pass, zmqBlockHost, zmqTxHost string, ...) (*BitcoindConn, error)

+ func (c *BitcoindConn) AddClient(client *BitcoindClient)

+ func (c *BitcoindConn) NewBitcoindClient() *BitcoindClient

+ func (c *BitcoindConn) RemoveClient(id uint64)

+ func (c *BitcoindConn) Start() error

+ func (c *BitcoindConn) Stop()

+ type BlockConnected wtxmgr.BlockMeta

+ type BlockDisconnected wtxmgr.BlockMeta

+ type BlockFilterer struct

+ ExReverseFilter map[string]waddrmgr.ScopedIndex

+ FoundExternal map[waddrmgr.KeyScope]map[uint32]struct{}

+ FoundInternal map[waddrmgr.KeyScope]map[uint32]struct{}

+ FoundOutPoints map[wire.OutPoint]btcutil.Address

+ InReverseFilter map[string]waddrmgr.ScopedIndex

+ Params *chaincfg.Params

+ RelevantTxns []*wire.MsgTx

+ WatchedOutPoints map[wire.OutPoint]btcutil.Address

+ func NewBlockFilterer(params *chaincfg.Params, req *FilterBlocksRequest) *BlockFilterer

+ func (bf *BlockFilterer) FilterBlock(block *wire.MsgBlock) bool

+ func (bf *BlockFilterer) FilterOutputAddrs(addrs []btcutil.Address) bool

+ func (bf *BlockFilterer) FilterTx(tx *wire.MsgTx) bool

+ type ClientConnected struct

+ type ConcurrentQueue struct

+ func NewConcurrentQueue(bufferSize int) *ConcurrentQueue

+ func (cq *ConcurrentQueue) ChanIn() chan<- interface{}

+ func (cq *ConcurrentQueue) ChanOut() <-chan interface{}

+ func (cq *ConcurrentQueue) Start()

+ func (cq *ConcurrentQueue) Stop()

+ type FilterBlocksRequest struct

+ Blocks []wtxmgr.BlockMeta

+ ExternalAddrs map[waddrmgr.ScopedIndex]btcutil.Address

+ InternalAddrs map[waddrmgr.ScopedIndex]btcutil.Address

+ WatchedOutPoints map[wire.OutPoint]btcutil.Address

+ type FilterBlocksResponse struct

+ BatchIndex uint32

+ BlockMeta wtxmgr.BlockMeta

+ FoundExternalAddrs map[waddrmgr.KeyScope]map[uint32]struct{}

+ FoundInternalAddrs map[waddrmgr.KeyScope]map[uint32]struct{}

+ FoundOutPoints map[wire.OutPoint]btcutil.Address

+ RelevantTxns []*wire.MsgTx

+ type FilteredBlockConnected struct

+ Block *wtxmgr.BlockMeta

+ RelevantTxs []*wtxmgr.TxRecord

+ type Interface interface

+ BackEnd func() string

+ BlockStamp func() (*waddrmgr.BlockStamp, error)

+ FilterBlocks func(*FilterBlocksRequest) (*FilterBlocksResponse, error)

+ GetBestBlock func() (*chainhash.Hash, int32, error)

+ GetBlock func(*chainhash.Hash) (*wire.MsgBlock, error)

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

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

+ IsCurrent func() bool

+ Notifications func() <-chan interface{}

+ NotifyBlocks func() error

+ NotifyReceived func([]btcutil.Address) error

+ Rescan func(*chainhash.Hash, []btcutil.Address, map[wire.OutPoint]btcutil.Address) error

+ SendRawTransaction func(*wire.MsgTx, bool) (*chainhash.Hash, error)

+ Start func() error

+ Stop func()

+ WaitForShutdown func()

+ type NeutrinoClient struct

+ CS *neutrino.ChainService

+ func NewNeutrinoClient(chainParams *chaincfg.Params, chainService *neutrino.ChainService) *NeutrinoClient

+ func (s *NeutrinoClient) BackEnd() string

+ func (s *NeutrinoClient) BlockStamp() (*waddrmgr.BlockStamp, error)

+ func (s *NeutrinoClient) FilterBlocks(req *FilterBlocksRequest) (*FilterBlocksResponse, error)

+ func (s *NeutrinoClient) GetBestBlock() (*chainhash.Hash, int32, error)

+ func (s *NeutrinoClient) GetBlock(hash *chainhash.Hash) (*wire.MsgBlock, error)

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

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

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

+ func (s *NeutrinoClient) IsCurrent() bool

+ func (s *NeutrinoClient) Notifications() <-chan interface{}

+ func (s *NeutrinoClient) NotifyBlocks() error

+ func (s *NeutrinoClient) NotifyReceived(addrs []btcutil.Address) error

+ func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Address, ...) error

+ func (s *NeutrinoClient) SendRawTransaction(tx *wire.MsgTx, allowHighFees bool) (*chainhash.Hash, error)

+ func (s *NeutrinoClient) SetStartTime(startTime time.Time)

+ func (s *NeutrinoClient) Start() error

+ func (s *NeutrinoClient) Stop()

+ func (s *NeutrinoClient) WaitForShutdown()

+ type RPCClient struct

+ func NewRPCClient(chainParams *chaincfg.Params, connect, user, pass string, certs []byte, ...) (*RPCClient, error)

+ func (c *RPCClient) BackEnd() string

+ func (c *RPCClient) BlockStamp() (*waddrmgr.BlockStamp, error)

+ func (c *RPCClient) FilterBlocks(req *FilterBlocksRequest) (*FilterBlocksResponse, error)

+ func (c *RPCClient) IsCurrent() bool

+ func (c *RPCClient) Notifications() <-chan interface{}

+ func (c *RPCClient) POSTClient() (*rpcclient.Client, error)

+ func (c *RPCClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Address, ...) error

+ func (c *RPCClient) Start() error

+ func (c *RPCClient) Stop()

+ func (c *RPCClient) WaitForShutdown()

+ type RelevantTx struct

+ Block *wtxmgr.BlockMeta

+ TxRecord *wtxmgr.TxRecord

+ type RescanFinished struct

+ Hash *chainhash.Hash

+ Height int32

+ Time time.Time

+ type RescanProgress struct

+ Hash *chainhash.Hash

+ Height int32

+ Time time.Time