chain

package

Go to main page

Versions in this module

v0

v0.0.14

Dec 3, 2024

Changes in this version

type BitcoindConfig

+ ConnectionTimeout time.Duration

v0.0.13

Nov 15, 2024

Changes in this version

+ var Bitcoind28ErrMap = map[string]error

+ var BtcdErrMap = map[string]error

+ var BtcdErrMapPre2402 = map[string]error

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

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

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

type BitcoindClient

+ func (c *BitcoindClient) EstimateFee(numBlocks int64) (float64, error)

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

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

type Interface

+ EstimateFee func(numBlocks int64) (float64, error)

+ MapRPCErr func(err error) error

+ PublicNotifications func() <-chan interface{}

type NeutrinoClient

+ func (c *NeutrinoClient) EstimateFee(numBlocks int64) (float64, error)

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

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

type RPCClient

+ func (c *RPCClient) EstimateFee(numBlocks int64) (float64, error)

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

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

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

+ 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 ReorgFinished struct

+ FromHash *chainhash.Hash

+ FromHeight int32

+ ToHash *chainhash.Hash

+ ToHeight int32

v0.0.12

Oct 11, 2024

v0.0.11

Sep 26, 2024

v0.0.10

Sep 18, 2024

v0.0.9

Sep 18, 2024

v0.0.8

Aug 29, 2024

v0.0.7

Aug 21, 2024

v0.0.6

Jul 13, 2024

v0.0.5

Jun 18, 2024

v0.0.4

Jun 10, 2024

v0.0.3

Jun 1, 2024

v0.0.2

May 2, 2024

Changes in this version

+ const DefaultBatchWaitInterval

+ const DefaultGetRawTxBatchSize

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

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

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

+ func BackEnds() []string

+ func DisableLog()

+ func UseLogger(logger btclog.Logger)

+ type BitcoindClient struct

+ func SetupBitcoind(cfg *BitcoindConfig) (*BitcoindClient, error)

+ 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) GetRawMempool() ([]*chainhash.Hash, error)

+ func (c *BitcoindClient) GetRawTransaction(hash *chainhash.Hash) (*btcutil.Tx, 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) LookupInputMempoolSpend(op wire.OutPoint) (chainhash.Hash, bool)

+ 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) TestMempoolAccept(txns []*wire.MsgTx, maxFeeRate float64) ([]*btcjson.TestMempoolAcceptResult, error)

+ func (c *BitcoindClient) WaitForShutdown()

+ type BitcoindConfig struct

+ ChainParams *chaincfg.Params

+ Dialer Dialer

+ Host string

+ Pass string

+ PollingConfig *PollingConfig

+ PrunedModeMaxPeers int

+ User string

+ ZMQConfig *ZMQConfig

+ func NewBitcoindConfig(host, user, password string) *BitcoindConfig

+ type BitcoindConn struct

+ func NewBitcoindConn(cfg *BitcoindConfig) (*BitcoindConn, error)

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

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

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

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

+ func (c *BitcoindConn) Start() error

+ func (c *BitcoindConn) Stop()

+ type BitcoindEvents interface

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

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

+ Start func() error

+ Stop func() error

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

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

+ 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 Dialer = func(string) (net.Conn, error)

+ 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()

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

+ WaitForShutdown func()

+ type JitterTicker struct

+ C <-chan time.Time

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

+ func (jt *JitterTicker) Stop()

+ 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 struct

+ CS NeutrinoChainService

+ 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) TestMempoolAccept(txns []*wire.MsgTx, maxFeeRate float64) ([]*btcjson.TestMempoolAcceptResult, error)

+ func (s *NeutrinoClient) WaitForShutdown()

+ type PollingConfig struct

+ BlockPollingInterval time.Duration

+ RPCBatchInterval time.Duration

+ RPCBatchSize uint32

+ TxPollingInterval time.Duration

+ TxPollingIntervalJitter float64

+ type PrunedBlockDispatcher struct

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

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

+ func (d *PrunedBlockDispatcher) Query(blocks []*chainhash.Hash, cancelChan chan<- error, 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

+ type RPCClient struct

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

+ func NewRPCClientWithConfig(cfg *RPCClientConfig) (*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) LookupInputMempoolSpend(op wire.OutPoint) (chainhash.Hash, 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 RPCClientConfig struct

+ Chain *chaincfg.Params

+ Conn *rpcclient.ConnConfig

+ NotificationHandlers *rpcclient.NotificationHandlers

+ ReconnectAttempts int

+ 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

+ type ZMQConfig struct

+ MempoolPollingInterval time.Duration

+ PollingIntervalJitter float64

+ RPCBatchInterval time.Duration

+ RPCBatchSize uint32

+ ZMQBlockHost string

+ ZMQReadDeadline time.Duration

+ ZMQTxHost string

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