db

Jul 15, 2020

Changes in this version

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

type ConfigDB

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

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

+ func (m *ConfigDB) Lock()

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

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

+ func (m *ConfigDB) Unlock()

+ type DB struct

+ Lock *sync.Mutex

+ SqlDB *sql.DB

+ type MessagesDB struct

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

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

+ func (m *MessagesDB) Lock()

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

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

+ func (m *MessagesDB) Unlock()

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

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

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

+ func (o *MessagesDB) Put(messageID, orderID string, mType pb.Message_MessageType, peerID string, ...) error

type PurchasesDB

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

type SQLiteDatastore

+ func (d *SQLiteDatastore) DB() *DB

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

type SalesDB

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

type WatchedScriptsDB

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

Aug 15, 2018

Changes in this version

+ 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) 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) repo.SpentTransactionOutputStore

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

+ func NewTransactionStore(db *sql.DB, lock *sync.Mutex) repo.TransactionStore

+ func NewUnspentTransactionStore(db *sql.DB, lock *sync.Mutex) repo.UnspentTransactionOutputStore

+ func NewWatchedScriptStore(db *sql.DB, lock *sync.Mutex) repo.WatchedScriptStore

+ func PaymentCoinForContract(contract *pb.RicardianContract) string

type CasesDB

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

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

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

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

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

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

+ func (m *CasesDB) Lock()

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

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

+ func (m *CasesDB) Unlock()

type ChatDB

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

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

+ func (m *ChatDB) Lock()

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

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

+ func (m *ChatDB) Unlock()

type CouponDB

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

+ func (m *CouponDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *CouponDB) Unlock()

type FollowerDB

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

+ func (m *FollowerDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *FollowerDB) Unlock()

type FollowingDB

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

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

+ 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 (m *FollowingDB) Unlock()

type InventoryDB

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

+ func (m *InventoryDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *InventoryDB) Unlock()

type KeysDB

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

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

+ func (m *KeysDB) Lock()

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

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

+ func (m *KeysDB) Unlock()

type ModeratedDB

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

+ func (m *ModeratedDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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) Unlock()

type NotficationsDB

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

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

+ func (m *NotficationsDB) Lock()

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

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

+ func (m *NotficationsDB) Unlock()

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

type OfflineMessagesDB

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

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

+ 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 (m *OfflineMessagesDB) Unlock()

type PointersDB

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

+ func (m *PointersDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *PointersDB) Unlock()

type PurchasesDB

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

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

+ func (m *PurchasesDB) Lock()

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

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

+ func (m *PurchasesDB) Unlock()

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

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

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

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

type SQLiteDatastore

+ func NewSQLiteDatastore(db *sql.DB, l *sync.Mutex) *SQLiteDatastore

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

type SalesDB

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

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

+ func (m *SalesDB) Lock()

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

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

+ func (m *SalesDB) Unlock()

+ func (s *SalesDB) GetNeedsResync() ([]repo.UnfundedSale, error)

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

+ func (s *SalesDB) SetNeedsResync(orderId string, needsResync bool) error

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

type SettingsDB

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

+ func (m *SettingsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *SettingsDB) Unlock()

type StxoDB

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

+ func (m *StxoDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *StxoDB) Unlock()

type TxMetadataDB

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

+ func (m *TxMetadataDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *TxMetadataDB) Unlock()

type TxnsDB

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

+ func (m *TxnsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *TxnsDB) Unlock()

type UtxoDB

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

+ func (m *UtxoDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *UtxoDB) Unlock()

type WatchedScriptsDB

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

