query

Aug 17, 2023

Changes in this version

type QueryOption

+ func NoRetryMax() QueryOption

+ func NumRetries(num uint8) QueryOption

type WorkManager

+ func NewWorkManager(cfg *Config) WorkManager

Nov 13, 2019

Changes in this version

+ var ErrJobCanceled = errors.New("job canceled")

+ var ErrPeerDisconnected = errors.New("peer disconnected")

+ var ErrQueryTimeout = errors.New("did not get response before timeout")

+ var ErrWorkManagerShuttingDown = errors.New("WorkManager shutting down")

+ func DisableLog()

+ func UseLogger(logger btclog.Logger)

+ type Config struct

+ ConnectedPeers func() (<-chan Peer, func(), error)

+ NewWorker func(Peer) Worker

+ Ranking PeerRanking

+ type Dispatcher interface

+ Query func(reqs []*Request, options ...QueryOption) chan error

+ type Peer interface

+ Addr func() string

+ OnDisconnect func() <-chan struct{}

+ QueueMessageWithEncoding func(msg wire.Message, doneChan chan<- struct{}, encoding wire.MessageEncoding)

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

+ type PeerRanking interface

+ AddPeer func(peer string)

+ Order func(peers []string)

+ Punish func(peer string)

+ Reward func(peer string)

+ func NewPeerRanking() PeerRanking

+ type Progress struct

+ Finished bool

+ Progressed bool

+ type QueryOption func(*queryOptions)

+ func Cancel(cancel chan struct{}) QueryOption

+ func Encoding(encoding wire.MessageEncoding) QueryOption

+ func Timeout(timeout time.Duration) QueryOption

+ type Request struct

+ HandleResp func(req, resp wire.Message, peer string) Progress

+ Req wire.Message

+ type Task interface

+ Index func() uint64

+ type WorkManager struct

+ func New(cfg *Config) *WorkManager

+ func (w *WorkManager) Query(requests []*Request, options ...QueryOption) chan error

+ func (w *WorkManager) Start() error

+ func (w *WorkManager) Stop() error

+ type Worker interface

+ NewJob func() chan<- *queryJob

+ Run func(results chan<- *jobResult, quit <-chan struct{})

+ func NewWorker(peer Peer) Worker