db

package
v2.4.3+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 8, 2020 License: MIT Imports: 29 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var SettingsNotSetError = errors.New("settings not set")

Functions

func CoinTypeForContract added in v0.12.1 

func CoinTypeForContract(contract *pb.RicardianContract) string

func NewCaseStore added in v0.11.1 

func NewCaseStore(db *sql.DB, lock *sync.Mutex) repo.CaseStore

func NewChatStore added in v0.11.1 

func NewChatStore(db *sql.DB, lock *sync.Mutex) repo.ChatStore

func NewConfigurationStore added in v0.11.1 

func NewConfigurationStore(db *sql.DB, lock *sync.Mutex) repo.ConfigurationStore

func NewCouponStore added in v0.11.1 

func NewCouponStore(db *sql.DB, lock *sync.Mutex) repo.CouponStore

func NewFollowerStore added in v0.11.1 

func NewFollowerStore(db *sql.DB, lock *sync.Mutex) repo.FollowerStore

func NewFollowingStore added in v0.11.1 

func NewFollowingStore(db *sql.DB, lock *sync.Mutex) repo.FollowingStore

func NewInventoryStore added in v0.11.1 

func NewInventoryStore(db *sql.DB, lock *sync.Mutex) repo.InventoryStore

func NewKeyStore added in v0.11.1 

func NewKeyStore(db *sql.DB, lock *sync.Mutex, coinType util.ExtCoinType) repo.KeyStore

func NewMessageStore added in v0.13.5 

func NewMessageStore(db *sql.DB, lock *sync.Mutex) repo.MessageStore

NewMessageStore return new MessagesDB

func NewModeratedStore added in v0.11.1 

func NewModeratedStore(db *sql.DB, lock *sync.Mutex) repo.ModeratedStore

func NewNotificationStore added in v0.11.1 

func NewNotificationStore(db *sql.DB, lock *sync.Mutex) repo.NotificationStore

func NewOfflineMessageStore added in v0.11.1 

func NewOfflineMessageStore(db *sql.DB, lock *sync.Mutex) repo.OfflineMessageStore

func NewPointerStore added in v0.11.1 

func NewPointerStore(db *sql.DB, lock *sync.Mutex) repo.PointerStore

func NewPurchaseStore added in v0.11.1 

func NewPurchaseStore(db *sql.DB, lock *sync.Mutex) repo.PurchaseStore

func NewSaleStore added in v0.11.1 

func NewSaleStore(db *sql.DB, lock *sync.Mutex) repo.SaleStore

func NewSpentTransactionStore added in v0.11.1 

func NewSpentTransactionStore(db *sql.DB, lock *sync.Mutex, coinType util.ExtCoinType) repo.SpentTransactionOutputStore

func NewTransactionMetadataStore added in v0.11.1 

func NewTransactionMetadataStore(db *sql.DB, lock *sync.Mutex) repo.TransactionMetadataStore

func NewTransactionStore added in v0.11.1 

func NewTransactionStore(db *sql.DB, lock *sync.Mutex, coinType util.ExtCoinType) repo.TransactionStore

func NewUnspentTransactionStore added in v0.11.1 

func NewUnspentTransactionStore(db *sql.DB, lock *sync.Mutex, coinType util.ExtCoinType) repo.UnspentTransactionOutputStore

func NewWatchedScriptStore added in v0.11.1 

func NewWatchedScriptStore(db *sql.DB, lock *sync.Mutex, coinType util.ExtCoinType) repo.WatchedScriptStore

func PaymentCoinForContract added in v0.12.1 

func PaymentCoinForContract(contract *pb.RicardianContract) (string, error)

Types

type CasesDB added in v0.3.0 

type CasesDB struct {
	// contains filtered or unexported fields
}

func (*CasesDB) BeginTransaction added in v0.11.1 

func (m *CasesDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*CasesDB) Count added in v0.6.0 

func (c *CasesDB) Count() int

func (*CasesDB) Delete added in v0.3.0 

func (c *CasesDB) Delete(orderID string) error

func (*CasesDB) ExecuteQuery added in v0.11.1 

func (m *CasesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*CasesDB) GetAll added in v0.3.0 

func (c *CasesDB) GetAll(stateFilter []pb.OrderState, searchTerm string, sortByAscending bool, sortByRead bool, limit int, exclude []string) ([]repo.Case, int, error)

func (*CasesDB) GetByCaseID added in v0.12.1 

func (c *CasesDB) GetByCaseID(caseID string) (*repo.DisputeCaseRecord, error)

func (*CasesDB) GetCaseMetadata added in v0.3.0 

func (c *CasesDB) GetCaseMetadata(caseID string) (buyerContract, vendorContract *pb.RicardianContract, buyerValidationErrors, vendorValidationErrors []string, state pb.OrderState, read bool, timestamp time.Time, buyerOpened bool, claim string, resolution *pb.DisputeResolution, err error)

func (*CasesDB) GetDisputesForDisputeExpiryNotification added in v0.12.1 

func (c *CasesDB) GetDisputesForDisputeExpiryNotification() ([]*repo.DisputeCaseRecord, error)

GetDisputesForDisputeExpiryNotification returns []*repo.DisputeCaseRecord including each record which needs Notifications to be generated. Currently, notifications are generated at 0, 15, 30, 44, and 45 days after opening.