+ func (m *WatchedScriptsDB) ExecuteQuery(query string, args ...interface{}) (sql.Result, 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 (m *WatchedScriptsDB) Unlock()

Oct 13, 2017

Changes in this version

type CasesDB

+ func (c *CasesDB) Count() int

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

type ConfigDB

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

type KeysDB

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

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

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

type NotficationsDB

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

+ func (n *NotficationsDB) MarkAllAsRead() error

type OfflineMessagesDB

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

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

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

type PurchasesDB

+ func (p *PurchasesDB) Count() int

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

type SQLiteDatastore

+ func (d *SQLiteDatastore) Ping() error

type SalesDB

+ func (s *SalesDB) Count() int

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

Apr 21, 2017

Changes in this version

+ var SettingsNotSetError error = errors.New("Settings not set")

+ type CasesDB struct

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

+ func (c *CasesDB) GetAll(offsetId string, limit int) ([]repo.Case, error)

+ func (c *CasesDB) GetCaseMetadata(caseID string) (buyerContract, vendorContract *pb.RicardianContract, ...)

+ func (c *CasesDB) GetPayoutDetails(caseID string) (buyerContract, vendorContract *pb.RicardianContract, ...)

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

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

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

+ func (c *CasesDB) UpdateBuyerInfo(caseID string, buyerContract *pb.RicardianContract, ...) error

+ func (c *CasesDB) UpdateVendorInfo(caseID string, vendorContract *pb.RicardianContract, ...) error

+ type ChatDB struct

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

+ func (c *ChatDB) DeleteMessage(msgID string) 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 (c *ChatDB) MarkAsRead(peerID string, subject string, outgoing bool, messageId string) (string, bool, error)

+ func (c *ChatDB) Put(messageId string, peerId string, subject string, message string, ...) error

+ type CouponDB struct

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

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

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

type KeysDB

+ func (k *KeysDB) GetKeyForScript(scriptPubKey []byte) (*btcec.PrivateKey, error)

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

+ type ModeratedDB struct

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

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

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

+ type NotficationsDB struct

+ func (n *NotficationsDB) Delete(notifID int) error

+ func (n *NotficationsDB) GetAll(offsetId int, limit int) []notif.Notification

+ func (n *NotficationsDB) MarkAsRead(notifID int) error

+ func (n *NotficationsDB) Put(notification notif.Data, timestamp time.Time) error

type PointersDB

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

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

type SQLiteDatastore

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

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

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

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

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

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

type SettingsDB

+ func (s *SettingsDB) Delete() error

+ type TxMetadataDB struct

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

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

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

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

type TxnsDB

+ func (t *TxnsDB) UpdateHeight(txid chainhash.Hash, height int) error

type UtxoDB

+ func (u *UtxoDB) SetWatchOnly(utxo spvwallet.Utxo) error

Oct 27, 2016

Changes in this version

+ func Decrypt() error

+ func Encrypt() error

+ type ConfigDB struct

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

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

+ func (c *ConfigDB) Init(mnemonic string, identityKey []byte, password string) error

+ func (c *ConfigDB) IsEncrypted() bool

+ type FollowerDB struct

+ func (f *FollowerDB) Count() int

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

+ func (f *FollowerDB) FollowsMe(peerId string) bool

+ func (f *FollowerDB) Get(offsetId string, limit int) ([]string, error)

+ func (f *FollowerDB) Put(follower string) error

+ type FollowingDB struct

+ func (f *FollowingDB) Count() int

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

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

+ func (f *FollowingDB) IsFollowing(peerId string) bool

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

+ type InventoryDB struct

+ func (i *InventoryDB) Delete(path string) error

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

+ func (i *InventoryDB) Get(slug string) (map[string]int, error)

+ func (i *InventoryDB) GetAll() (map[string]int, error)

+ func (i *InventoryDB) GetSpecific(path string) (int, error)

+ func (i *InventoryDB) Put(slug string, count int) error

+ type KeysDB struct

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

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

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

+ func (k *KeysDB) GetPathForScript(scriptPubKey []byte) (spvwallet.KeyPath, error)

+ func (k *KeysDB) GetUnused(purpose spvwallet.KeyPurpose) (int, error)

+ func (k *KeysDB) MarkKeyAsUsed(scriptPubKey []byte) error

+ func (k *KeysDB) Put(scriptPubKey []byte, keyPath spvwallet.KeyPath) error

+ type OfflineMessagesDB struct

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

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

+ type PointersDB struct

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

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

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

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

+ type PurchasesDB struct

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

+ func (p *PurchasesDB) GetAll() ([]string, error)

+ func (p *PurchasesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*spvwallet.TransactionRecord, ...)

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

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

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

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

+ type SQLiteDatastore struct

+ func Create(repoPath, password string, testnet bool) (*SQLiteDatastore, error)

+ func (d *SQLiteDatastore) Close()

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

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

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

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

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

+ func (d *SQLiteDatastore) Keys() spvwallet.Keys

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

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

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

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

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

+ func (d *SQLiteDatastore) State() spvwallet.State

+ func (d *SQLiteDatastore) Stxos() spvwallet.Stxos

+ func (d *SQLiteDatastore) Txns() spvwallet.Txns

+ func (d *SQLiteDatastore) Utxos() spvwallet.Utxos

+ func (d *SQLiteDatastore) WatchedScripts() spvwallet.WatchedScripts

+ type SalesDB struct

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

+ func (s *SalesDB) GetAll() ([]string, error)

+ func (s *SalesDB) GetByOrderId(orderId string) (*pb.RicardianContract, pb.OrderState, bool, []*spvwallet.TransactionRecord, ...)

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

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

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

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

+ type SettingsDB struct

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

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

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

+ type StateDB struct

+ func (s *StateDB) Get(key string) (string, error)

+ func (s *StateDB) Put(key, value string) error

+ type StxoDB struct

+ func (s *StxoDB) Delete(stxo spvwallet.Stxo) error

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

+ func (s *StxoDB) Put(stxo spvwallet.Stxo) error

+ type TxnsDB struct

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

+ func (t *TxnsDB) Get(txid chainhash.Hash) (*wire.MsgTx, error)

+ func (t *TxnsDB) GetAll() ([]*wire.MsgTx, error)

+ func (t *TxnsDB) Put(txn *wire.MsgTx) error

+ type UtxoDB struct

+ func (u *UtxoDB) Delete(utxo spvwallet.Utxo) error

+ func (u *UtxoDB) Freeze(utxo spvwallet.Utxo) error

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

+ func (u *UtxoDB) Put(utxo spvwallet.Utxo) error

+ type WatchedScriptsDB struct

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

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

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