Documentation ¶
Index ¶
- Variables
- func CoinTypeForContract(contract *pb.RicardianContract) string
- func NewCaseStore(db *sql.DB, lock *sync.Mutex) repo.CaseStore
- func NewChatStore(db *sql.DB, lock *sync.Mutex) repo.ChatStore
- func NewConfigurationStore(db *sql.DB, lock *sync.Mutex) repo.ConfigurationStore
- func NewCouponStore(db *sql.DB, lock *sync.Mutex) repo.CouponStore
- func NewFollowerStore(db *sql.DB, lock *sync.Mutex) repo.FollowerStore
- func NewFollowingStore(db *sql.DB, lock *sync.Mutex) repo.FollowingStore
- func NewInventoryStore(db *sql.DB, lock *sync.Mutex) repo.InventoryStore
- func NewKeyStore(db *sql.DB, lock *sync.Mutex, coinType wallet.CoinType) repo.KeyStore
- func NewModeratedStore(db *sql.DB, lock *sync.Mutex) repo.ModeratedStore
- func NewNotificationStore(db *sql.DB, lock *sync.Mutex) repo.NotificationStore
- func NewOfflineMessageStore(db *sql.DB, lock *sync.Mutex) repo.OfflineMessageStore
- func NewPointerStore(db *sql.DB, lock *sync.Mutex) repo.PointerStore
- func NewPurchaseStore(db *sql.DB, lock *sync.Mutex) repo.PurchaseStore
- func NewSaleStore(db *sql.DB, lock *sync.Mutex) repo.SaleStore
- func NewSpentTransactionStore(db *sql.DB, lock *sync.Mutex, coinType wallet.CoinType) repo.SpentTransactionOutputStore
- func NewTransactionMetadataStore(db *sql.DB, lock *sync.Mutex) repo.TransactionMetadataStore
- func NewTransactionStore(db *sql.DB, lock *sync.Mutex, coinType wallet.CoinType) repo.TransactionStore
- func NewUnspentTransactionStore(db *sql.DB, lock *sync.Mutex, coinType wallet.CoinType) repo.UnspentTransactionOutputStore
- func NewWatchedScriptStore(db *sql.DB, lock *sync.Mutex, coinType wallet.CoinType) repo.WatchedScriptStore
- func PaymentCoinForContract(contract *pb.RicardianContract) string
- type CasesDB
- func (m *CasesDB) BeginTransaction() (*sql.Tx, error)
- func (c *CasesDB) Count() int
- func (c *CasesDB) Delete(orderID string) error
- func (m *CasesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (c *CasesDB) GetAll(stateFilter []pb.OrderState, searchTerm string, sortByAscending bool, ...) ([]repo.Case, int, error)
- func (c *CasesDB) GetByCaseID(caseID string) (*repo.DisputeCaseRecord, error)
- func (c *CasesDB) GetCaseMetadata(caseID string) (buyerContract, vendorContract *pb.RicardianContract, ...)
- func (c *CasesDB) GetDisputesForDisputeExpiryNotification() ([]*repo.DisputeCaseRecord, error)
- func (m *CasesDB) Lock()
- func (c *CasesDB) MarkAsClosed(caseID string, resolution *pb.DisputeResolution) error
- func (c *CasesDB) MarkAsRead(orderID string) error
- func (c *CasesDB) MarkAsUnread(orderID string) error
- func (m *CasesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *CasesDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (c *CasesDB) Put(caseID string, state pb.OrderState, buyerOpened bool, claim string, ...) error
- func (c *CasesDB) PutRecord(dispute *repo.DisputeCaseRecord) error
- func (m *CasesDB) Unlock()
- func (c *CasesDB) UpdateBuyerInfo(caseID string, buyerContract *pb.RicardianContract, ...) error
- func (c *CasesDB) UpdateDisputesLastDisputeExpiryNotifiedAt(disputeCases []*repo.DisputeCaseRecord) error
- func (c *CasesDB) UpdateVendorInfo(caseID string, vendorContract *pb.RicardianContract, ...) error
- type ChatDB
- func (m *ChatDB) BeginTransaction() (*sql.Tx, error)
- func (c *ChatDB) DeleteConversation(peerId string) error
- func (c *ChatDB) DeleteMessage(msgID string) error
- func (m *ChatDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (c *ChatDB) GetConversations() []repo.ChatConversation
- func (c *ChatDB) GetMessages(peerID string, subject string, offsetId string, limit int) []repo.ChatMessage
- func (c *ChatDB) GetUnreadCount(subject string) (int, error)
- func (m *ChatDB) Lock()
- func (c *ChatDB) MarkAsRead(peerID string, subject string, outgoing bool, messageId string) (string, bool, error)
- func (m *ChatDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *ChatDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (c *ChatDB) Put(messageId string, peerId string, subject string, message string, ...) error
- func (m *ChatDB) Unlock()
- type ConfigDB
- func (c *ConfigDB) GetCreationDate() (time.Time, error)
- func (c *ConfigDB) GetIdentityKey() ([]byte, error)
- func (c *ConfigDB) GetMnemonic() (string, error)
- func (c *ConfigDB) Init(mnemonic string, identityKey []byte, password string, creationDate time.Time) error
- func (c *ConfigDB) IsEncrypted() bool
- type CouponDB
- func (m *CouponDB) BeginTransaction() (*sql.Tx, error)
- func (c *CouponDB) Delete(slug string) error
- func (m *CouponDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (c *CouponDB) Get(slug string) ([]repo.Coupon, error)
- func (m *CouponDB) Lock()
- func (m *CouponDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *CouponDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (c *CouponDB) Put(coupons []repo.Coupon) error
- func (m *CouponDB) Unlock()
- type FollowerDB
- func (m *FollowerDB) BeginTransaction() (*sql.Tx, error)
- func (f *FollowerDB) Count() int
- func (f *FollowerDB) Delete(follower string) error
- func (m *FollowerDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (f *FollowerDB) FollowsMe(peerId string) bool
- func (f *FollowerDB) Get(offsetId string, limit int) ([]repo.Follower, error)
- func (m *FollowerDB) Lock()
- func (m *FollowerDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *FollowerDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (f *FollowerDB) Put(follower string, proof []byte) error
- func (m *FollowerDB) Unlock()
- type FollowingDB
- func (m *FollowingDB) BeginTransaction() (*sql.Tx, error)
- func (f *FollowingDB) Count() int
- func (f *FollowingDB) Delete(follower string) error
- func (m *FollowingDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (f *FollowingDB) Get(offsetId string, limit int) ([]string, error)
- func (f *FollowingDB) IsFollowing(peerId string) bool
- func (m *FollowingDB) Lock()
- func (m *FollowingDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *FollowingDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (f *FollowingDB) Put(follower string) error
- func (m *FollowingDB) Unlock()
- type InventoryDB
- func (m *InventoryDB) BeginTransaction() (*sql.Tx, error)
- func (i *InventoryDB) Delete(slug string, variantIndex int) error
- func (i *InventoryDB) DeleteAll(slug string) error
- func (m *InventoryDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (i *InventoryDB) Get(slug string) (map[int]int64, error)
- func (i *InventoryDB) GetAll() (map[string]map[int]int64, error)
- func (i *InventoryDB) GetSpecific(slug string, variantIndex int) (int64, error)
- func (m *InventoryDB) Lock()
- func (m *InventoryDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *InventoryDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (i *InventoryDB) Put(slug string, variantIndex int, count int64) error
- func (m *InventoryDB) Unlock()
- type KeysDB
- func (m *KeysDB) BeginTransaction() (*sql.Tx, error)
- func (m *KeysDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (k *KeysDB) GetAll() ([]wallet.KeyPath, error)
- func (k *KeysDB) GetImported() ([]*btcec.PrivateKey, error)
- func (k *KeysDB) GetKey(scriptAddress []byte) (*btcec.PrivateKey, error)
- func (k *KeysDB) GetLastKeyIndex(purpose wallet.KeyPurpose) (int, bool, error)
- func (k *KeysDB) GetLookaheadWindows() map[wallet.KeyPurpose]int
- func (k *KeysDB) GetPathForKey(scriptAddress []byte) (wallet.KeyPath, error)
- func (k *KeysDB) GetUnused(purpose wallet.KeyPurpose) ([]int, error)
- func (k *KeysDB) ImportKey(scriptAddress []byte, key *btcec.PrivateKey) error
- func (m *KeysDB) Lock()
- func (k *KeysDB) MarkKeyAsUsed(scriptAddress []byte) error
- func (m *KeysDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *KeysDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (k *KeysDB) Put(scriptAddress []byte, keyPath wallet.KeyPath) error
- func (m *KeysDB) Unlock()
- type ModeratedDB
- func (m *ModeratedDB) BeginTransaction() (*sql.Tx, error)
- func (m *ModeratedDB) Delete(follower string) error
- func (m *ModeratedDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (m *ModeratedDB) Get(offsetId string, limit int) ([]string, error)
- func (m *ModeratedDB) Lock()
- func (m *ModeratedDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *ModeratedDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (m *ModeratedDB) Put(peerId string) error
- func (m *ModeratedDB) Unlock()
- type NotficationsDB
- func (m *NotficationsDB) BeginTransaction() (*sql.Tx, error)
- func (n *NotficationsDB) Delete(notifID string) error
- func (m *NotficationsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (n *NotficationsDB) GetAll(offsetId string, limit int, typeFilter []string) ([]*repo.Notification, int, error)
- func (n *NotficationsDB) GetUnreadCount() (int, error)
- func (m *NotficationsDB) Lock()
- func (n *NotficationsDB) MarkAllAsRead() error
- func (n *NotficationsDB) MarkAsRead(notifID string) error
- func (m *NotficationsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *NotficationsDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (n *NotficationsDB) PutRecord(record *repo.Notification) error
- func (m *NotficationsDB) Unlock()
- type OfflineMessagesDB
- func (m *OfflineMessagesDB) BeginTransaction() (*sql.Tx, error)
- func (o *OfflineMessagesDB) DeleteMessage(url string) error
- func (m *OfflineMessagesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (o *OfflineMessagesDB) GetMessages() (map[string][]byte, error)
- func (o *OfflineMessagesDB) Has(url string) bool
- func (m *OfflineMessagesDB) Lock()
- func (m *OfflineMessagesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *OfflineMessagesDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (o *OfflineMessagesDB) Put(url string) error
- func (o *OfflineMessagesDB) SetMessage(url string, message []byte) error
- func (m *OfflineMessagesDB) Unlock()
- type PointersDB
- func (m *PointersDB) BeginTransaction() (*sql.Tx, error)
- func (p *PointersDB) Delete(id peer.ID) error
- func (p *PointersDB) DeleteAll(purpose ipfs.Purpose) error
- func (m *PointersDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (p *PointersDB) Get(id peer.ID) (ipfs.Pointer, error)
- func (p *PointersDB) GetAll() ([]ipfs.Pointer, error)
- func (p *PointersDB) GetByPurpose(purpose ipfs.Purpose) ([]ipfs.Pointer, error)
- func (m *PointersDB) Lock()
- func (m *PointersDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *PointersDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (p *PointersDB) Put(pointer ipfs.Pointer) error
- func (m *PointersDB) Unlock()
- type PurchasesDB
- func (m *PurchasesDB) BeginTransaction() (*sql.Tx, error)
- func (p *PurchasesDB) Count() int
- func (p *PurchasesDB) Delete(orderID string) error
- func (m *PurchasesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (p *PurchasesDB) GetAll(stateFilter []pb.OrderState, searchTerm string, sortByAscending bool, ...) ([]repo.Purchase, int, error)
- func (p *PurchasesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, bool, ...)
- func (p *PurchasesDB) GetByPaymentAddress(addr btc.Address) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, error)
- func (p *PurchasesDB) GetPurchasesForDisputeExpiryNotification() ([]*repo.PurchaseRecord, error)
- func (p *PurchasesDB) GetPurchasesForDisputeTimeoutNotification() ([]*repo.PurchaseRecord, error)
- func (m *PurchasesDB) Lock()
- func (p *PurchasesDB) MarkAsRead(orderID string) error
- func (p *PurchasesDB) MarkAsUnread(orderID string) error
- func (m *PurchasesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *PurchasesDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (p *PurchasesDB) Put(orderID string, contract pb.RicardianContract, state pb.OrderState, read bool) error
- func (m *PurchasesDB) Unlock()
- func (p *PurchasesDB) UpdateFunding(orderId string, funded bool, records []*wallet.TransactionRecord) error
- func (p *PurchasesDB) UpdatePurchasesLastDisputeExpiryNotifiedAt(purchases []*repo.PurchaseRecord) error
- func (p *PurchasesDB) UpdatePurchasesLastDisputeTimeoutNotifiedAt(purchases []*repo.PurchaseRecord) error
- type SQLiteDatastore
- func (d *SQLiteDatastore) Cases() repo.CaseStore
- func (d *SQLiteDatastore) Chat() repo.ChatStore
- func (d *SQLiteDatastore) Close()
- func (d *SQLiteDatastore) Config() repo.Config
- func (d *SQLiteDatastore) Copy(dbPath string, password string) error
- func (d *SQLiteDatastore) Coupons() repo.CouponStore
- func (d *SQLiteDatastore) Followers() repo.FollowerStore
- func (d *SQLiteDatastore) Following() repo.FollowingStore
- func (s *SQLiteDatastore) InitTables(password string) error
- func (d *SQLiteDatastore) Inventory() repo.InventoryStore
- func (d *SQLiteDatastore) Keys() wallet.Keys
- func (d *SQLiteDatastore) ModeratedStores() repo.ModeratedStore
- func (d *SQLiteDatastore) Notifications() repo.NotificationStore
- func (d *SQLiteDatastore) OfflineMessages() repo.OfflineMessageStore
- func (d *SQLiteDatastore) Ping() error
- func (d *SQLiteDatastore) Pointers() repo.PointerStore
- func (d *SQLiteDatastore) Purchases() repo.PurchaseStore
- func (d *SQLiteDatastore) Sales() repo.SaleStore
- func (d *SQLiteDatastore) Settings() repo.ConfigurationStore
- func (d *SQLiteDatastore) Stxos() wallet.Stxos
- func (d *SQLiteDatastore) TxMetadata() repo.TransactionMetadataStore
- func (d *SQLiteDatastore) Txns() wallet.Txns
- func (d *SQLiteDatastore) Utxos() wallet.Utxos
- func (d *SQLiteDatastore) WatchedScripts() wallet.WatchedScripts
- type SalesDB
- func (m *SalesDB) BeginTransaction() (*sql.Tx, error)
- func (s *SalesDB) Count() int
- func (s *SalesDB) Delete(orderID string) error
- func (m *SalesDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (s *SalesDB) GetAll(stateFilter []pb.OrderState, searchTerm string, sortByAscending bool, ...) ([]repo.Sale, int, error)
- func (s *SalesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, bool, ...)
- func (s *SalesDB) GetByPaymentAddress(addr btc.Address) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, error)
- func (s *SalesDB) GetNeedsResync() ([]repo.UnfundedSale, error)
- func (s *SalesDB) GetSalesForDisputeTimeoutNotification() ([]*repo.SaleRecord, error)
- func (m *SalesDB) Lock()
- func (s *SalesDB) MarkAsRead(orderID string) error
- func (s *SalesDB) MarkAsUnread(orderID string) error
- func (m *SalesDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *SalesDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (s *SalesDB) Put(orderID string, contract pb.RicardianContract, state pb.OrderState, read bool) error
- func (s *SalesDB) SetNeedsResync(orderId string, needsResync bool) error
- func (m *SalesDB) Unlock()
- func (s *SalesDB) UpdateFunding(orderId string, funded bool, records []*wallet.TransactionRecord) error
- func (s *SalesDB) UpdateSalesLastDisputeTimeoutNotifiedAt(sales []*repo.SaleRecord) error
- type SettingsDB
- func (m *SettingsDB) BeginTransaction() (*sql.Tx, error)
- func (s *SettingsDB) Delete() error
- func (m *SettingsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (s *SettingsDB) Get() (repo.SettingsData, error)
- func (m *SettingsDB) Lock()
- func (m *SettingsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *SettingsDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (s *SettingsDB) Put(settings repo.SettingsData) error
- func (m *SettingsDB) Unlock()
- func (s *SettingsDB) Update(settings repo.SettingsData) error
- type StxoDB
- func (m *StxoDB) BeginTransaction() (*sql.Tx, error)
- func (s *StxoDB) Delete(stxo wallet.Stxo) error
- func (m *StxoDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (s *StxoDB) GetAll() ([]wallet.Stxo, error)
- func (m *StxoDB) Lock()
- func (m *StxoDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *StxoDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (s *StxoDB) Put(stxo wallet.Stxo) error
- func (m *StxoDB) Unlock()
- type TxMetadataDB
- func (m *TxMetadataDB) BeginTransaction() (*sql.Tx, error)
- func (t *TxMetadataDB) Delete(txid string) error
- func (m *TxMetadataDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (t *TxMetadataDB) Get(txid string) (repo.Metadata, error)
- func (t *TxMetadataDB) GetAll() (map[string]repo.Metadata, error)
- func (m *TxMetadataDB) Lock()
- func (m *TxMetadataDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *TxMetadataDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (t *TxMetadataDB) Put(m repo.Metadata) error
- func (m *TxMetadataDB) Unlock()
- type TxnsDB
- func (m *TxnsDB) BeginTransaction() (*sql.Tx, error)
- func (t *TxnsDB) Delete(txid *chainhash.Hash) error
- func (m *TxnsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (t *TxnsDB) Get(txid chainhash.Hash) (wallet.Txn, error)
- func (t *TxnsDB) GetAll(includeWatchOnly bool) ([]wallet.Txn, error)
- func (m *TxnsDB) Lock()
- func (m *TxnsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *TxnsDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (t *TxnsDB) Put(raw []byte, txid string, value, height int, timestamp time.Time, ...) error
- func (m *TxnsDB) Unlock()
- func (t *TxnsDB) UpdateHeight(txid chainhash.Hash, height int, timestamp time.Time) error
- type UtxoDB
- func (m *UtxoDB) BeginTransaction() (*sql.Tx, error)
- func (u *UtxoDB) Delete(utxo wallet.Utxo) error
- func (m *UtxoDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (u *UtxoDB) GetAll() ([]wallet.Utxo, error)
- func (m *UtxoDB) Lock()
- func (m *UtxoDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *UtxoDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (u *UtxoDB) Put(utxo wallet.Utxo) error
- func (u *UtxoDB) SetWatchOnly(utxo wallet.Utxo) error
- func (m *UtxoDB) Unlock()
- type WatchedScriptsDB
- func (m *WatchedScriptsDB) BeginTransaction() (*sql.Tx, error)
- func (w *WatchedScriptsDB) Delete(scriptPubKey []byte) error
- func (m *WatchedScriptsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, error)
- func (w *WatchedScriptsDB) GetAll() ([][]byte, error)
- func (m *WatchedScriptsDB) Lock()
- func (m *WatchedScriptsDB) PrepareAndExecuteQuery(query string, args ...interface{}) (*sql.Rows, error)
- func (m *WatchedScriptsDB) PrepareQuery(query string) (*sql.Stmt, error)
- func (w *WatchedScriptsDB) Put(scriptPubKey []byte) error
- func (m *WatchedScriptsDB) Unlock()
Constants ¶
This section is empty.
Variables ¶
var SettingsNotSetError error = errors.New("Settings not set")
Functions ¶
func CoinTypeForContract ¶ added in v0.12.1
func CoinTypeForContract(contract *pb.RicardianContract) string
func NewConfigurationStore ¶ added in v0.11.1
func NewCouponStore ¶ added in v0.11.1
func NewFollowerStore ¶ added in v0.11.1
func NewFollowingStore ¶ added in v0.11.1
func NewInventoryStore ¶ added in v0.11.1
func NewKeyStore ¶ added in v0.11.1
func NewModeratedStore ¶ added in v0.11.1
func NewNotificationStore ¶ added in v0.11.1
func NewOfflineMessageStore ¶ added in v0.11.1
func NewPointerStore ¶ added in v0.11.1
func NewPurchaseStore ¶ added in v0.11.1
func NewSpentTransactionStore ¶ added in v0.11.1
func NewTransactionMetadataStore ¶ added in v0.11.1
func NewTransactionStore ¶ added in v0.11.1
func NewUnspentTransactionStore ¶ added in v0.11.1
func NewWatchedScriptStore ¶ added in v0.11.1
func PaymentCoinForContract ¶ added in v0.12.1
func PaymentCoinForContract(contract *pb.RicardianContract) string
Types ¶
type CasesDB ¶ added in v0.3.0
type CasesDB struct {
// contains filtered or unexported fields
}
func (*CasesDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*CasesDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
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) 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 (*CasesDB) MarkAsUnread ¶ added in v0.6.1
func (*CasesDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*CasesDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
func (*CasesDB) PutRecord ¶ added in v0.12.1
func (c *CasesDB) PutRecord(dispute *repo.DisputeCaseRecord) error
func (*CasesDB) UpdateBuyerInfo ¶ added in v0.3.0
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.
type ChatDB ¶ added in v0.3.1
type ChatDB struct {
// contains filtered or unexported fields
}
func (*ChatDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*ChatDB) DeleteConversation ¶ added in v0.3.1
func (*ChatDB) DeleteMessage ¶ added in v0.3.1
func (*ChatDB) ExecuteQuery ¶ added in v0.11.1
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 (*ChatDB) GetUnreadCount ¶ added in v0.5.1
func (*ChatDB) MarkAsRead ¶ added in v0.3.1
func (*ChatDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*ChatDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type ConfigDB ¶
type ConfigDB struct {
// contains filtered or unexported fields
}
func (*ConfigDB) GetCreationDate ¶ added in v0.6.4
func (*ConfigDB) GetIdentityKey ¶
func (*ConfigDB) GetMnemonic ¶
func (*ConfigDB) IsEncrypted ¶
type CouponDB ¶ added in v0.5.0
type CouponDB struct {
// contains filtered or unexported fields
}
func (*CouponDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*CouponDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*CouponDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*CouponDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type FollowerDB ¶
type FollowerDB struct {
// contains filtered or unexported fields
}
func (*FollowerDB) BeginTransaction ¶ added in v0.11.1
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
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) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*FollowerDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type FollowingDB ¶
type FollowingDB struct {
// contains filtered or unexported fields
}
func (*FollowingDB) BeginTransaction ¶ added in v0.11.1
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
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*FollowingDB) IsFollowing ¶ added in v0.2.0
func (f *FollowingDB) IsFollowing(peerId string) bool
func (*FollowingDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*FollowingDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
func (*FollowingDB) Put ¶
func (f *FollowingDB) Put(follower string) error
type InventoryDB ¶
type InventoryDB struct {
// contains filtered or unexported fields
}
func (*InventoryDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*InventoryDB) DeleteAll ¶ added in v0.1.1
func (i *InventoryDB) DeleteAll(slug string) error
func (*InventoryDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*InventoryDB) GetSpecific ¶ added in v0.1.1
func (i *InventoryDB) GetSpecific(slug string, variantIndex int) (int64, error)
func (*InventoryDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*InventoryDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type KeysDB ¶
type KeysDB struct {
// contains filtered or unexported fields
}
func (*KeysDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*KeysDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
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 (*KeysDB) GetLookaheadWindows ¶
func (*KeysDB) GetPathForKey ¶ added in v0.7.0
func (*KeysDB) ImportKey ¶ added in v0.4.2
func (k *KeysDB) ImportKey(scriptAddress []byte, key *btcec.PrivateKey) error
func (*KeysDB) MarkKeyAsUsed ¶
func (*KeysDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*KeysDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type ModeratedDB ¶ added in v0.5.1
type ModeratedDB struct {
// contains filtered or unexported fields
}
func (*ModeratedDB) BeginTransaction ¶ added in v0.11.1
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
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) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*ModeratedDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
func (*ModeratedDB) Put ¶ added in v0.5.1
func (m *ModeratedDB) Put(peerId string) error
type NotficationsDB ¶ added in v0.3.1
type NotficationsDB struct {
// contains filtered or unexported fields
}
func (*NotficationsDB) BeginTransaction ¶ added in v0.11.1
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
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) 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
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
type OfflineMessagesDB ¶
type OfflineMessagesDB struct {
// contains filtered or unexported fields
}
func (*OfflineMessagesDB) BeginTransaction ¶ added in v0.11.1
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
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) 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
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
type PointersDB ¶
type PointersDB struct {
// contains filtered or unexported fields
}
func (*PointersDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*PointersDB) DeleteAll ¶ added in v0.1.1
func (p *PointersDB) DeleteAll(purpose ipfs.Purpose) error
func (*PointersDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*PointersDB) GetByPurpose ¶ added in v0.5.3
func (*PointersDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*PointersDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type PurchasesDB ¶ added in v0.1.2
type PurchasesDB struct {
// contains filtered or unexported fields
}
func (*PurchasesDB) BeginTransaction ¶ added in v0.11.1
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
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*PurchasesDB) GetByOrderId ¶ added in v0.2.0
func (p *PurchasesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, bool, 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) 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
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*PurchasesDB) PrepareQuery ¶ added in v0.11.1
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) 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 wallet.CoinType) (*SQLiteDatastore, error)
func NewSQLiteDatastore ¶ added in v0.12.1
func NewSQLiteDatastore(db *sql.DB, l *sync.Mutex, coinType wallet.CoinType) *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) Coupons ¶ added in v0.5.0
func (d *SQLiteDatastore) Coupons() repo.CouponStore
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) 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
Begin returns a *sql.Tx for transactional query support
func (*SalesDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*SalesDB) GetByOrderId ¶ added in v0.2.0
func (s *SalesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*wallet.TransactionRecord, bool, 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) GetNeedsResync ¶ added in v0.9.4
func (s *SalesDB) GetNeedsResync() ([]repo.UnfundedSale, 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) MarkAsRead ¶ added in v0.1.2
func (*SalesDB) MarkAsUnread ¶ added in v0.6.1
func (*SalesDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*SalesDB) PrepareQuery ¶ added in v0.11.1
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) SetNeedsResync ¶ added in v0.9.4
func (*SalesDB) UpdateFunding ¶ added in v0.2.0
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
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
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*SettingsDB) Get ¶
func (s *SettingsDB) Get() (repo.SettingsData, error)
func (*SettingsDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*SettingsDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
func (*SettingsDB) Put ¶
func (s *SettingsDB) Put(settings repo.SettingsData) error
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
Begin returns a *sql.Tx for transactional query support
func (*StxoDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*StxoDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*StxoDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type TxMetadataDB ¶ added in v0.5.1
type TxMetadataDB struct {
// contains filtered or unexported fields
}
func (*TxMetadataDB) BeginTransaction ¶ added in v0.11.1
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
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) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*TxMetadataDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type TxnsDB ¶
type TxnsDB struct {
// contains filtered or unexported fields
}
func (*TxnsDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*TxnsDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*TxnsDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*TxnsDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
type UtxoDB ¶
type UtxoDB struct {
// contains filtered or unexported fields
}
func (*UtxoDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*UtxoDB) ExecuteQuery ¶ added in v0.11.1
ExecuteQuery returns the *sql.Result for the executed query without returning Rows
func (*UtxoDB) PrepareAndExecuteQuery ¶ added in v0.11.1
PrepareAndExecuteQuery returns the resulting *sql.Rows for the executed query
func (*UtxoDB) PrepareQuery ¶ added in v0.11.1
PrepareQuery returns a *sql.Stmt to the wrapped DB
func (*UtxoDB) SetWatchOnly ¶ added in v0.5.3
type WatchedScriptsDB ¶ added in v0.2.0
type WatchedScriptsDB struct {
// contains filtered or unexported fields
}
func (*WatchedScriptsDB) BeginTransaction ¶ added in v0.11.1
Begin returns a *sql.Tx for transactional query support
func (*WatchedScriptsDB) Delete ¶ added in v0.2.0
func (w *WatchedScriptsDB) Delete(scriptPubKey []byte) error
func (*WatchedScriptsDB) ExecuteQuery ¶ added in v0.11.1
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)
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
PrepareQuery returns a *sql.Stmt to the wrapped DB
func (*WatchedScriptsDB) Put ¶ added in v0.2.0
func (w *WatchedScriptsDB) Put(scriptPubKey []byte) error