func (*CasesDB) Lock added in v0.12.1 

func (m *CasesDB) Lock()

func (*CasesDB) MarkAsClosed added in v0.3.0 

func (c *CasesDB) MarkAsClosed(caseID string, resolution *pb.DisputeResolution) error

func (*CasesDB) MarkAsRead added in v0.3.0 

func (c *CasesDB) MarkAsRead(orderID string) error

func (*CasesDB) MarkAsUnread added in v0.6.1 

func (c *CasesDB) MarkAsUnread(orderID string) error

func (*CasesDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *CasesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*CasesDB) PrepareQuery added in v0.11.1 

func (m *CasesDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*CasesDB) Put added in v0.3.0 

func (c *CasesDB) Put(caseID string, state pb.OrderState, buyerOpened bool, claim string, paymentCoin string, coinType string) error

func (*CasesDB) PutRecord added in v0.12.1 

func (c *CasesDB) PutRecord(dispute *repo.DisputeCaseRecord) error

func (*CasesDB) Unlock added in v0.12.1 

func (m *CasesDB) Unlock()

func (*CasesDB) UpdateBuyerInfo added in v0.3.0 

func (c *CasesDB) UpdateBuyerInfo(caseID string, buyerContract *pb.RicardianContract, buyerValidationErrors []string, buyerPayoutAddress string, buyerOutpoints []*pb.Outpoint) error

func (*CasesDB) UpdateDisputesLastDisputeExpiryNotifiedAt added in v0.12.1 

func (c *CasesDB) UpdateDisputesLastDisputeExpiryNotifiedAt(disputeCases []*repo.DisputeCaseRecord) error

UpdateDisputesLastDisputeExpiryNotifiedAt accepts []*repo.DisputeCaseRecord and updates each DisputeCaseRecord by their CaseID to the set LastDisputeExpiryNotifiedAt value. The update will be attempted atomically with a rollback attempted in the event of an error.

func (*CasesDB) UpdateVendorInfo added in v0.3.0 

func (c *CasesDB) UpdateVendorInfo(caseID string, vendorContract *pb.RicardianContract, vendorValidationErrors []string, vendorPayoutAddress string, vendorOutpoints []*pb.Outpoint) error

type ChatDB added in v0.3.1 

type ChatDB struct {
	// contains filtered or unexported fields
}

func (*ChatDB) BeginTransaction added in v0.11.1 

func (m *ChatDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*ChatDB) DeleteConversation added in v0.3.1 

func (c *ChatDB) DeleteConversation(peerId string) error

func (*ChatDB) DeleteMessage added in v0.3.1 

func (c *ChatDB) DeleteMessage(msgID string) error

func (*ChatDB) ExecuteQuery added in v0.11.1 

func (m *ChatDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*ChatDB) GetConversations added in v0.3.1 

func (c *ChatDB) GetConversations() []repo.ChatConversation

func (*ChatDB) GetMessages added in v0.3.1 

func (c *ChatDB) GetMessages(peerID string, subject string, offsetID string, limit int) []repo.ChatMessage

func (*ChatDB) GetUnreadCount added in v0.5.1 

func (c *ChatDB) GetUnreadCount(subject string) (int, error)

func (*ChatDB) Lock added in v0.12.1 

func (m *ChatDB) Lock()

func (*ChatDB) MarkAsRead added in v0.3.1 

func (c *ChatDB) MarkAsRead(peerID string, subject string, outgoing bool, messageId string) (string, bool, error)

func (*ChatDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *ChatDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*ChatDB) PrepareQuery added in v0.11.1 

func (m *ChatDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*ChatDB) Put added in v0.3.1 

func (c *ChatDB) Put(messageId string, peerID string, subject string, message string, timestamp time.Time, read bool, outgoing bool) error

func (*ChatDB) Unlock added in v0.12.1 

func (m *ChatDB) Unlock()

type ConfigDB 

type ConfigDB struct {
	// contains filtered or unexported fields
}

func (*ConfigDB) BeginTransaction added in v0.14.0 

func (m *ConfigDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*ConfigDB) ExecuteQuery added in v0.14.0 

func (m *ConfigDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*ConfigDB) GetCreationDate added in v0.6.4 

func (c *ConfigDB) GetCreationDate() (time.Time, error)

func (*ConfigDB) GetIdentityKey 

func (c *ConfigDB) GetIdentityKey() ([]byte, error)

func (*ConfigDB) GetMnemonic 

func (c *ConfigDB) GetMnemonic() (string, bool, error)

func (*ConfigDB) Init 

func (c *ConfigDB) Init(mnemonic string, identityKey []byte, password string, creationDate time.Time) error

func (*ConfigDB) IsEncrypted 

func (c *ConfigDB) IsEncrypted() bool

func (*ConfigDB) Lock added in v0.14.0 

func (m *ConfigDB) Lock()

func (*ConfigDB) PrepareAndExecuteQuery added in v0.14.0 

func (m *ConfigDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*ConfigDB) PrepareQuery added in v0.14.0 

func (m *ConfigDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*ConfigDB) Unlock added in v0.14.0 

func (m *ConfigDB) Unlock()

func (*ConfigDB) UpdateMnemonic 

func (c *ConfigDB) UpdateMnemonic(mnemonic string, isEncrypted bool) error

