db

package
v0.0.0-...-8eaf68a Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2017 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func Decrypt 

func Decrypt() error

Create a temp database, read the encrypted database into it then replace the encrypted database

func Encrypt 

func Encrypt() error

Create a temp encrypted database, read the unencrypted database into it then replace the unencrypted database

Types

type CasesDB 

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

func (*CasesDB) Delete 

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

func (*CasesDB) GetAll 

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

func (*CasesDB) GetCaseMetadata 

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) GetPayoutDetails 

func (c *CasesDB) GetPayoutDetails(caseID string) (buyerContract, vendorContract *pb.RicardianContract, buyerPayoutAddress, vendorPayoutAddress string, buyerOutpoints, vendorOutpoints []*pb.Outpoint, state pb.OrderState, err error)

func (*CasesDB) MarkAsClosed 

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

func (*CasesDB) MarkAsRead 

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

func (*CasesDB) Put 

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

func (*CasesDB) UpdateBuyerInfo 

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

func (*CasesDB) UpdateVendorInfo 

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

type ChatDB 

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

func (*ChatDB) DeleteConversation 

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

func (*ChatDB) DeleteMessage 

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

func (*ChatDB) GetConversations 

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

func (*ChatDB) GetMessages 

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

func (*ChatDB) GetUnreadCount 

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

func (*ChatDB) MarkAsRead 

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

func (*ChatDB) Put 

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

type ConfigDB 

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

func (*ConfigDB) GetIdentityKey 

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

func (*ConfigDB) GetMnemonic 

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

func (*ConfigDB) Init 

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

func (*ConfigDB) IsEncrypted 

func (c *ConfigDB) IsEncrypted() bool

type CouponDB 

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

func (*CouponDB) Delete 

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

func (*CouponDB) Get 

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

func (*CouponDB) Put 

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

type FollowerDB 

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

func (*FollowerDB) Count 

func (f *FollowerDB) Count() int

func (*FollowerDB) Delete 

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

func (*FollowerDB) FollowsMe 

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

func (*FollowerDB) Get 

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

func (*FollowerDB) Put 

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

type FollowingDB 

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

func (*FollowingDB) Count 

func (f *FollowingDB) Count() int

func (*FollowingDB) Delete 

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

func (*FollowingDB) Get 

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

func (*FollowingDB) IsFollowing 

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

func (*FollowingDB) Put 

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

type InventoryDB 

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

func (*InventoryDB) Delete 

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

func (*InventoryDB) DeleteAll 

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

func (*InventoryDB) Get 

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

func (*InventoryDB) GetAll 

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

func (*InventoryDB) GetSpecific 

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

func (*InventoryDB) Put 

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

type KeysDB 

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

func (*KeysDB) GetAll 

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

func (*KeysDB) GetKeyForScript 

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

func (*KeysDB) GetLastKeyIndex 

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

func (*KeysDB) GetLookaheadWindows 

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

func (*KeysDB) GetPathForScript 

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

func (*KeysDB) GetUnused 

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

func (*KeysDB) ImportKey 

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

func (*KeysDB) MarkKeyAsUsed 

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

func (*KeysDB) Put 

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

type ModeratedDB 

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

func (*ModeratedDB) Delete 

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

func (*ModeratedDB) Get 

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

func (*ModeratedDB) Put 

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

type NotficationsDB 

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

func (*NotficationsDB) Delete 

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

func (*NotficationsDB) GetAll 

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

func (*NotficationsDB) MarkAsRead 

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

func (*NotficationsDB) Put 

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

type OfflineMessagesDB 

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

func (*OfflineMessagesDB) Has 

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

func (*OfflineMessagesDB) Put 

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

type PointersDB 

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

func (*PointersDB) Delete 

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

func (*PointersDB) DeleteAll 

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

func (*PointersDB) Get 

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

func (*PointersDB) GetAll 

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

func (*PointersDB) GetByPurpose 

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

func (*PointersDB) Put 

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

type PurchasesDB 

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

func (*PurchasesDB) Delete 

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

func (*PurchasesDB) GetAll 

func (p *PurchasesDB) GetAll(offsetId string, limit int) ([]repo.Purchase, error)

func (*PurchasesDB) GetByOrderId 

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

func (*PurchasesDB) GetByPaymentAddress 

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

func (*PurchasesDB) MarkAsRead 

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

func (*PurchasesDB) Put 

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

func (*PurchasesDB) UpdateFunding 

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

type SQLiteDatastore 

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

func Create 

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

func (*SQLiteDatastore) Cases 

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

func (*SQLiteDatastore) Chat 

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

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 

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

func (*SQLiteDatastore) Followers 

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

func (*SQLiteDatastore) Following 

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

func (*SQLiteDatastore) Inventory 

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

func (*SQLiteDatastore) Keys 

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

func (*SQLiteDatastore) ModeratedStores 

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

func (*SQLiteDatastore) Notifications 

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

func (*SQLiteDatastore) OfflineMessages 

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

func (*SQLiteDatastore) Pointers 

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

func (*SQLiteDatastore) Purchases 

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

func (*SQLiteDatastore) Sales 

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

func (*SQLiteDatastore) Settings 

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

func (*SQLiteDatastore) Stxos 

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

func (*SQLiteDatastore) TxMetadata 

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

func (*SQLiteDatastore) Txns 

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

func (*SQLiteDatastore) Utxos 

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

func (*SQLiteDatastore) WatchedScripts 

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

type SalesDB 

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

func (*SalesDB) Delete 

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

func (*SalesDB) GetAll 

func (s *SalesDB) GetAll(offsetId string, limit int) ([]repo.Sale, error)

func (*SalesDB) GetByOrderId 

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

func (*SalesDB) GetByPaymentAddress 

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

func (*SalesDB) MarkAsRead 

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

func (*SalesDB) Put 

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

func (*SalesDB) UpdateFunding 

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

type SettingsDB 

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

func (*SettingsDB) Delete 

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) Get 

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

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) Delete 

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

func (*StxoDB) GetAll 

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

func (*StxoDB) Put 

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

type TxMetadataDB 

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

func (*TxMetadataDB) Delete 

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

func (*TxMetadataDB) Get 

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

func (*TxMetadataDB) GetAll 

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

func (*TxMetadataDB) Put 

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

type TxnsDB 

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

func (*TxnsDB) Delete 

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

func (*TxnsDB) Get 

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

func (*TxnsDB) GetAll 

func (t *TxnsDB) GetAll() ([]spvwallet.Txn, error)

func (*TxnsDB) MarkAsDead 

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

func (*TxnsDB) Put 

func (t *TxnsDB) Put(txn *wire.MsgTx, value, height int, timestamp time.Time) error

type UtxoDB 

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

func (*UtxoDB) Delete 

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

func (*UtxoDB) Freeze 

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

func (*UtxoDB) GetAll 

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

func (*UtxoDB) Put 

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

type WatchedScriptsDB 

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

func (*WatchedScriptsDB) Delete 

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

func (*WatchedScriptsDB) GetAll 

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

func (*WatchedScriptsDB) Put 

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

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.