Versions in this module Expand all Collapse all v0 v0.0.8 Apr 4, 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) (*acmjson.GetBlockHeaderVerboseResult, error) + func (c *BitcoindClient) GetBlockHeight(hash *chainhash.Hash) (int32, error) + func (c *BitcoindClient) GetBlockVerbose(hash *chainhash.Hash) (*acmjson.GetBlockVerboseResult, error) + func (c *BitcoindClient) GetRawTransactionVerbose(hash *chainhash.Hash) (*acmjson.TxRawResult, error) + func (c *BitcoindClient) GetTxOut(txHash *chainhash.Hash, index uint32, mempool bool) (*acmjson.GetTxOutResult, error) + 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 []acmutil.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 []acmutil.Address, ...) error + func (c *BitcoindClient) RescanBlocks(blockHashes []chainhash.Hash) ([]acmjson.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]acmutil.Address + InReverseFilter map[string]waddrmgr.ScopedIndex + Params *chaincfg.Params + RelevantTxns []*wire.MsgTx + WatchedOutPoints map[wire.OutPoint]acmutil.Address + func NewBlockFilterer(params *chaincfg.Params, req *FilterBlocksRequest) *BlockFilterer + func (bf *BlockFilterer) FilterBlock(block *wire.MsgBlock) bool + func (bf *BlockFilterer) FilterOutputAddrs(addrs []acmutil.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]acmutil.Address + InternalAddrs map[waddrmgr.ScopedIndex]acmutil.Address + WatchedOutPoints map[wire.OutPoint]acmutil.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]acmutil.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) + Notifications func() <-chan interface{} + NotifyBlocks func() error + NotifyReceived func([]acmutil.Address) error + Rescan func(*chainhash.Hash, []acmutil.Address, map[wire.OutPoint]acmutil.Address) error + SendRawTransaction func(*wire.MsgTx, bool) (*chainhash.Hash, error) + Start func() error + Stop func() + WaitForShutdown func() + type NeutrinoClient struct + CS *actrino.ChainService + func NewNeutrinoClient(chainParams *chaincfg.Params, chainService *actrino.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) Notifications() <-chan interface{} + func (s *NeutrinoClient) NotifyBlocks() error + func (s *NeutrinoClient) NotifyReceived(addrs []acmutil.Address) error + func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []acmutil.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) Notifications() <-chan interface{} + func (c *RPCClient) POSTClient() (*rpcclient.Client, error) + func (c *RPCClient) Rescan(startHash *chainhash.Hash, addrs []acmutil.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
Go to main page