type CouponDB added in v0.5.0 

type CouponDB struct {
	// contains filtered or unexported fields
}

func (*CouponDB) BeginTransaction added in v0.11.1 

func (m *CouponDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*CouponDB) Delete added in v0.5.0 

func (c *CouponDB) Delete(slug string) error

func (*CouponDB) ExecuteQuery added in v0.11.1 

func (m *CouponDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*CouponDB) Get added in v0.5.0 

func (c *CouponDB) Get(slug string) ([]repo.Coupon, error)

func (*CouponDB) Lock added in v0.12.1 

func (m *CouponDB) Lock()

func (*CouponDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *CouponDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*CouponDB) PrepareQuery added in v0.11.1 

func (m *CouponDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*CouponDB) Put added in v0.5.0 

func (c *CouponDB) Put(coupons []repo.Coupon) error

func (*CouponDB) Unlock added in v0.12.1 

func (m *CouponDB) Unlock()

type DB added in v0.13.0 

type DB struct {
	SqlDB *sql.DB
	Lock  *sync.Mutex
}

type FollowerDB 

type FollowerDB struct {
	// contains filtered or unexported fields
}

func (*FollowerDB) BeginTransaction added in v0.11.1 

func (m *FollowerDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*FollowerDB) Count 

func (f *FollowerDB) Count() int

func (*FollowerDB) Delete 

func (f *FollowerDB) Delete(follower string) error

func (*FollowerDB) ExecuteQuery added in v0.11.1 

func (m *FollowerDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*FollowerDB) FollowsMe added in v0.2.0 

func (f *FollowerDB) FollowsMe(peerID string) bool

func (*FollowerDB) Get 

func (f *FollowerDB) Get(offsetID string, limit int) ([]repo.Follower, error)

func (*FollowerDB) Lock added in v0.12.1 

func (m *FollowerDB) Lock()

func (*FollowerDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *FollowerDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*FollowerDB) PrepareQuery added in v0.11.1 

func (m *FollowerDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*FollowerDB) Put 

func (f *FollowerDB) Put(follower string, proof []byte) error

func (*FollowerDB) Unlock added in v0.12.1 

func (m *FollowerDB) Unlock()

type FollowingDB 

type FollowingDB struct {
	// contains filtered or unexported fields
}

func (*FollowingDB) BeginTransaction added in v0.11.1 

func (m *FollowingDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*FollowingDB) Count 

func (f *FollowingDB) Count() int

func (*FollowingDB) Delete 

func (f *FollowingDB) Delete(follower string) error

func (*FollowingDB) ExecuteQuery added in v0.11.1 

func (m *FollowingDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*FollowingDB) Get 

func (f *FollowingDB) Get(offsetID string, limit int) ([]string, error)

func (*FollowingDB) IsFollowing added in v0.2.0 

func (f *FollowingDB) IsFollowing(peerID string) bool

func (*FollowingDB) Lock added in v0.12.1 

func (m *FollowingDB) Lock()

func (*FollowingDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *FollowingDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*FollowingDB) PrepareQuery added in v0.11.1 

func (m *FollowingDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*FollowingDB) Put 

func (f *FollowingDB) Put(follower string) error

func (*FollowingDB) Unlock added in v0.12.1 

func (m *FollowingDB) Unlock()

type InventoryDB 

type InventoryDB struct {
	// contains filtered or unexported fields
}

func (*InventoryDB) BeginTransaction added in v0.11.1 

func (m *InventoryDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*InventoryDB) Delete 

func (i *InventoryDB) Delete(slug string, variantIndex int) error

func (*InventoryDB) DeleteAll added in v0.1.1 

func (i *InventoryDB) DeleteAll(slug string) error

func (*InventoryDB) ExecuteQuery added in v0.11.1 

func (m *InventoryDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*InventoryDB) Get 

func (i *InventoryDB) Get(slug string) (map[int]*big.Int, error)

func (*InventoryDB) GetAll 

func (i *InventoryDB) GetAll() (map[string]map[int]*big.Int, error)

func (*InventoryDB) GetSpecific added in v0.1.1 

func (i *InventoryDB) GetSpecific(slug string, variantIndex int) (*big.Int, error)

func (*InventoryDB) Lock added in v0.12.1 

func (m *InventoryDB) Lock()

func (*InventoryDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *InventoryDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*InventoryDB) PrepareQuery added in v0.11.1 

func (m *InventoryDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*InventoryDB) Put 

func (i *InventoryDB) Put(slug string, variantIndex int, count *big.Int) error

func (*InventoryDB) Unlock added in v0.12.1 

func (m *InventoryDB) Unlock()

type KeysDB 

type KeysDB struct {
	// contains filtered or unexported fields
}

func (*KeysDB) BeginTransaction added in v0.11.1 

func (m *KeysDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*KeysDB) ExecuteQuery added in v0.11.1 

func (m *KeysDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*KeysDB) GetAll 

func (k *KeysDB) GetAll() ([]wallet.KeyPath, error)

func (*KeysDB) GetImported added in v0.9.2 

func (k *KeysDB) GetImported() ([]*btcec.PrivateKey, error)

func (*KeysDB) GetKey added in v0.7.0 

func (k *KeysDB) GetKey(scriptAddress []byte) (*btcec.PrivateKey, error)

