Versions in this module Expand all Collapse all v0 v0.0.3 Sep 11, 2024 Changes in this version + func NewMockConn(localPk, remotePk *btcec.PublicKey, localAddr, remoteAddr net.Addr, ...) (*MockPeer, *MockPeer) + func NewQueueDB[T any]() wtdb.Queue[T] + type DiskQueueDB struct + func (d *DiskQueueDB[T]) Len() (uint64, error) + func (d *DiskQueueDB[T]) PopUpTo(n int) ([]T, error) + func (d *DiskQueueDB[T]) Push(items ...T) error + func (d *DiskQueueDB[T]) PushHead(items ...T) error + type MockPeer struct + IncomingMsgs chan []byte + OutgoingMsgs chan []byte + Quit chan struct{} + RemoteQuit chan struct{} + func NewMockPeer(lpk, rpk *btcec.PublicKey, addr net.Addr, bufferSize int) *MockPeer + func (p *MockPeer) Close() error + func (p *MockPeer) LocalAddr() net.Addr + func (p *MockPeer) Read(dst []byte) (int, error) + func (p *MockPeer) ReadNextMessage() ([]byte, error) + func (p *MockPeer) RemoteAddr() net.Addr + func (p *MockPeer) RemotePub() *btcec.PublicKey + func (p *MockPeer) SetDeadline(t time.Time) error + func (p *MockPeer) SetReadDeadline(t time.Time) error + func (p *MockPeer) SetWriteDeadline(t time.Time) error + func (p *MockPeer) Write(b []byte) (n int, err error) + type MockSigner struct + func NewMockSigner() *MockSigner + func (s *MockSigner) AddPrivKey(privKey *btcec.PrivateKey) keychain.KeyLocator + func (s *MockSigner) ComputeInputScript(tx *wire.MsgTx, signDesc *input.SignDescriptor) (*input.Script, error) + func (s *MockSigner) MuSig2Cleanup(input.MuSig2SessionID) error + func (s *MockSigner) MuSig2CombineSig(input.MuSig2SessionID, []*musig2.PartialSignature) (*schnorr.Signature, bool, error) + func (s *MockSigner) MuSig2CreateSession(input.MuSig2Version, keychain.KeyLocator, []*btcec.PublicKey, ...) (*input.MuSig2SessionInfo, error) + func (s *MockSigner) MuSig2RegisterNonces(input.MuSig2SessionID, [][musig2.PubNonceSize]byte) (bool, error) + func (s *MockSigner) MuSig2Sign(input.MuSig2SessionID, [sha256.Size]byte, bool) (*musig2.PartialSignature, error) + func (s *MockSigner) SignOutputRaw(tx *wire.MsgTx, signDesc *input.SignDescriptor) (input.Signature, error) + type SecretKeyRing struct + func NewSecretKeyRing() *SecretKeyRing + func (m *SecretKeyRing) DeriveKey(keyLoc keychain.KeyLocator) (keychain.KeyDescriptor, error) + func (m *SecretKeyRing) ECDH(keyDesc keychain.KeyDescriptor, pub *btcec.PublicKey) ([32]byte, error) + type TowerDB struct + func NewTowerDB() *TowerDB + func (db *TowerDB) DeleteSession(target wtdb.SessionID) error + func (db *TowerDB) GetLookoutTip() (*chainntnfs.BlockEpoch, error) + func (db *TowerDB) GetSessionInfo(id *wtdb.SessionID) (*wtdb.SessionInfo, error) + func (db *TowerDB) InsertSessionInfo(info *wtdb.SessionInfo) error + func (db *TowerDB) InsertStateUpdate(update *wtdb.SessionStateUpdate) (uint16, error) + func (db *TowerDB) QueryMatches(breachHints []blob.BreachHint) ([]wtdb.Match, error) + func (db *TowerDB) SetLookoutTip(epoch *chainntnfs.BlockEpoch) error
Go to main page