actrino

module

Go to main page

Versions in this module

v0

v0.0.19

Mar 4, 2020

v0.0.18

Mar 4, 2020

v0.0.17

Mar 4, 2020

v0.0.16

Mar 4, 2020

v0.0.15

Mar 4, 2020

v0.0.14

Mar 4, 2020

v0.0.13

Mar 4, 2020

v0.0.12

Mar 4, 2020

v0.0.11

Mar 4, 2020

v0.0.10

Mar 2, 2020

Changes in this version

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

+ var QueryBatchTimeout = time.Second * 30

+ var QueryPeerCooldown = time.Second * 5

type ChainService

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

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

+ type ChainSource interface

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

+ ChainParams func() chaincfg.Params

+ GetBlock func(chainhash.Hash, ...QueryOption) (*ltcutil.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

+ AssertFilterHeader *headerfs.FilterHeader

type QueryOption

+ func OptimisticBatch() QueryOption

+ func OptimisticReverseBatch() QueryOption

type Rescan

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

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

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

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

v0.0.9

Mar 2, 2020

v0.0.8

Mar 2, 2020

v0.0.7

Mar 2, 2020

v0.0.5

Apr 4, 2019

v0.0.3

Apr 4, 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 = 4096 * 1000

+ var DisableDNSSeed = false

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

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

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

+ var MaxPeers = 125

+ var QueryEncoding = wire.WitnessEncoding

+ var QueryNumRetries = 2

+ var QueryPeerConnectTimeout = time.Second * 30

+ var QueryTimeout = time.Second * 3

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

+ var Services = wire.SFNodeWitness | wire.SFNodeCF

+ var TargetOutbound = 8

+ var UserAgentName = "actrino"

+ 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(sp *ServerPeer)

+ func (s *ChainService) BestBlock() (*waddrmgr.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) (*acmutil.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) IsCurrent() bool

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

+ func (s *ChainService) NewRescan(options ...RescanOption) *Rescan

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

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

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

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

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

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

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

+ func (s *ChainService) Start()

+ func (s *ChainService) Stop() error

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

+ type Config struct

+ AddPeers []string

+ 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 QueryOption func(*queryOptions)

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

+ func Encoding(encoding wire.MessageEncoding) QueryOption

+ func NumRetries(numRetries uint8) QueryOption

+ func PeerConnectTimeout(timeout time.Duration) QueryOption

+ func PersistToDisk() QueryOption

+ func Timeout(timeout time.Duration) QueryOption

+ type Rescan struct

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

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

+ func (r *Rescan) WaitForShutdown()

+ type RescanOption func(ro *rescanOptions)

+ func EndBlock(endBlock *waddrmgr.BlockStamp) RescanOption

+ func NotificationHandlers(ntfn rpcclient.NotificationHandlers) RescanOption

+ func QueryOptions(options ...QueryOption) RescanOption

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

+ func StartBlock(startBlock *waddrmgr.BlockStamp) RescanOption

+ func StartTime(startTime time.Time) RescanOption

+ func TxIdx(txIdx uint32) RescanOption

+ func WatchAddrs(watchAddrs ...acmutil.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 ...acmutil.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() (*waddrmgr.BlockStamp, error)

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

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

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

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