func (*KeysDB) GetLastKeyIndex 

func (k *KeysDB) GetLastKeyIndex(purpose wallet.KeyPurpose) (int, bool, error)

func (*KeysDB) GetLookaheadWindows 

func (k *KeysDB) GetLookaheadWindows() map[wallet.KeyPurpose]int

func (*KeysDB) GetPathForKey added in v0.7.0 

func (k *KeysDB) GetPathForKey(scriptAddress []byte) (wallet.KeyPath, error)

func (*KeysDB) GetUnused 

func (k *KeysDB) GetUnused(purpose wallet.KeyPurpose) ([]int, error)

func (*KeysDB) ImportKey added in v0.4.2 

func (k *KeysDB) ImportKey(scriptAddress []byte, key *btcec.PrivateKey) error

func (*KeysDB) Lock added in v0.12.1 

func (m *KeysDB) Lock()

func (*KeysDB) MarkKeyAsUsed 

func (k *KeysDB) MarkKeyAsUsed(scriptAddress []byte) error

func (*KeysDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *KeysDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*KeysDB) PrepareQuery added in v0.11.1 

func (m *KeysDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*KeysDB) Put 

func (k *KeysDB) Put(scriptAddress []byte, keyPath wallet.KeyPath) error

func (*KeysDB) Unlock added in v0.12.1 

func (m *KeysDB) Unlock()

type MessagesDB added in v0.13.5 

type MessagesDB struct {
	// contains filtered or unexported fields
}

MessagesDB represents the messages table

func (*MessagesDB) BeginTransaction added in v0.13.5 

func (m *MessagesDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*MessagesDB) ExecuteQuery added in v0.13.5 

func (m *MessagesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*MessagesDB) GetAllErrored added in v0.14.0 

func (o *MessagesDB) GetAllErrored() ([]repo.OrderMessage, error)

GetAllErrored returns all messages which have an error state

func (*MessagesDB) GetByOrderIDType added in v0.13.5 

func (o *MessagesDB) GetByOrderIDType(orderID string, mType pb.Message_MessageType) (*repo.Message, string, error)

GetByOrderIDType returns the message for the specified order and message type

func (*MessagesDB) Lock added in v0.13.5 

func (m *MessagesDB) Lock()

func (*MessagesDB) MarkAsResolved added in v0.14.0 

func (o *MessagesDB) MarkAsResolved(m repo.OrderMessage) error

MarkAsResolved sets a provided message as resolved

func (*MessagesDB) PrepareAndExecuteQuery added in v0.13.5 

func (m *MessagesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*MessagesDB) PrepareQuery added in v0.13.5 

func (m *MessagesDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*MessagesDB) Put added in v0.13.5 

func (o *MessagesDB) Put(messageID, orderID string, mType pb.Message_MessageType, peerID string, msg repo.Message, rErr string, receivedAt int64, pubkey []byte) error

Put will insert a record into the messages

func (*MessagesDB) Unlock added in v0.13.5 

func (m *MessagesDB) Unlock()

type ModeratedDB added in v0.5.1 

type ModeratedDB struct {
	// contains filtered or unexported fields
}

func (*ModeratedDB) BeginTransaction added in v0.11.1 

func (m *ModeratedDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*ModeratedDB) Delete added in v0.5.1 

func (m *ModeratedDB) Delete(follower string) error

func (*ModeratedDB) ExecuteQuery added in v0.11.1 

func (m *ModeratedDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*ModeratedDB) Get added in v0.5.1 

func (m *ModeratedDB) Get(offsetId string, limit int) ([]string, error)

func (*ModeratedDB) Lock added in v0.12.1 

func (m *ModeratedDB) Lock()

func (*ModeratedDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *ModeratedDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*ModeratedDB) PrepareQuery added in v0.11.1 

func (m *ModeratedDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*ModeratedDB) Put added in v0.5.1 

func (m *ModeratedDB) Put(peerId string) error

func (*ModeratedDB) Unlock added in v0.12.1 

func (m *ModeratedDB) Unlock()

type NotficationsDB added in v0.3.1 

type NotficationsDB struct {
	// contains filtered or unexported fields
}

func (*NotficationsDB) BeginTransaction added in v0.11.1 

func (m *NotficationsDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*NotficationsDB) Delete added in v0.3.1 

func (n *NotficationsDB) Delete(notifID string) error

func (*NotficationsDB) ExecuteQuery added in v0.11.1 

func (m *NotficationsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*NotficationsDB) GetAll added in v0.3.1 

func (n *NotficationsDB) GetAll(offsetID string, limit int, typeFilter []string) ([]*repo.Notification, int, error)

func (*NotficationsDB) GetUnreadCount added in v0.5.6 

func (n *NotficationsDB) GetUnreadCount() (int, error)

func (*NotficationsDB) Lock added in v0.12.1 

func (m *NotficationsDB) Lock()

func (*NotficationsDB) MarkAllAsRead added in v0.6.4 

func (n *NotficationsDB) MarkAllAsRead() error

func (*NotficationsDB) MarkAsRead added in v0.3.1 

func (n *NotficationsDB) MarkAsRead(notifID string) error

func (*NotficationsDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *NotficationsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*NotficationsDB) PrepareQuery added in v0.11.1 

