Versions in this module Expand all Collapse all v1 v1.9.25 Mar 25, 2021 v1.9.24 Mar 24, 2021 Changes in this version + const ConnectionRetryInterval + const DefaultMaxOrphanTxSize + const DefaultRequiredServices + const DefaultServices + const DefaultTargetOutbound + const GBTNonceRange + const GBTRegenerateSeconds + const JSONRPCSemverMajor + const JSONRPCSemverMinor + const JSONRPCSemverPatch + const JSONRPCSemverString + const MaxProtocolVersion + const RPCAuthTimeoutSeconds + const Uint256Size + const WebsocketSendBufferSize + var D logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var DefaultConnectTimeout = time.Second * 30 + var Dial = func(stateCfg *state.Config) func(addr net.Addr) (net.Conn, error) + var E logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var ErrClientQuit = errors.New("client quit") + var ErrRPCNoWallet = &btcjson.RPCError + var ErrRPCUnimplemented = &btcjson.RPCError + var ErrRescanReorg = btcjson.RPCError + var F logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var GBTCapabilities = []string + var GBTCoinbaseAux = &btcjson.GetBlockTemplateResultAux + var GBTMutableFields = []string + var GetworkDataLen = ... + var Hash1Len = ... + var HelpDescsEnUS = map[string]string + var I logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var Lookup = func(stateCfg *state.Config) func(host string) ([]net.IP, error) + var RPCAskWallet = map[string]CommandHandler + var RPCHandlers map[string]CommandHandler + var RPCHandlersBeforeInit = map[string]CommandHandler + var RPCLimited = map[string]CommandHandler + var RPCUnimplemented = map[string]struct + var ResultTypes = map[string][]interface + var T logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var TimeZeroVal = time.Time + var UserAgentName = "pod" + var UserAgentVersion = fmt.Sprintf("%d.%d.%d", version.AppMajor, version.AppMinor, version.AppPatch) + var W logg.LevelPrinter = logg.GetLogPrinterSet(subsystem) + var WSHandlers map[string]WSCommandHandler + var WSHandlersBeforeInit = map[string]WSCommandHandler + func AddLocalAddress(addrMgr *addrmgr.AddrManager, addr string, services wire.ServiceFlag) (e error) + func AddrStringToNetAddr(config *podcfg.Config, stateCfg *state.Config, addr string) (net.Addr, error) + func BigToLEUint256(n *big.Int) [Uint256Size]byte + func BlockDetails(block *block.Block, txIndex int) *btcjson.BlockDetails + func BuilderScript(builder *txscript.ScriptBuilder) []byte + func ChainErrToGBTErrString(e error) string + func CheckAddressValidity(addrs []string, params *chaincfg.Params) (e error) + func CreateMarshalledReply(id, result interface{}, replyErr error) ([]byte, error) + func CreateTxRawResult(chainParams *chaincfg.Params, mtx *wire.MsgTx, txHash string, ...) (*btcjson.TxRawResult, error) + func CreateVinList(mtx *wire.MsgTx) []btcjson.Vin + func CreateVinListPrevOut(s *Server, mtx *wire.MsgTx, chainParams *chaincfg.Params, vinExtra bool, ...) ([]btcjson.VinPrevOut, error) + func CreateVoutList(mtx *wire.MsgTx, chainParams *chaincfg.Params, ...) []btcjson.Vout + func DecodeHexError(gotHex string) *btcjson.RPCError + func DecodeTemplateID(templateID string) (*chainhash.Hash, int64, error) + func DescendantBlock(prevHash *chainhash.Hash, curBlock *block.Block) (e error) + func DeserializeOutpoints(serializedOuts []btcjson.OutPoint) ([]*wire.OutPoint, error) + func DisconnectPeer(peerList map[int32]*NodePeer, compareFunc func(*NodePeer) bool, ...) bool + func DynamicTickDuration(remaining time.Duration) time.Duration + func EncodeTemplateID(prevHash *chainhash.Hash, lastGenerated time.Time) string + func FetchInputTxos(s *Server, tx *wire.MsgTx) (map[wire.OutPoint]wire.TxOut, error) + func FetchMempoolTxnsForAddress(s *Server, addr btcaddr.Address, numToSkip, numRequested uint32) ([]*util.Tx, uint32) + func FileExists(name string) bool + func GenCertPair(certFile, keyFile string) (e error) + func GetBlkTemplateGenerator(node *Node, cfg *podcfg.Config, stateCfg *state.Config) *mining.BlkTmplGenerator + func GetDifficultyRatio(b uint32, params *chaincfg.Params, algo int32) float64 + func GetHasServices(advertised, desired wire.ServiceFlag) bool + func GetIsWhitelisted(statecfg *state.Config, addr net.Addr) bool + func HandleAddNode(s *Server, cmd interface{}, closeChan qu.C) (ifc interface{}, e error) + func HandleAskWallet(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleCreateRawTransaction(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleDecodeRawTransaction(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleDecodeScript(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleEstimateFee(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGenerate(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetAddedNodeInfo(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBestBlock(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBestBlockHash(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlock(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlockChainInfo(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlockCount(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlockHash(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlockHeader(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlockTemplate(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetBlockTemplateLongPoll(s *Server, longPollID string, useCoinbaseValue bool, closeChan qu.C) (interface{}, error) + func HandleGetBlockTemplateProposal(s *Server, request *btcjson.TemplateRequest) (interface{}, error) + func HandleGetBlockTemplateRequest(s *Server, request *btcjson.TemplateRequest, closeChan qu.C) (interface{}, error) + func HandleGetCFilter(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetCFilterHeader(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetConnectionCount(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetCurrentNet(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetDifficulty(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetGenerate(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetHashesPerSec(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetHeaders(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetInfo(s *Server, cmd interface{}, closeChan qu.C) (ret interface{}, e error) + func HandleGetMempoolInfo(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetMiningInfo(s *Server, cmd interface{}, closeChan qu.C) (ret interface{}, e error) + func HandleGetNetTotals(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetNetworkHashPS(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetPeerInfo(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetRawMempool(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetRawTransaction(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetTxOut(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetWork(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleGetWorkSubmission(s *Server, hexData string) (interface{}, error) + func HandleHelp(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleLoadTxFilter(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleNode(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleNotifyBlocks(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleNotifyNewTransactions(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleNotifyReceived(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleNotifySpent(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandlePing(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleRescan(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleRescanBlocks(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleResetChain(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleRestart(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleSearchRawTransactions(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleSendRawTransaction(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleSession(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleSetGenerate(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleStop(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleStopNotifyBlocks(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleStopNotifyNewTransactions(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleStopNotifyReceived(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleStopNotifySpent(wsc *WSClient, icmd interface{}) (interface{}, error) + func HandleSubmitBlock(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleUnimplemented(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleUptime(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleValidateAddress(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleVerifyChain(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleVerifyMessage(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleVersion(s *Server, cmd interface{}, closeChan qu.C) (interface{}, error) + func HandleWebsocketHelp(wsc *WSClient, icmd interface{}) (interface{}, error) + func InitListeners(config *podcfg.Config, activeNet *chaincfg.Params, aMgr *addrmgr.AddrManager, ...) ([]net.Listener, upnp.NAT, error) + func InternalRPCError(errStr, context string) *btcjson.RPCError + func JSONAuthFail(w http.ResponseWriter) + func MergeCheckpoints(defaultCheckpoints, additional []chaincfg.Checkpoint) []chaincfg.Checkpoint + func MessageToHex(msg wire.Message) (string, error) + func NewPeerConfig(sp *NodePeer) *peer.Config + func NewRedeemingTxNotification(txHex string, index int, block *block.Block) ([]byte, error) + func NoTxInfoError(txHash *chainhash.Hash) *btcjson.RPCError + func NormalizeAddress(addr, defaultPort string) string + func ParseListeners(addrs []string) ([]net.Addr, error) + func PeerExists(connMgr ServerConnManager, addr string, nodeID int32) bool + func QueueHandler(in <-chan interface{}, out chan<- interface{}, quit qu.C) + func RandomUint16Number(max uint16) uint16 + func RecoverFromReorg(chain *blockchain.BlockChain, minBlock, maxBlock int32, ...) ([]chainhash.Hash, error) + func RescanBlock(wsc *WSClient, lookups *RescanKeys, blk *block.Block) + func RescanBlockFilter(filter *WSClientFilter, block *block.Block, params *chaincfg.Params) []string + func ReverseUint32Array(b []byte) + func RunAPI(server *Server, quit qu.C) + func SetupRPCListeners(config *podcfg.Config, urls []string) ([]net.Listener, error) + func SoftForkStatus(state blockchain.ThresholdState) (string, error) + func TxHexString(tx *wire.MsgTx) string + func VerifyChain(s *Server, level, depth int32) (e error) + type API struct + Ch interface{} + Params interface{} + Result interface{} + func (a API) AddNode(cmd *btcjson.AddNodeCmd) (e error) + func (a API) AddNodeChk() (isNew bool) + func (a API) AddNodeGetRes() (out *None, e error) + func (a API) AddNodeWait(cmd *btcjson.AddNodeCmd) (out *None, e error) + func (a API) CreateRawTransaction(cmd *btcjson.CreateRawTransactionCmd) (e error) + func (a API) CreateRawTransactionChk() (isNew bool) + func (a API) CreateRawTransactionGetRes() (out *string, e error) + func (a API) CreateRawTransactionWait(cmd *btcjson.CreateRawTransactionCmd) (out *string, e error) + func (a API) DecodeRawTransaction(cmd *btcjson.DecodeRawTransactionCmd) (e error) + func (a API) DecodeRawTransactionChk() (isNew bool) + func (a API) DecodeRawTransactionGetRes() (out *btcjson.TxRawDecodeResult, e error) + func (a API) DecodeRawTransactionWait(cmd *btcjson.DecodeRawTransactionCmd) (out *btcjson.TxRawDecodeResult, e error) + func (a API) DecodeScript(cmd *btcjson.DecodeScriptCmd) (e error) + func (a API) DecodeScriptChk() (isNew bool) + func (a API) DecodeScriptGetRes() (out *btcjson.DecodeScriptResult, e error) + func (a API) DecodeScriptWait(cmd *btcjson.DecodeScriptCmd) (out *btcjson.DecodeScriptResult, e error) + func (a API) EstimateFee(cmd *btcjson.EstimateFeeCmd) (e error) + func (a API) EstimateFeeChk() (isNew bool) + func (a API) EstimateFeeGetRes() (out *float64, e error) + func (a API) EstimateFeeWait(cmd *btcjson.EstimateFeeCmd) (out *float64, e error) + func (a API) Generate(cmd *None) (e error) + func (a API) GenerateChk() (isNew bool) + func (a API) GenerateGetRes() (out *[]string, e error) + func (a API) GenerateWait(cmd *None) (out *[]string, e error) + func (a API) GetAddedNodeInfo(cmd *btcjson.GetAddedNodeInfoCmd) (e error) + func (a API) GetAddedNodeInfoChk() (isNew bool) + func (a API) GetAddedNodeInfoGetRes() (out *[]btcjson.GetAddedNodeInfoResultAddr, e error) + func (a API) GetAddedNodeInfoWait(cmd *btcjson.GetAddedNodeInfoCmd) (out *[]btcjson.GetAddedNodeInfoResultAddr, e error) + func (a API) GetBestBlock(cmd *None) (e error) + func (a API) GetBestBlockChk() (isNew bool) + func (a API) GetBestBlockGetRes() (out *btcjson.GetBestBlockResult, e error) + func (a API) GetBestBlockHash(cmd *None) (e error) + func (a API) GetBestBlockHashChk() (isNew bool) + func (a API) GetBestBlockHashGetRes() (out *string, e error) + func (a API) GetBestBlockHashWait(cmd *None) (out *string, e error) + func (a API) GetBestBlockWait(cmd *None) (out *btcjson.GetBestBlockResult, e error) + func (a API) GetBlock(cmd *btcjson.GetBlockCmd) (e error) + func (a API) GetBlockChainInfo(cmd *None) (e error) + func (a API) GetBlockChainInfoChk() (isNew bool) + func (a API) GetBlockChainInfoGetRes() (out *btcjson.GetBlockChainInfoResult, e error) + func (a API) GetBlockChainInfoWait(cmd *None) (out *btcjson.GetBlockChainInfoResult, e error) + func (a API) GetBlockChk() (isNew bool) + func (a API) GetBlockCount(cmd *None) (e error) + func (a API) GetBlockCountChk() (isNew bool) + func (a API) GetBlockCountGetRes() (out *int64, e error) + func (a API) GetBlockCountWait(cmd *None) (out *int64, e error) + func (a API) GetBlockGetRes() (out *btcjson.GetBlockVerboseResult, e error) + func (a API) GetBlockHash(cmd *btcjson.GetBlockHashCmd) (e error) + func (a API) GetBlockHashChk() (isNew bool) + func (a API) GetBlockHashGetRes() (out *string, e error) + func (a API) GetBlockHashWait(cmd *btcjson.GetBlockHashCmd) (out *string, e error) + func (a API) GetBlockHeader(cmd *btcjson.GetBlockHeaderCmd) (e error) + func (a API) GetBlockHeaderChk() (isNew bool) + func (a API) GetBlockHeaderGetRes() (out *btcjson.GetBlockHeaderVerboseResult, e error) + func (a API) GetBlockHeaderWait(cmd *btcjson.GetBlockHeaderCmd) (out *btcjson.GetBlockHeaderVerboseResult, e error) + func (a API) GetBlockTemplate(cmd *btcjson.GetBlockTemplateCmd) (e error) + func (a API) GetBlockTemplateChk() (isNew bool) + func (a API) GetBlockTemplateGetRes() (out *string, e error) + func (a API) GetBlockTemplateWait(cmd *btcjson.GetBlockTemplateCmd) (out *string, e error) + func (a API) GetBlockWait(cmd *btcjson.GetBlockCmd) (out *btcjson.GetBlockVerboseResult, e error) + func (a API) GetCFilter(cmd *btcjson.GetCFilterCmd) (e error) + func (a API) GetCFilterChk() (isNew bool) + func (a API) GetCFilterGetRes() (out *string, e error) + func (a API) GetCFilterHeader(cmd *btcjson.GetCFilterHeaderCmd) (e error) + func (a API) GetCFilterHeaderChk() (isNew bool) + func (a API) GetCFilterHeaderGetRes() (out *string, e error) + func (a API) GetCFilterHeaderWait(cmd *btcjson.GetCFilterHeaderCmd) (out *string, e error) + func (a API) GetCFilterWait(cmd *btcjson.GetCFilterCmd) (out *string, e error) + func (a API) GetConnectionCount(cmd *None) (e error) + func (a API) GetConnectionCountChk() (isNew bool) + func (a API) GetConnectionCountGetRes() (out *int32, e error) + func (a API) GetConnectionCountWait(cmd *None) (out *int32, e error) + func (a API) GetCurrentNet(cmd *None) (e error) + func (a API) GetCurrentNetChk() (isNew bool) + func (a API) GetCurrentNetGetRes() (out *string, e error) + func (a API) GetCurrentNetWait(cmd *None) (out *string, e error) + func (a API) GetDifficulty(cmd *btcjson.GetDifficultyCmd) (e error) + func (a API) GetDifficultyChk() (isNew bool) + func (a API) GetDifficultyGetRes() (out *float64, e error) + func (a API) GetDifficultyWait(cmd *btcjson.GetDifficultyCmd) (out *float64, e error) + func (a API) GetGenerate(cmd *btcjson.GetHeadersCmd) (e error) + func (a API) GetGenerateChk() (isNew bool) + func (a API) GetGenerateGetRes() (out *bool, e error) + func (a API) GetGenerateWait(cmd *btcjson.GetHeadersCmd) (out *bool, e error) + func (a API) GetHashesPerSec(cmd *None) (e error) + func (a API) GetHashesPerSecChk() (isNew bool) + func (a API) GetHashesPerSecGetRes() (out *float64, e error) + func (a API) GetHashesPerSecWait(cmd *None) (out *float64, e error) + func (a API) GetHeaders(cmd *btcjson.GetHeadersCmd) (e error) + func (a API) GetHeadersChk() (isNew bool) + func (a API) GetHeadersGetRes() (out *[]string, e error) + func (a API) GetHeadersWait(cmd *btcjson.GetHeadersCmd) (out *[]string, e error) + func (a API) GetInfo(cmd *None) (e error) + func (a API) GetInfoChk() (isNew bool) + func (a API) GetInfoGetRes() (out *btcjson.InfoChainResult0, e error) + func (a API) GetInfoWait(cmd *None) (out *btcjson.InfoChainResult0, e error) + func (a API) GetMempoolInfo(cmd *None) (e error) + func (a API) GetMempoolInfoChk() (isNew bool) + func (a API) GetMempoolInfoGetRes() (out *btcjson.GetMempoolInfoResult, e error) + func (a API) GetMempoolInfoWait(cmd *None) (out *btcjson.GetMempoolInfoResult, e error) + func (a API) GetMiningInfo(cmd *None) (e error) + func (a API) GetMiningInfoChk() (isNew bool) + func (a API) GetMiningInfoGetRes() (out *btcjson.GetMiningInfoResult, e error) + func (a API) GetMiningInfoWait(cmd *None) (out *btcjson.GetMiningInfoResult, e error) + func (a API) GetNetTotals(cmd *None) (e error) + func (a API) GetNetTotalsChk() (isNew bool) + func (a API) GetNetTotalsGetRes() (out *btcjson.GetNetTotalsResult, e error) + func (a API) GetNetTotalsWait(cmd *None) (out *btcjson.GetNetTotalsResult, e error) + func (a API) GetNetworkHashPS(cmd *btcjson.GetNetworkHashPSCmd) (e error) + func (a API) GetNetworkHashPSChk() (isNew bool) + func (a API) GetNetworkHashPSGetRes() (out *[]btcjson.GetPeerInfoResult, e error) + func (a API) GetNetworkHashPSWait(cmd *btcjson.GetNetworkHashPSCmd) (out *[]btcjson.GetPeerInfoResult, e error) + func (a API) GetPeerInfo(cmd *None) (e error) + func (a API) GetPeerInfoChk() (isNew bool) + func (a API) GetPeerInfoGetRes() (out *[]btcjson.GetPeerInfoResult, e error) + func (a API) GetPeerInfoWait(cmd *None) (out *[]btcjson.GetPeerInfoResult, e error) + func (a API) GetRawMempool(cmd *btcjson.GetRawMempoolCmd) (e error) + func (a API) GetRawMempoolChk() (isNew bool) + func (a API) GetRawMempoolGetRes() (out *[]string, e error) + func (a API) GetRawMempoolWait(cmd *btcjson.GetRawMempoolCmd) (out *[]string, e error) + func (a API) GetRawTransaction(cmd *btcjson.GetRawTransactionCmd) (e error) + func (a API) GetRawTransactionChk() (isNew bool) + func (a API) GetRawTransactionGetRes() (out *string, e error) + func (a API) GetRawTransactionWait(cmd *btcjson.GetRawTransactionCmd) (out *string, e error) + func (a API) GetTxOut(cmd *btcjson.GetTxOutCmd) (e error) + func (a API) GetTxOutChk() (isNew bool) + func (a API) GetTxOutGetRes() (out *string, e error) + func (a API) GetTxOutWait(cmd *btcjson.GetTxOutCmd) (out *string, e error) + func (a API) Help(cmd *btcjson.HelpCmd) (e error) + func (a API) HelpChk() (isNew bool) + func (a API) HelpGetRes() (out *string, e error) + func (a API) HelpWait(cmd *btcjson.HelpCmd) (out *string, e error) + func (a API) Node(cmd *btcjson.NodeCmd) (e error) + func (a API) NodeChk() (isNew bool) + func (a API) NodeGetRes() (out *None, e error) + func (a API) NodeWait(cmd *btcjson.NodeCmd) (out *None, e error) + func (a API) Ping(cmd *None) (e error) + func (a API) PingChk() (isNew bool) + func (a API) PingGetRes() (out *None, e error) + func (a API) PingWait(cmd *None) (out *None, e error) + func (a API) ResetChain(cmd *None) (e error) + func (a API) ResetChainChk() (isNew bool) + func (a API) ResetChainGetRes() (out *None, e error) + func (a API) ResetChainWait(cmd *None) (out *None, e error) + func (a API) Restart(cmd *None) (e error) + func (a API) RestartChk() (isNew bool) + func (a API) RestartGetRes() (out *None, e error) + func (a API) RestartWait(cmd *None) (out *None, e error) + func (a API) SearchRawTransactions(cmd *btcjson.SearchRawTransactionsCmd) (e error) + func (a API) SearchRawTransactionsChk() (isNew bool) + func (a API) SearchRawTransactionsGetRes() (out *[]btcjson.SearchRawTransactionsResult, e error) + func (a API) SearchRawTransactionsWait(cmd *btcjson.SearchRawTransactionsCmd) (out *[]btcjson.SearchRawTransactionsResult, e error) + func (a API) SendRawTransaction(cmd *btcjson.SendRawTransactionCmd) (e error) + func (a API) SendRawTransactionChk() (isNew bool) + func (a API) SendRawTransactionGetRes() (out *None, e error) + func (a API) SendRawTransactionWait(cmd *btcjson.SendRawTransactionCmd) (out *None, e error) + func (a API) SetGenerate(cmd *btcjson.SetGenerateCmd) (e error) + func (a API) SetGenerateChk() (isNew bool) + func (a API) SetGenerateGetRes() (out *None, e error) + func (a API) SetGenerateWait(cmd *btcjson.SetGenerateCmd) (out *None, e error) + func (a API) Stop(cmd *None) (e error) + func (a API) StopChk() (isNew bool) + func (a API) StopGetRes() (out *None, e error) + func (a API) StopWait(cmd *None) (out *None, e error) + func (a API) SubmitBlock(cmd *btcjson.SubmitBlockCmd) (e error) + func (a API) SubmitBlockChk() (isNew bool) + func (a API) SubmitBlockGetRes() (out *string, e error) + func (a API) SubmitBlockWait(cmd *btcjson.SubmitBlockCmd) (out *string, e error) + func (a API) Uptime(cmd *None) (e error) + func (a API) UptimeChk() (isNew bool) + func (a API) UptimeGetRes() (out *btcjson.GetMempoolInfoResult, e error) + func (a API) UptimeWait(cmd *None) (out *btcjson.GetMempoolInfoResult, e error) + func (a API) ValidateAddress(cmd *btcjson.ValidateAddressCmd) (e error) + func (a API) ValidateAddressChk() (isNew bool) + func (a API) ValidateAddressGetRes() (out *btcjson.ValidateAddressChainResult, e error) + func (a API) ValidateAddressWait(cmd *btcjson.ValidateAddressCmd) (out *btcjson.ValidateAddressChainResult, e error) + func (a API) VerifyChain(cmd *btcjson.VerifyChainCmd) (e error) + func (a API) VerifyChainChk() (isNew bool) + func (a API) VerifyChainGetRes() (out *bool, e error) + func (a API) VerifyChainWait(cmd *btcjson.VerifyChainCmd) (out *bool, e error) + func (a API) VerifyMessage(cmd *btcjson.VerifyMessageCmd) (e error) + func (a API) VerifyMessageChk() (isNew bool) + func (a API) VerifyMessageGetRes() (out *bool, e error) + func (a API) VerifyMessageWait(cmd *btcjson.VerifyMessageCmd) (out *bool, e error) + func (a API) Version(cmd *btcjson.VersionCmd) (e error) + func (a API) VersionChk() (isNew bool) + func (a API) VersionGetRes() (out *map[string]btcjson.VersionResult, e error) + func (a API) VersionWait(cmd *btcjson.VersionCmd) (out *map[string]btcjson.VersionResult, e error) + type AddNodeRes struct + Err error + Res *None + type BroadcastInventoryAdd RelayMsg + type BroadcastInventoryDel *wire.InvVect + type BroadcastMsg struct + ExcludePeers []*NodePeer + Message wire.Message + type CAPI struct + Timeout time.Duration + func NewCAPI(quit qu.C, timeout ...time.Duration) (c *CAPI) + func (c *CAPI) AddNode(req *btcjson.AddNodeCmd, resp None) (e error) + func (c *CAPI) CreateRawTransaction(req *btcjson.CreateRawTransactionCmd, resp string) (e error) + func (c *CAPI) DecodeRawTransaction(req *btcjson.DecodeRawTransactionCmd, resp btcjson.TxRawDecodeResult) (e error) + func (c *CAPI) DecodeScript(req *btcjson.DecodeScriptCmd, resp btcjson.DecodeScriptResult) (e error) + func (c *CAPI) EstimateFee(req *btcjson.EstimateFeeCmd, resp float64) (e error) + func (c *CAPI) Generate(req *None, resp []string) (e error) + func (c *CAPI) GetAddedNodeInfo(req *btcjson.GetAddedNodeInfoCmd, resp []btcjson.GetAddedNodeInfoResultAddr) (e error) + func (c *CAPI) GetBestBlock(req *None, resp btcjson.GetBestBlockResult) (e error) + func (c *CAPI) GetBestBlockHash(req *None, resp string) (e error) + func (c *CAPI) GetBlock(req *btcjson.GetBlockCmd, resp btcjson.GetBlockVerboseResult) (e error) + func (c *CAPI) GetBlockChainInfo(req *None, resp btcjson.GetBlockChainInfoResult) (e error) + func (c *CAPI) GetBlockCount(req *None, resp int64) (e error) + func (c *CAPI) GetBlockHash(req *btcjson.GetBlockHashCmd, resp string) (e error) + func (c *CAPI) GetBlockHeader(req *btcjson.GetBlockHeaderCmd, resp btcjson.GetBlockHeaderVerboseResult) (e error) + func (c *CAPI) GetBlockTemplate(req *btcjson.GetBlockTemplateCmd, resp string) (e error) + func (c *CAPI) GetCFilter(req *btcjson.GetCFilterCmd, resp string) (e error) + func (c *CAPI) GetCFilterHeader(req *btcjson.GetCFilterHeaderCmd, resp string) (e error) + func (c *CAPI) GetConnectionCount(req *None, resp int32) (e error) + func (c *CAPI) GetCurrentNet(req *None, resp string) (e error) + func (c *CAPI) GetDifficulty(req *btcjson.GetDifficultyCmd, resp float64) (e error) + func (c *CAPI) GetGenerate(req *btcjson.GetHeadersCmd, resp bool) (e error) + func (c *CAPI) GetHashesPerSec(req *None, resp float64) (e error) + func (c *CAPI) GetHeaders(req *btcjson.GetHeadersCmd, resp []string) (e error) + func (c *CAPI) GetInfo(req *None, resp btcjson.InfoChainResult0) (e error) + func (c *CAPI) GetMempoolInfo(req *None, resp btcjson.GetMempoolInfoResult) (e error) + func (c *CAPI) GetMiningInfo(req *None, resp btcjson.GetMiningInfoResult) (e error) + func (c *CAPI) GetNetTotals(req *None, resp btcjson.GetNetTotalsResult) (e error) + func (c *CAPI) GetNetworkHashPS(req *btcjson.GetNetworkHashPSCmd, resp []btcjson.GetPeerInfoResult) (e error) + func (c *CAPI) GetPeerInfo(req *None, resp []btcjson.GetPeerInfoResult) (e error) + func (c *CAPI) GetRawMempool(req *btcjson.GetRawMempoolCmd, resp []string) (e error) + func (c *CAPI) GetRawTransaction(req *btcjson.GetRawTransactionCmd, resp string) (e error) + func (c *CAPI) GetTxOut(req *btcjson.GetTxOutCmd, resp string) (e error) + func (c *CAPI) Help(req *btcjson.HelpCmd, resp string) (e error) + func (c *CAPI) Node(req *btcjson.NodeCmd, resp None) (e error) + func (c *CAPI) Ping(req *None, resp None) (e error) + func (c *CAPI) ResetChain(req *None, resp None) (e error) + func (c *CAPI) Restart(req *None, resp None) (e error) + func (c *CAPI) SearchRawTransactions(req *btcjson.SearchRawTransactionsCmd, ...) (e error) + func (c *CAPI) SendRawTransaction(req *btcjson.SendRawTransactionCmd, resp None) (e error) + func (c *CAPI) SetGenerate(req *btcjson.SetGenerateCmd, resp None) (e error) + func (c *CAPI) Stop(req *None, resp None) (e error) + func (c *CAPI) SubmitBlock(req *btcjson.SubmitBlockCmd, resp string) (e error) + func (c *CAPI) Uptime(req *None, resp btcjson.GetMempoolInfoResult) (e error) + func (c *CAPI) ValidateAddress(req *btcjson.ValidateAddressCmd, resp btcjson.ValidateAddressChainResult) (e error) + func (c *CAPI) VerifyChain(req *btcjson.VerifyChainCmd, resp bool) (e error) + func (c *CAPI) VerifyMessage(req *btcjson.VerifyMessageCmd, resp bool) (e error) + func (c *CAPI) Version(req *btcjson.VersionCmd, resp map[string]btcjson.VersionResult) (e error) + type CAPIClient struct + func NewCAPIClient(conn io.ReadWriteCloser) *CAPIClient + func (r *CAPIClient) AddNode(cmd ...*btcjson.AddNodeCmd) (res None, e error) + func (r *CAPIClient) CreateRawTransaction(cmd ...*btcjson.CreateRawTransactionCmd) (res string, e error) + func (r *CAPIClient) DecodeRawTransaction(cmd ...*btcjson.DecodeRawTransactionCmd) (res btcjson.TxRawDecodeResult, e error) + func (r *CAPIClient) DecodeScript(cmd ...*btcjson.DecodeScriptCmd) (res btcjson.DecodeScriptResult, e error) + func (r *CAPIClient) EstimateFee(cmd ...*btcjson.EstimateFeeCmd) (res float64, e error) + func (r *CAPIClient) Generate(cmd ...*None) (res []string, e error) + func (r *CAPIClient) GetAddedNodeInfo(cmd ...*btcjson.GetAddedNodeInfoCmd) (res []btcjson.GetAddedNodeInfoResultAddr, e error) + func (r *CAPIClient) GetBestBlock(cmd ...*None) (res btcjson.GetBestBlockResult, e error) + func (r *CAPIClient) GetBestBlockHash(cmd ...*None) (res string, e error) + func (r *CAPIClient) GetBlock(cmd ...*btcjson.GetBlockCmd) (res btcjson.GetBlockVerboseResult, e error) + func (r *CAPIClient) GetBlockChainInfo(cmd ...*None) (res btcjson.GetBlockChainInfoResult, e error) + func (r *CAPIClient) GetBlockCount(cmd ...*None) (res int64, e error) + func (r *CAPIClient) GetBlockHash(cmd ...*btcjson.GetBlockHashCmd) (res string, e error) + func (r *CAPIClient) GetBlockHeader(cmd ...*btcjson.GetBlockHeaderCmd) (res btcjson.GetBlockHeaderVerboseResult, e error) + func (r *CAPIClient) GetBlockTemplate(cmd ...*btcjson.GetBlockTemplateCmd) (res string, e error) + func (r *CAPIClient) GetCFilter(cmd ...*btcjson.GetCFilterCmd) (res string, e error) + func (r *CAPIClient) GetCFilterHeader(cmd ...*btcjson.GetCFilterHeaderCmd) (res string, e error) + func (r *CAPIClient) GetConnectionCount(cmd ...*None) (res int32, e error) + func (r *CAPIClient) GetCurrentNet(cmd ...*None) (res string, e error) + func (r *CAPIClient) GetDifficulty(cmd ...*btcjson.GetDifficultyCmd) (res float64, e error) + func (r *CAPIClient) GetGenerate(cmd ...*btcjson.GetHeadersCmd) (res bool, e error) + func (r *CAPIClient) GetHashesPerSec(cmd ...*None) (res float64, e error) + func (r *CAPIClient) GetHeaders(cmd ...*btcjson.GetHeadersCmd) (res []string, e error) + func (r *CAPIClient) GetInfo(cmd ...*None) (res btcjson.InfoChainResult0, e error) + func (r *CAPIClient) GetMempoolInfo(cmd ...*None) (res btcjson.GetMempoolInfoResult, e error) + func (r *CAPIClient) GetMiningInfo(cmd ...*None) (res btcjson.GetMiningInfoResult, e error) + func (r *CAPIClient) GetNetTotals(cmd ...*None) (res btcjson.GetNetTotalsResult, e error) + func (r *CAPIClient) GetNetworkHashPS(cmd ...*btcjson.GetNetworkHashPSCmd) (res []btcjson.GetPeerInfoResult, e error) + func (r *CAPIClient) GetPeerInfo(cmd ...*None) (res []btcjson.GetPeerInfoResult, e error) + func (r *CAPIClient) GetRawMempool(cmd ...*btcjson.GetRawMempoolCmd) (res []string, e error) + func (r *CAPIClient) GetRawTransaction(cmd ...*btcjson.GetRawTransactionCmd) (res string, e error) + func (r *CAPIClient) GetTxOut(cmd ...*btcjson.GetTxOutCmd) (res string, e error) + func (r *CAPIClient) Help(cmd ...*btcjson.HelpCmd) (res string, e error) + func (r *CAPIClient) Node(cmd ...*btcjson.NodeCmd) (res None, e error) + func (r *CAPIClient) Ping(cmd ...*None) (res None, e error) + func (r *CAPIClient) ResetChain(cmd ...*None) (res None, e error) + func (r *CAPIClient) Restart(cmd ...*None) (res None, e error) + func (r *CAPIClient) SearchRawTransactions(cmd ...*btcjson.SearchRawTransactionsCmd) (res []btcjson.SearchRawTransactionsResult, e error) + func (r *CAPIClient) SendRawTransaction(cmd ...*btcjson.SendRawTransactionCmd) (res None, e error) + func (r *CAPIClient) SetGenerate(cmd ...*btcjson.SetGenerateCmd) (res None, e error) + func (r *CAPIClient) Stop(cmd ...*None) (res None, e error) + func (r *CAPIClient) SubmitBlock(cmd ...*btcjson.SubmitBlockCmd) (res string, e error) + func (r *CAPIClient) Uptime(cmd ...*None) (res btcjson.GetMempoolInfoResult, e error) + func (r *CAPIClient) ValidateAddress(cmd ...*btcjson.ValidateAddressCmd) (res btcjson.ValidateAddressChainResult, e error) + func (r *CAPIClient) VerifyChain(cmd ...*btcjson.VerifyChainCmd) (res bool, e error) + func (r *CAPIClient) VerifyMessage(cmd ...*btcjson.VerifyMessageCmd) (res bool, e error) + func (r *CAPIClient) Version(cmd ...*btcjson.VersionCmd) (res map[string]btcjson.VersionResult, e error) + type CFHeaderKV struct + BlockHash chainhash.Hash + FilterHeader chainhash.Hash + type CheckpointSorter []chaincfg.Checkpoint + func (s CheckpointSorter) Len() int + func (s CheckpointSorter) Less(i, j int) bool + func (s CheckpointSorter) Swap(i, j int) + type CommandHandler struct + Call chan API + Fn func(*Server, interface{}, qu.C) (interface{}, error) + Result func() API + type ConnManager struct + func (cm *ConnManager) AddRebroadcastInventory(iv *wire.InvVect, data interface{}) + func (cm *ConnManager) BroadcastMessage(msg wire.Message) + func (cm *ConnManager) Connect(addr string, permanent bool) (e error) + func (cm *ConnManager) ConnectedCount() int32 + func (cm *ConnManager) ConnectedPeers() []ServerPeer + func (cm *ConnManager) DisconnectByAddr(addr string) (e error) + func (cm *ConnManager) DisconnectByID(id int32) (e error) + func (cm *ConnManager) NetTotals() (uint64, uint64) + func (cm *ConnManager) PersistentPeers() []ServerPeer + func (cm *ConnManager) RelayTransactions(txns []*mempool.TxDesc) + func (cm *ConnManager) RemoveByAddr(addr string) (e error) + func (cm *ConnManager) RemoveByID(id int32) (e error) + type ConnectNodeMsg struct + Addr string + Permanent bool + Reply chan error + type Context struct + ActiveNet *chaincfg.Params + Config *podcfg.Config + Hashrate uberatomic.Uint64 + StateCfg *state.Config + type CreateRawTransactionRes struct + Err error + Res *string + type DecodeRawTransactionRes struct + Err error + Res *btcjson.TxRawDecodeResult + type DecodeScriptRes struct + Err error + Res *btcjson.DecodeScriptResult + type DisconnectNodeMsg struct + Cmp func(*NodePeer) bool + Reply chan error + type EstimateFeeRes struct + Err error + Res *float64 + type GBTWorkState struct + Algo string + Config *podcfg.Config + LastGenerated time.Time + LastTxUpdate time.Time + MinTimestamp time.Time + NotifyMap map[chainhash.Hash]map[int64]qu.C + StateCfg *state.Config + Template *mining.BlockTemplate + TimeSource blockchain.MedianTimeSource + func NewGbtWorkState(timeSource blockchain.MedianTimeSource, algoName string) *GBTWorkState + func (state *GBTWorkState) BlockTemplateResult(useCoinbaseValue bool, submitOld *bool) (*btcjson.GetBlockTemplateResult, error) + func (state *GBTWorkState) NotifyBlockConnected(blockHash *chainhash.Hash) + func (state *GBTWorkState) NotifyLongPollers(latestHash *chainhash.Hash, lastGenerated time.Time) + func (state *GBTWorkState) NotifyMempoolTx(lastUpdated time.Time) + func (state *GBTWorkState) TemplateUpdateChan(prevHash *chainhash.Hash, lastGenerated int64) qu.C + func (state *GBTWorkState) UpdateBlockTemplate(s *Server, useCoinbaseValue bool) (e error) + type GenerateRes struct + Err error + Res *[]string + type GetAddedNodeInfoRes struct + Err error + Res *[]btcjson.GetAddedNodeInfoResultAddr + type GetAddedNodesMsg struct + Reply chan []*NodePeer + type GetBestBlockHashRes struct + Err error + Res *string + type GetBestBlockRes struct + Err error + Res *btcjson.GetBestBlockResult + type GetBlockChainInfoRes struct + Err error + Res *btcjson.GetBlockChainInfoResult + type GetBlockCountRes struct + Err error + Res *int64 + type GetBlockHashRes struct + Err error + Res *string + type GetBlockHeaderRes struct + Err error + Res *btcjson.GetBlockHeaderVerboseResult + type GetBlockRes struct + Err error + Res *btcjson.GetBlockVerboseResult + type GetBlockTemplateRes struct + Err error + Res *string + type GetCFilterHeaderRes struct + Err error + Res *string + type GetCFilterRes struct + Err error + Res *string + type GetConnCountMsg struct + Reply chan int32 + type GetConnectionCountRes struct + Err error + Res *int32 + type GetCurrentNetRes struct + Err error + Res *string + type GetDifficultyRes struct + Err error + Res *float64 + type GetGenerateRes struct + Err error + Res *bool + type GetHashesPerSecRes struct + Err error + Res *float64 + type GetHeadersRes struct + Err error + Res *[]string + type GetInfoRes struct + Err error + Res *btcjson.InfoChainResult0 + type GetMempoolInfoRes struct + Err error + Res *btcjson.GetMempoolInfoResult + type GetMiningInfoRes struct + Err error + Res *btcjson.GetMiningInfoResult + type GetNetTotalsRes struct + Err error + Res *btcjson.GetNetTotalsResult + type GetNetworkHashPSRes struct + Err error + Res *[]btcjson.GetPeerInfoResult + type GetOutboundGroup struct + Key string + Reply chan int + type GetPeerInfoRes struct + Err error + Res *[]btcjson.GetPeerInfoResult + type GetPeersMsg struct + Reply chan []*NodePeer + type GetRawMempoolRes struct + Err error + Res *[]string + type GetRawTransactionRes struct + Err error + Res *string + type GetTxOutRes struct + Err error + Res *string + type HelpCacher struct + func NewHelpCacher() *HelpCacher + func (c *HelpCacher) RPCMethodHelp(method string) (string, error) + func (c *HelpCacher) RPCUsage(includeWebsockets bool) (string, error) + type HelpRes struct + Err error + Res *string + type Node struct + ActiveNet *chaincfg.Params + AddrIndex *indexers.AddrIndex + AddrManager *addrmgr.AddrManager + BanPeers chan *NodePeer + Broadcast chan BroadcastMsg + BytesReceived uint64 + BytesSent uint64 + CFCheckptCaches map[wire.FilterType][]CFHeaderKV + CFCheckptCachesMtx sync.RWMutex + CFIndex *indexers.CFIndex + CPUMiner *exec.Cmd + Chain *blockchain.BlockChain + ChainParams *chaincfg.Params + Config *podcfg.Config + ConnManager *connmgr.ConnManager + DB database.DB + DonePeers chan *NodePeer + FeeEstimator *mempool.FeeEstimator + GenThreads uint32 + HashCache *txscript.HashCache + HighestKnown uberatomic.Int32 + ModifyRebroadcastInv chan interface{} + NAT upnp.NAT + NewPeers chan *NodePeer + PeerHeightsUpdate chan UpdatePeerHeightsMsg + PeerState chan chan peersummary.PeerSummaries + Query chan interface{} + Quit qu.C + RPCServers []*Server + RelayInv chan RelayMsg + Services wire.ServiceFlag + Shutdown int32 + ShutdownSched int32 + SigCache *txscript.SigCache + StartController qu.C + Started int32 + StartupTime int64 + StateCfg *state.Config + StopController qu.C + SyncManager *netsync.SyncManager + TimeSource blockchain.MedianTimeSource + TxIndex *indexers.TxIndex + TxMemPool *mempool.TxPool + WG sync.WaitGroup + func NewNode(listenAddrs []string, db database.DB, interruptChan qu.C, cx *Context, ...) (*Node, error) + func (n *Node) AddBytesReceived(bytesReceived uint64) + func (n *Node) AddBytesSent(bytesSent uint64) + func (n *Node) AddPeer(sp *NodePeer) + func (n *Node) AddRebroadcastInventory(iv *wire.InvVect, data interface{}) + func (n *Node) AnnounceNewTransactions(txns []*mempool.TxDesc) + func (n *Node) BanPeer(sp *NodePeer) + func (n *Node) BroadcastMessage(msg wire.Message, exclPeers ...*NodePeer) + func (n *Node) ConnectedCount() int32 + func (n *Node) HandleAddPeerMsg(state *PeerState, sp *NodePeer) bool + func (n *Node) HandleBanPeerMsg(state *PeerState, sp *NodePeer) + func (n *Node) HandleBroadcastMsg(state *PeerState, bmsg *BroadcastMsg) + func (n *Node) HandleDonePeerMsg(state *PeerState, sp *NodePeer) + func (n *Node) HandleQuery(state *PeerState, querymsg interface{}) + func (n *Node) HandleRelayInvMsg(state *PeerState, msg RelayMsg) + func (n *Node) HandleUpdatePeerHeights(state *PeerState, umsg UpdatePeerHeightsMsg) + func (n *Node) InboundPeerConnected(conn net.Conn) + func (n *Node) NetTotals() (uint64, uint64) + func (n *Node) OutboundGroupCount(key string) int + func (n *Node) OutboundPeerConnected(c *connmgr.ConnReq, conn net.Conn) + func (n *Node) PeerDoneHandler(sp *NodePeer) + func (n *Node) PeerHandler() + func (n *Node) PushBlockMsg(sp *NodePeer, hash *chainhash.Hash, doneChan chan<- struct{}, waitChan qu.C, ...) (e error) + func (n *Node) PushMerkleBlockMsg(sp *NodePeer, hash *chainhash.Hash, doneChan chan<- struct{}, waitChan qu.C, ...) (e error) + func (n *Node) PushTxMsg(sp *NodePeer, hash *chainhash.Hash, doneChan chan<- struct{}, waitChan qu.C, ...) (e error) + func (n *Node) RebroadcastHandler() + func (n *Node) RelayInventory(invVect *wire.InvVect, data interface{}) + func (n *Node) RelayTransactions(txns []*mempool.TxDesc) + func (n *Node) RemoveRebroadcastInventory(iv *wire.InvVect) + func (n *Node) ScheduleShutdown(duration time.Duration) + func (n *Node) Start() + func (n *Node) Stop() (e error) + func (n *Node) TransactionConfirmed(tx *util.Tx) + func (n *Node) UPNPUpdateThread() + func (n *Node) UpdatePeerHeights(latestBlkHash *chainhash.Hash, latestHeight int32, updateSource *peer.Peer) + func (n *Node) WaitForShutdown() + type NodePeer struct + BanScore connmgr.DynamicBanScore + BlockProcessed qu.C + ConnReq *connmgr.ConnReq + ContinueHash *chainhash.Hash + DisableRelayTx bool + FeeFilter int64 + Filter *bloom.Filter + IP net.IP + IsWhitelisted bool + KnownAddresses map[string]struct{} + Persistent bool + Port uint16 + Quit qu.C + RelayMtx sync.Mutex + SentAddrs bool + Server *Node + TxProcessed qu.C + func NewServerPeer(s *Node, localIP net.IP, isPersistent bool) *NodePeer + func (np *NodePeer) AddBanScore(persistent, transient uint32, reason string) bool + func (np *NodePeer) AddKnownAddresses(addresses []*wire.NetAddress) + func (np *NodePeer) EnforceNodeBloomFlag(cmd string) bool + func (np *NodePeer) GetNewestBlock() (*chainhash.Hash, int32, error) + func (np *NodePeer) IsAddressKnown(na *wire.NetAddress) bool + func (np *NodePeer) IsRelayTxDisabled() bool + func (np *NodePeer) OnAddr(_ *peer.Peer, msg *wire.MsgAddr) + func (np *NodePeer) OnBlock(_ *peer.Peer, msg *wire.Block, buf []byte) + func (np *NodePeer) OnFeeFilter(_ *peer.Peer, msg *wire.MsgFeeFilter) + func (np *NodePeer) OnFilterAdd(_ *peer.Peer, msg *wire.MsgFilterAdd) + func (np *NodePeer) OnFilterClear(_ *peer.Peer, msg *wire.MsgFilterClear) + func (np *NodePeer) OnFilterLoad(_ *peer.Peer, msg *wire.MsgFilterLoad) + func (np *NodePeer) OnGetAddr(_ *peer.Peer, msg *wire.MsgGetAddr) + func (np *NodePeer) OnGetBlocks(_ *peer.Peer, msg *wire.MsgGetBlocks) + func (np *NodePeer) OnGetCFCheckpt(_ *peer.Peer, msg *wire.MsgGetCFCheckpt) + func (np *NodePeer) OnGetCFHeaders(_ *peer.Peer, msg *wire.MsgGetCFHeaders) + func (np *NodePeer) OnGetCFilters(_ *peer.Peer, msg *wire.MsgGetCFilters) + func (np *NodePeer) OnGetData(_ *peer.Peer, msg *wire.MsgGetData) + func (np *NodePeer) OnGetHeaders(_ *peer.Peer, msg *wire.MsgGetHeaders) + func (np *NodePeer) OnHeaders(_ *peer.Peer, msg *wire.MsgHeaders) + func (np *NodePeer) OnInv(_ *peer.Peer, msg *wire.MsgInv) + func (np *NodePeer) OnMemPool(_ *peer.Peer, msg *wire.MsgMemPool) + func (np *NodePeer) OnRead(_ *peer.Peer, bytesRead int, msg wire.Message, e error) + func (np *NodePeer) OnTx(_ *peer.Peer, msg *wire.MsgTx) + func (np *NodePeer) OnVersion(_ *peer.Peer, msg *wire.MsgVersion) *wire.MsgReject + func (np *NodePeer) OnWrite(_ *peer.Peer, bytesWritten int, msg wire.Message, e error) + func (np *NodePeer) PreparePushAddrMsg(addresses []*wire.NetAddress) + func (np *NodePeer) SetDisableRelayTx(disable bool) + type NodeRes struct + Err error + Res *None + type None struct + type NotificationBlockConnected block.Block + type NotificationBlockDisconnected block.Block + type NotificationRegisterAddr struct + Addrs []string + WSC *WSClient + type NotificationRegisterBlocks WSClient + type NotificationRegisterClient WSClient + type NotificationRegisterNewMempoolTxs WSClient + type NotificationRegisterSpent struct + OPs []*wire.OutPoint + WSC *WSClient + type NotificationTxAcceptedByMempool struct + IsNew bool + Tx *util.Tx + type NotificationUnregisterAddr struct + Addr string + WSC *WSClient + type NotificationUnregisterBlocks WSClient + type NotificationUnregisterClient WSClient + type NotificationUnregisterNewMempoolTxs WSClient + type NotificationUnregisterSpent struct + OP *wire.OutPoint + WSC *WSClient + type OnionAddr struct + Addr string + func (oa *OnionAddr) Network() string + func (oa *OnionAddr) String() string + type ParsedRPCCmd struct + Cmd interface{} + Err *btcjson.RPCError + ID interface{} + Method string + func ParseCmd(request *btcjson.Request) *ParsedRPCCmd + type Peer NodePeer + func (p *Peer) GetBanScore() uint32 + func (p *Peer) GetFeeFilter() int64 + func (p *Peer) IsTxRelayDisabled() bool + func (p *Peer) ToPeer() *peer.Peer + type PeerState struct + Banned map[string]time.Time + InboundPeers map[int32]*NodePeer + OutboundGroups map[string]int + OutboundPeers map[int32]*NodePeer + PersistentPeers map[int32]*NodePeer + func (ps *PeerState) Count() int + func (ps *PeerState) ForAllOutboundPeers(closure func(sp *NodePeer)) + func (ps *PeerState) ForAllPeers(closure func(sp *NodePeer)) + type PingRes struct + Err error + Res *None + type RelayMsg struct + Data interface{} + InvVect *wire.InvVect + type RemoveNodeMsg struct + Cmp func(*NodePeer) bool + Reply chan error + type RescanKeys struct + CompressedPubKeys map[[33]byte]struct{} + Fallbacks map[string]struct{} + PubKeyHashes map[[ripemd160.Size]byte]struct{} + ScriptHashes map[[ripemd160.Size]byte]struct{} + UncompressedPubKeys map[[65]byte]struct{} + Unspent map[wire.OutPoint]struct{} + func (r *RescanKeys) UnspentSlice() []*wire.OutPoint + type ResetChainRes struct + Err error + Res *None + type RestartRes struct + Err error + Res *None + type RetrievedTx struct + BlkHash *chainhash.Hash + Tx *util.Tx + TxBytes []byte + type SearchRawTransactionsRes struct + Err error + Res *[]btcjson.SearchRawTransactionsResult + type Semaphore qu.C + func MakeSemaphore(n int) Semaphore + func (s Semaphore) Acquire() + func (s Semaphore) Release() + type SendRawTransactionRes struct + Err error + Res *None + type Server struct + AuthSHA [sha256.Size]byte + Cfg ServerConfig + Config *podcfg.Config + GBTWorkState *GBTWorkState + HelpCacher *HelpCacher + LimitAuthSHA [sha256.Size]byte + NtfnMgr *WSNtfnMgr + NumClients int32 + Quit qu.C + RequestProcessShutdown qu.C + Shutdown int32 + StartController qu.C + Started int32 + StateCfg *state.Config + StatusLines map[int]string + StatusLock sync.RWMutex + StopController qu.C + WG sync.WaitGroup + func NewRPCServer(config *ServerConfig, statecfg *state.Config, podcfg *podcfg.Config) (*Server, error) + func (s *Server) CheckAuth(r *http.Request, require bool) (bool, bool, error) + func (s *Server) DecrementClients() + func (s *Server) HTTPStatusLine(req *http.Request, code int) string + func (s *Server) HandleBlockchainNotification(notification *blockchain.Notification) + func (s *Server) IncrementClients() + func (s *Server) JSONRPCRead(w http.ResponseWriter, r *http.Request, isAdmin bool) + func (s *Server) LimitConnections(w http.ResponseWriter, remoteAddr string) bool + func (s *Server) NotifyNewTransactions(txns []*mempool.TxDesc) + func (s *Server) RequestedProcessShutdown() qu.C + func (s *Server) StandardCmdResult(cmd *ParsedRPCCmd, closeChan qu.C) (interface{}, error) + func (s *Server) Start() + func (s *Server) Stop() (e error) + func (s *Server) WebsocketHandler(conn *websocket.Conn, remoteAddr string, authenticated bool, isAdmin bool) + func (s *Server) WriteHTTPResponseHeaders(req *http.Request, headers http.Header, code int, w io.Writer) (e error) + type ServerConfig struct + AddrIndex *indexers.AddrIndex + Algo string + CfIndex *indexers.CFIndex + Cfg *podcfg.Config + Chain *blockchain.BlockChain + ChainParams *chaincfg.Params + ConnMgr ServerConnManager + DB database.DB + FeeEstimator *mempool.FeeEstimator + Generator *mining.BlkTmplGenerator + Hashrate uberatomic.Uint64 + Listeners []net.Listener + Quit qu.C + StartController qu.C + StartupTime int64 + StopController qu.C + SyncMgr ServerSyncManager + TimeSource blockchain.MedianTimeSource + TxIndex *indexers.TxIndex + TxMemPool *mempool.TxPool + type ServerConnManager interface + AddRebroadcastInventory func(iv *wire.InvVect, data interface{}) + BroadcastMessage func(msg wire.Message) + Connect func(addr string, permanent bool) error + ConnectedCount func() int32 + ConnectedPeers func() []ServerPeer + DisconnectByAddr func(addr string) error + DisconnectByID func(id int32) error + NetTotals func() (uint64, uint64) + PersistentPeers func() []ServerPeer + RelayTransactions func(txns []*mempool.TxDesc) + RemoveByAddr func(addr string) error + RemoveByID func(id int32) error + type ServerPeer interface + GetBanScore func() uint32 + GetFeeFilter func() int64 + IsTxRelayDisabled func() bool + ToPeer func() *p.Peer + type ServerSyncManager interface + IsCurrent func() bool + LocateHeaders func(locators []*chainhash.Hash, hashStop *chainhash.Hash) []wire.BlockHeader + Pause func() chan<- struct{} + SubmitBlock func(block *block.Block, flags blockchain.BehaviorFlags) (bool, error) + SyncPeerID func() int32 + type SetGenerateRes struct + Err error + Res *None + type SimpleAddr struct + Addr string + Net string + func (a SimpleAddr) Network() string + func (a SimpleAddr) String() string + type StopRes struct + Err error + Res *None + type SubmitBlockRes struct + Err error + Res *string + type SyncManager struct + func (b *SyncManager) IsCurrent() bool + func (b *SyncManager) LocateHeaders(locators []*chainhash.Hash, hashStop *chainhash.Hash) []wire.BlockHeader + func (b *SyncManager) Pause() chan<- struct{} + func (b *SyncManager) SubmitBlock(block *block.Block, flags blockchain.BehaviorFlags) (bool, error) + func (b *SyncManager) SyncPeerID() int32 + type UpdatePeerHeightsMsg struct + NewHash *chainhash.Hash + NewHeight int32 + OriginPeer *peer.Peer + type UptimeRes struct + Err error + Res *btcjson.GetMempoolInfoResult + type ValidateAddressRes struct + Err error + Res *btcjson.ValidateAddressChainResult + type VerifyChainRes struct + Err error + Res *bool + type VerifyMessageRes struct + Err error + Res *bool + type VersionRes struct + Err error + Res *map[string]btcjson.VersionResult + type WSClient struct + Addr string + AddrRequests map[string]struct{} + Authenticated bool + Conn *websocket.Conn + Disconnected bool + FilterData *WSClientFilter + IsAdmin bool + NtfnChan chan []byte + Quit qu.C + SendChan chan WSResponse + Server *Server + ServiceRequestSem Semaphore + SessionID uint64 + SpentRequests map[wire.OutPoint]struct{} + VerboseTxUpdates bool + WG sync.WaitGroup + func NewWebsocketClient(server *Server, conn *websocket.Conn, remoteAddr string, authenticated bool, ...) (*WSClient, error) + func (c *WSClient) Disconnect() + func (c *WSClient) InHandler() + func (c *WSClient) IsDisconnected() bool + func (c *WSClient) NotificationQueueHandler() + func (c *WSClient) OutHandler() + func (c *WSClient) QueueNotification(marshalledJSON []byte) (e error) + func (c *WSClient) SendMessage(marshalledJSON []byte, doneChan chan bool) + func (c *WSClient) ServiceRequest(r *ParsedRPCCmd) + func (c *WSClient) Start() + func (c *WSClient) WaitForShutdown() + type WSClientFilter struct + CompressedPubKeys map[[33]byte]struct{} + OtherAddresses map[string]struct{} + PubKeyHashes map[[ripemd160.Size]byte]struct{} + ScriptHashes map[[ripemd160.Size]byte]struct{} + UncompressedPubKeys map[[65]byte]struct{} + Unspent map[wire.OutPoint]struct{} + func NewWSClientFilter(addresses []string, unspentOutPoints []wire.OutPoint, params *chaincfg.Params) *WSClientFilter + func (f *WSClientFilter) AddAddress(a btcaddr.Address) + func (f *WSClientFilter) AddAddressStr(s string, params *chaincfg.Params) + func (f *WSClientFilter) AddUnspentOutPoint(op *wire.OutPoint) + func (f *WSClientFilter) ExistsAddress(a btcaddr.Address) bool + func (f *WSClientFilter) ExistsUnspentOutPoint(op *wire.OutPoint) bool + type WSCommandHandler func(*WSClient, interface{}) (interface{}, error) + type WSNtfnMgr struct + NotificationMsgs chan interface{} + NumClients chan int + QueueNotification chan interface{} + Quit qu.C + Server *Server + WG sync.WaitGroup + func NewWSNotificationManager(server *Server) *WSNtfnMgr + func (*WSNtfnMgr) AddAddrRequests(addrMap map[string]map[qu.C]*WSClient, wsc *WSClient, addrs []string) + func (*WSNtfnMgr) NotifyBlockConnected(clients map[qu.C]*WSClient, block *block.Block) + func (*WSNtfnMgr) NotifyBlockDisconnected(clients map[qu.C]*WSClient, block *block.Block) + func (*WSNtfnMgr) NotifyFilteredBlockDisconnected(clients map[qu.C]*WSClient, block *block.Block) + func (*WSNtfnMgr) RemoveAddrRequest(addrs map[string]map[qu.C]*WSClient, wsc *WSClient, addr string) + func (*WSNtfnMgr) RemoveSpentRequest(ops map[...]map[qu.C]*WSClient, wsc *WSClient, op *wire.OutPoint) + func (m *WSNtfnMgr) AddClient(wsc *WSClient) + func (m *WSNtfnMgr) AddSpentRequests(opMap map[...]map[qu.C]*WSClient, wsc *WSClient, ops []*wire.OutPoint) + func (m *WSNtfnMgr) GetNumClients() (n int) + func (m *WSNtfnMgr) GetSubscribedClients(tx *util.Tx, clients map[qu.C]*WSClient) map[qu.C]struct{} + func (m *WSNtfnMgr) NotificationHandler() + func (m *WSNtfnMgr) NotifyFilteredBlockConnected(clients map[qu.C]*WSClient, block *block.Block) + func (m *WSNtfnMgr) NotifyForNewTx(clients map[qu.C]*WSClient, tx *util.Tx) + func (m *WSNtfnMgr) NotifyForTx(ops map[wire.OutPoint]map[qu.C]*WSClient, addrs map[string]map[qu.C]*WSClient, ...) + func (m *WSNtfnMgr) NotifyForTxIns(ops map[...]map[qu.C]*WSClient, tx *util.Tx, block *block.Block) + func (m *WSNtfnMgr) NotifyForTxOuts(ops map[wire.OutPoint]map[qu.C]*WSClient, addrs map[string]map[qu.C]*WSClient, ...) + func (m *WSNtfnMgr) NotifyRelevantTxAccepted(tx *util.Tx, clients map[qu.C]*WSClient) + func (m *WSNtfnMgr) QueueHandler() + func (m *WSNtfnMgr) RegisterBlockUpdates(wsc *WSClient) + func (m *WSNtfnMgr) RegisterNewMempoolTxsUpdates(wsc *WSClient) + func (m *WSNtfnMgr) RegisterSpentRequests(wsc *WSClient, ops []*wire.OutPoint) + func (m *WSNtfnMgr) RegisterTxOutAddressRequests(wsc *WSClient, addrs []string) + func (m *WSNtfnMgr) RemoveClient(wsc *WSClient) + func (m *WSNtfnMgr) SendNotifyBlockConnected(block *block.Block) + func (m *WSNtfnMgr) SendNotifyBlockDisconnected(block *block.Block) + func (m *WSNtfnMgr) SendNotifyMempoolTx(tx *util.Tx, isNew bool) + func (m *WSNtfnMgr) Shutdown() + func (m *WSNtfnMgr) Start() + func (m *WSNtfnMgr) UnregisterBlockUpdates(wsc *WSClient) + func (m *WSNtfnMgr) UnregisterNewMempoolTxsUpdates(wsc *WSClient) + func (m *WSNtfnMgr) UnregisterSpentRequest(wsc *WSClient, op *wire.OutPoint) + func (m *WSNtfnMgr) UnregisterTxOutAddressRequest(wsc *WSClient, addr string) + func (m *WSNtfnMgr) WaitForShutdown() + type WSResponse struct + DoneChan chan bool + Msg []byte