func (m *NotficationsDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*NotficationsDB) PutRecord added in v0.12.1 

func (n *NotficationsDB) PutRecord(record *repo.Notification) error

func (*NotficationsDB) Unlock added in v0.12.1 

func (m *NotficationsDB) Unlock()

type OfflineMessagesDB 

type OfflineMessagesDB struct {
	// contains filtered or unexported fields
}

func (*OfflineMessagesDB) BeginTransaction added in v0.11.1 

func (m *OfflineMessagesDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*OfflineMessagesDB) DeleteMessage added in v0.6.3 

func (o *OfflineMessagesDB) DeleteMessage(url string) error

func (*OfflineMessagesDB) ExecuteQuery added in v0.11.1 

func (m *OfflineMessagesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*OfflineMessagesDB) GetMessages added in v0.6.3 

func (o *OfflineMessagesDB) GetMessages() (map[string][]byte, error)

func (*OfflineMessagesDB) Has 

func (o *OfflineMessagesDB) Has(url string) bool

func (*OfflineMessagesDB) Lock added in v0.12.1 

func (m *OfflineMessagesDB) Lock()

func (*OfflineMessagesDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *OfflineMessagesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*OfflineMessagesDB) PrepareQuery added in v0.11.1 

func (m *OfflineMessagesDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*OfflineMessagesDB) Put 

func (o *OfflineMessagesDB) Put(url string) error

func (*OfflineMessagesDB) SetMessage added in v0.6.3 

func (o *OfflineMessagesDB) SetMessage(url string, message []byte) error

func (*OfflineMessagesDB) Unlock added in v0.12.1 

func (m *OfflineMessagesDB) Unlock()

type PointersDB 

type PointersDB struct {
	// contains filtered or unexported fields
}

func (*PointersDB) BeginTransaction added in v0.11.1 

func (m *PointersDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*PointersDB) Delete 

func (p *PointersDB) Delete(id peer.ID) error

func (*PointersDB) DeleteAll added in v0.1.1 

func (p *PointersDB) DeleteAll(purpose ipfs.Purpose) error

func (*PointersDB) ExecuteQuery added in v0.11.1 

func (m *PointersDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*PointersDB) Get added in v0.5.0 

func (p *PointersDB) Get(id peer.ID) (ipfs.Pointer, error)

func (*PointersDB) GetAll 

func (p *PointersDB) GetAll() ([]ipfs.Pointer, error)

func (*PointersDB) GetByPurpose added in v0.5.3 

func (p *PointersDB) GetByPurpose(purpose ipfs.Purpose) ([]ipfs.Pointer, error)

func (*PointersDB) Lock added in v0.12.1 

func (m *PointersDB) Lock()

func (*PointersDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *PointersDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*PointersDB) PrepareQuery added in v0.11.1 

func (m *PointersDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*PointersDB) Put 

func (p *PointersDB) Put(pointer ipfs.Pointer) error

func (*PointersDB) Unlock added in v0.12.1 

func (m *PointersDB) Unlock()

type PurchasesDB added in v0.1.2 

type PurchasesDB struct {
	// contains filtered or unexported fields
}

func (*PurchasesDB) BeginTransaction added in v0.11.1 

func (m *PurchasesDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*PurchasesDB) Count added in v0.6.0 

func (p *PurchasesDB) Count() int

func (*PurchasesDB) Delete added in v0.1.2 

func (p *PurchasesDB) Delete(orderID string) error

func (*PurchasesDB) ExecuteQuery added in v0.11.1 

func (m *PurchasesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*PurchasesDB) GetAll added in v0.1.2 

func (p *PurchasesDB) GetAll(stateFilter []pb.OrderState, searchTerm string, sortByAscending bool, sortByRead bool, limit int, exclude []string) ([]repo.Purchase, int, error)

func (*PurchasesDB) GetByOrderId added in v0.2.0 

func (p *PurchasesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, bool, *repo.CurrencyCode, error)

func (*PurchasesDB) GetByPaymentAddress added in v0.2.0 

func (p *PurchasesDB) GetByPaymentAddress(addr btc.Address) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, error)

func (*PurchasesDB) GetPurchasesForDisputeExpiryNotification added in v0.12.1 

func (p *PurchasesDB) GetPurchasesForDisputeExpiryNotification() ([]*repo.PurchaseRecord, error)

func (*PurchasesDB) GetPurchasesForDisputeTimeoutNotification added in v0.12.1 

func (p *PurchasesDB) GetPurchasesForDisputeTimeoutNotification() ([]*repo.PurchaseRecord, error)

GetPurchasesForDisputeTimeoutNotification returns []*PurchaseRecord including each record which needs Notifications to be generated.

func (*PurchasesDB) GetUnfunded added in v0.13.5 

func (p *PurchasesDB) GetUnfunded() ([]repo.UnfundedOrder, error)

func (*PurchasesDB) Lock added in v0.12.1 

func (m *PurchasesDB) Lock()

func (*PurchasesDB) MarkAsRead added in v0.1.2 

func (p *PurchasesDB) MarkAsRead(orderID string) error

func (*PurchasesDB) MarkAsUnread added in v0.6.1 

func (p *PurchasesDB) MarkAsUnread(orderID string) error

func (*PurchasesDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *PurchasesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*PurchasesDB) PrepareQuery added in v0.11.1 

func (m *PurchasesDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*PurchasesDB) Put added in v0.1.2 

func (p *PurchasesDB) Put(orderID string, contract pb.RicardianContract, state pb.OrderState, read bool) error

func (*PurchasesDB) Unlock added in v0.12.1 

func (m *PurchasesDB) Unlock()

func (*PurchasesDB) UpdateFunding added in v0.2.0 

func (p *PurchasesDB) UpdateFunding(orderId string, funded bool, records []*wallet.TransactionRecord) error

func (*PurchasesDB) UpdatePurchasesLastDisputeExpiryNotifiedAt added in v0.12.1 

func (p *PurchasesDB) UpdatePurchasesLastDisputeExpiryNotifiedAt(purchases []*repo.PurchaseRecord) error

UpdatePurchasesLastDisputeExpiryNotifiedAt accepts []*repo.PurchaseRecord and updates each PurchaseRecord by their OrderID to the set LastDisputeExpiryNotifiedAt value. The update will be attempted atomically with a rollback attempted in the event of an error.

func (*PurchasesDB) UpdatePurchasesLastDisputeTimeoutNotifiedAt added in v0.12.1 

func (p *PurchasesDB) UpdatePurchasesLastDisputeTimeoutNotifiedAt(purchases []*repo.PurchaseRecord) error

UpdatePurchasesLastDisputeTimeoutNotifiedAt accepts []*repo.PurchaseRecord and updates each PurchaseRecord by their OrderID to the set LastDisputeTimeoutNotifiedAt value. The update will be attempted atomically with a rollback attempted in the event of an error.

type SQLiteDatastore 

type SQLiteDatastore struct {
	// contains filtered or unexported fields
}

func Create 

func Create(repoPath, password string, testnet bool, coinType util.ExtCoinType) (*SQLiteDatastore, error)

func NewSQLiteDatastore added in v0.12.1 

func NewSQLiteDatastore(db *sql.DB, l *sync.Mutex, coinType util.ExtCoinType) *SQLiteDatastore

func (*SQLiteDatastore) Cases added in v0.3.0 

func (d *SQLiteDatastore) Cases() repo.CaseStore

func (*SQLiteDatastore) Chat added in v0.3.1 

func (d *SQLiteDatastore) Chat() repo.ChatStore

func (*SQLiteDatastore) Close 

func (d *SQLiteDatastore) Close()

func (*SQLiteDatastore) Config 

func (d *SQLiteDatastore) Config() repo.Config

func (*SQLiteDatastore) Copy 

func (d *SQLiteDatastore) Copy(dbPath string, password string) error

func (*SQLiteDatastore) Coupons added in v0.5.0 

func (d *SQLiteDatastore) Coupons() repo.CouponStore

func (*SQLiteDatastore) DB added in v0.13.0 

func (d *SQLiteDatastore) DB() *DB

func (*SQLiteDatastore) Followers 

func (d *SQLiteDatastore) Followers() repo.FollowerStore

func (*SQLiteDatastore) Following 

func (d *SQLiteDatastore) Following() repo.FollowingStore

func (*SQLiteDatastore) InitTables added in v0.9.4 

func (s *SQLiteDatastore) InitTables(password string) error

func (*SQLiteDatastore) Inventory 

func (d *SQLiteDatastore) Inventory() repo.InventoryStore

func (*SQLiteDatastore) Keys 

func (d *SQLiteDatastore) Keys() wallet.Keys

func (*SQLiteDatastore) Messages added in v0.13.5 

func (d *SQLiteDatastore) Messages() repo.MessageStore

Messages - return the messages datastore

func (*SQLiteDatastore) ModeratedStores added in v0.5.1 

func (d *SQLiteDatastore) ModeratedStores() repo.ModeratedStore

func (*SQLiteDatastore) Notifications added in v0.3.1 

func (d *SQLiteDatastore) Notifications() repo.NotificationStore

func (*SQLiteDatastore) OfflineMessages 

func (d *SQLiteDatastore) OfflineMessages() repo.OfflineMessageStore

func (*SQLiteDatastore) Ping added in v0.7.0 

func (d *SQLiteDatastore) Ping() error

func (*SQLiteDatastore) Pointers 

func (d *SQLiteDatastore) Pointers() repo.PointerStore

func (*SQLiteDatastore) Purchases added in v0.1.2 

func (d *SQLiteDatastore) Purchases() repo.PurchaseStore

func (*SQLiteDatastore) Sales added in v0.1.2 

func (d *SQLiteDatastore) Sales() repo.SaleStore

func (*SQLiteDatastore) Settings 

func (d *SQLiteDatastore) Settings() repo.ConfigurationStore

func (*SQLiteDatastore) Stxos 

func (d *SQLiteDatastore) Stxos() wallet.Stxos

func (*SQLiteDatastore) TxMetadata added in v0.5.1 

func (d *SQLiteDatastore) TxMetadata() repo.TransactionMetadataStore

func (*SQLiteDatastore) Txns 

func (d *SQLiteDatastore) Txns() wallet.Txns

func (*SQLiteDatastore) Utxos 

func (d *SQLiteDatastore) Utxos() wallet.Utxos

func (*SQLiteDatastore) WatchedScripts added in v0.2.0 

func (d *SQLiteDatastore) WatchedScripts() wallet.WatchedScripts

type SalesDB added in v0.1.2 

type SalesDB struct {
	// contains filtered or unexported fields
}

func (*SalesDB) BeginTransaction added in v0.11.1 

func (m *SalesDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*SalesDB) Count added in v0.6.0 

func (s *SalesDB) Count() int

func (*SalesDB) Delete added in v0.1.2 

func (s *SalesDB) Delete(orderID string) error

func (*SalesDB) ExecuteQuery added in v0.11.1 

func (m *SalesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*SalesDB) GetAll added in v0.1.2 

func (s *SalesDB) GetAll(stateFilter []pb.OrderState, searchTerm string, sortByAscending bool, sortByRead bool, limit int, exclude []string) ([]repo.Sale, int, error)

func (*SalesDB) GetByOrderId added in v0.2.0 

func (s *SalesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, bool, *repo.CurrencyCode, error)

func (*SalesDB) GetByPaymentAddress added in v0.2.0 

func (s *SalesDB) GetByPaymentAddress(addr btc.Address) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, error)

func (*SalesDB) GetSalesForDisputeTimeoutNotification added in v0.12.1 

func (s *SalesDB) GetSalesForDisputeTimeoutNotification() ([]*repo.SaleRecord, error)

GetSalesForDisputeTimeoutNotification returns []*SaleRecord including each record which needs Notifications to be generated.

func (*SalesDB) GetUnfunded added in v0.13.5 

func (s *SalesDB) GetUnfunded() ([]repo.UnfundedOrder, error)

func (*SalesDB) Lock added in v0.12.1 

func (m *SalesDB) Lock()

func (*SalesDB) MarkAsRead added in v0.1.2 

func (s *SalesDB) MarkAsRead(orderID string) error

func (*SalesDB) MarkAsUnread added in v0.6.1 

func (s *SalesDB) MarkAsUnread(orderID string) error

func (*SalesDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *SalesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*SalesDB) PrepareQuery added in v0.11.1 

func (m *SalesDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*SalesDB) Put added in v0.1.2 

func (s *SalesDB) Put(orderID string, contract pb.RicardianContract, state pb.OrderState, read bool) error

func (*SalesDB) Unlock added in v0.12.1 

func (m *SalesDB) Unlock()

func (*SalesDB) UpdateFunding added in v0.2.0 

func (s *SalesDB) UpdateFunding(orderId string, funded bool, records []*wallet.TransactionRecord) error

func (*SalesDB) UpdateSalesLastDisputeTimeoutNotifiedAt added in v0.12.1 

func (s *SalesDB) UpdateSalesLastDisputeTimeoutNotifiedAt(sales []*repo.SaleRecord) error

UpdateSalesLastDisputeTimeoutNotifiedAt accepts []*repo.SaleRecord and updates each SaleRecord by their OrderID to the set LastDisputeTimeoutNotifiedAt value. The update will be attempted atomically with a rollback attempted in the event of an error.

type SettingsDB 

type SettingsDB struct {
	// contains filtered or unexported fields
}

func (*SettingsDB) BeginTransaction added in v0.11.1 

func (m *SettingsDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*SettingsDB) Delete added in v0.2.4 

func (s *SettingsDB) Delete() error

Delete removes all settings from the database. It's a destructive action that should be used with care.

func (*SettingsDB) ExecuteQuery added in v0.11.1 

func (m *SettingsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*SettingsDB) Get 

func (s *SettingsDB) Get() (repo.SettingsData, error)

func (*SettingsDB) Lock added in v0.12.1 

func (m *SettingsDB) Lock()

func (*SettingsDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *SettingsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*SettingsDB) PrepareQuery added in v0.11.1 

func (m *SettingsDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*SettingsDB) Put 

func (s *SettingsDB) Put(settings repo.SettingsData) error

func (*SettingsDB) Unlock added in v0.12.1 

func (m *SettingsDB) Unlock()

func (*SettingsDB) Update 

func (s *SettingsDB) Update(settings repo.SettingsData) error

type StxoDB 

type StxoDB struct {
	// contains filtered or unexported fields
}

func (*StxoDB) BeginTransaction added in v0.11.1 

func (m *StxoDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*StxoDB) Delete 

func (s *StxoDB) Delete(stxo wallet.Stxo) error

func (*StxoDB) ExecuteQuery added in v0.11.1 

func (m *StxoDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*StxoDB) GetAll 

func (s *StxoDB) GetAll() ([]wallet.Stxo, error)

func (*StxoDB) Lock added in v0.12.1 

func (m *StxoDB) Lock()

func (*StxoDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *StxoDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*StxoDB) PrepareQuery added in v0.11.1 

func (m *StxoDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*StxoDB) Put 

func (s *StxoDB) Put(stxo wallet.Stxo) error

func (*StxoDB) Unlock added in v0.12.1 

func (m *StxoDB) Unlock()

type TxMetadataDB added in v0.5.1 

type TxMetadataDB struct {
	// contains filtered or unexported fields
}

func (*TxMetadataDB) BeginTransaction added in v0.11.1 

func (m *TxMetadataDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*TxMetadataDB) Delete added in v0.5.1 

func (t *TxMetadataDB) Delete(txid string) error

func (*TxMetadataDB) ExecuteQuery added in v0.11.1 

func (m *TxMetadataDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*TxMetadataDB) Get added in v0.5.1 

func (t *TxMetadataDB) Get(txid string) (repo.Metadata, error)

func (*TxMetadataDB) GetAll added in v0.5.1 

func (t *TxMetadataDB) GetAll() (map[string]repo.Metadata, error)

func (*TxMetadataDB) Lock added in v0.12.1 

func (m *TxMetadataDB) Lock()

func (*TxMetadataDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *TxMetadataDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*TxMetadataDB) PrepareQuery added in v0.11.1 

func (m *TxMetadataDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*TxMetadataDB) Put added in v0.5.1 

func (t *TxMetadataDB) Put(m repo.Metadata) error

func (*TxMetadataDB) Unlock added in v0.12.1 

func (m *TxMetadataDB) Unlock()

type TxnsDB 

type TxnsDB struct {
	// contains filtered or unexported fields
}

func (*TxnsDB) BeginTransaction added in v0.11.1 

func (m *TxnsDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*TxnsDB) Delete 

func (t *TxnsDB) Delete(txid *chainhash.Hash) error

func (*TxnsDB) ExecuteQuery added in v0.11.1 

func (m *TxnsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*TxnsDB) Get 

func (t *TxnsDB) Get(txid chainhash.Hash) (wallet.Txn, error)

func (*TxnsDB) GetAll 

func (t *TxnsDB) GetAll(includeWatchOnly bool) ([]wallet.Txn, error)

func (*TxnsDB) Lock added in v0.12.1 

func (m *TxnsDB) Lock()

func (*TxnsDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *TxnsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*TxnsDB) PrepareQuery added in v0.11.1 

func (m *TxnsDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*TxnsDB) Put 

func (t *TxnsDB) Put(raw []byte, txid, value string, height int, timestamp time.Time, watchOnly bool) error

func (*TxnsDB) Unlock added in v0.12.1 

func (m *TxnsDB) Unlock()

func (*TxnsDB) UpdateHeight added in v0.5.4 

func (t *TxnsDB) UpdateHeight(txid chainhash.Hash, height int, timestamp time.Time) error

type UtxoDB 

type UtxoDB struct {
	// contains filtered or unexported fields
}

func (*UtxoDB) BeginTransaction added in v0.11.1 

func (m *UtxoDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*UtxoDB) Delete 

func (u *UtxoDB) Delete(utxo wallet.Utxo) error

func (*UtxoDB) ExecuteQuery added in v0.11.1 

func (m *UtxoDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*UtxoDB) GetAll 

func (u *UtxoDB) GetAll() ([]wallet.Utxo, error)

func (*UtxoDB) Lock added in v0.12.1 

func (m *UtxoDB) Lock()

func (*UtxoDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *UtxoDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*UtxoDB) PrepareQuery added in v0.11.1 

func (m *UtxoDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*UtxoDB) Put 

func (u *UtxoDB) Put(utxo wallet.Utxo) error

func (*UtxoDB) SetWatchOnly added in v0.5.3 

func (u *UtxoDB) SetWatchOnly(utxo wallet.Utxo) error

func (*UtxoDB) Unlock added in v0.12.1 

func (m *UtxoDB) Unlock()

type WatchedScriptsDB added in v0.2.0 

type WatchedScriptsDB struct {
	// contains filtered or unexported fields
}

WatchScriptsDB type definition. Sets a pointer to SQL database and syncs reader/writer mutex-based lock.

func (*WatchedScriptsDB) BeginTransaction added in v0.11.1 

func (m *WatchedScriptsDB) BeginTransaction() (*sql.Tx, error)

Begin returns a *sql.Tx for transactional query support

func (*WatchedScriptsDB) Delete added in v0.2.0 

func (w *WatchedScriptsDB) Delete(scriptPubKey []byte) error

WatchedScriptsDB Delete method deletes a watched script based on its public key.

func (*WatchedScriptsDB) ExecuteQuery added in v0.11.1 

func (m *WatchedScriptsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)

ExecuteQuery returns the *sql.Result for the executed query without returning Rows

func (*WatchedScriptsDB) GetAll added in v0.2.0 

func (w *WatchedScriptsDB) GetAll() ([][]byte, error)

WatchedScriptsDB GetAll() method Returns all watched script public keys.

func (*WatchedScriptsDB) Lock added in v0.12.1 

func (m *WatchedScriptsDB) Lock()

func (*WatchedScriptsDB) PrepareAndExecuteQuery added in v0.11.1 

func (m *WatchedScriptsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)

PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query

func (*WatchedScriptsDB) PrepareQuery added in v0.11.1 

func (m *WatchedScriptsDB) PrepareQuery(query string) (*sql.Stmt, error)

PrepareQuery returns a *sql.Stmt to the wrapped DB

func (*WatchedScriptsDB) Put added in v0.2.0 

func (w *WatchedScriptsDB) Put(scriptPubKey []byte) error

WatchdScriptsDB Put method insert and replace operations based on watched script public keys.

func (*WatchedScriptsDB) PutAll added in v0.13.8 

func (w *WatchedScriptsDB) PutAll(scriptPubKeys [][]byte) error

func (*WatchedScriptsDB) Unlock added in v0.12.1 

func (m *WatchedScriptsDB) Unlock()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.