database

package
v0.0.0-...-5fdeb2f Latest Latest
Warning

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

Go to latest
Published: Sep 10, 2020 License: LGPL-3.0 Imports: 20 Imported by: 0

Documentation

Overview

Package database is a generated GoMock package.

Index

Constants

View Source
const (
	// GasPledgeTotalKey : how many EMPOW is pledged
	GasPledgeTotalKey = "gt"
	// GasLimitKey : how much gas can be generated max per EMPOW
	GasLimitKey = "gl"
	// GasUpdateTimeKey : when the gas state is refreshed last time, for internal use
	GasUpdateTimeKey = "gu"
	// GasStockKey : how much gas is there when last time refreshed
	GasStockKey = "gs"
	// GasPledgeKey : i pledge how much coins for others
	GasPledgeKey = "gp"
	// TransferableGasKey :
	TransferableGasKey = "tg"
	// TransferableGasQuotaKey :
	TransferableGasQuotaKey = "tq"
)
View Source
const (
	IntPrefix       = "i"
	StringPrefix    = "s"
	NilPrefix       = "n"
	BoolPrefix      = "b"
	JSONPrefix      = "j"
	MapHolderPrefix = "@"
	FixPointPrefix  = "f"
)

const prefixs

View Source
const ApplicationSeparator = "@"

ApplicationSeparator separator of value

View Source
const BasicPrefix = "b-"

BasicPrefix prefix of basic types

View Source
const ContractPrefix = "c-"

ContractPrefix ...

View Source
const EMPOWRatio int64 = 100000000

EMPOWRatio ...

View Source
const GasContractName = "gas.empow"

GasContractName name of basic token contract

View Source
const (
	GasDecimal = 2
)

decimals of gas

View Source
const GasFulfillSeconds int64 = 2 * 24 * 3600

GasFulfillSeconds it takes 2 days to fulfill the gas buffer.

View Source
const MapPrefix = "m-"

MapPrefix prefix of map key

View Source
const RAMContractName = "ram.empow"

RAMContractName name of basic token contract

View Source
const Separator = "-"

Separator separator of map key

View Source
const (
	// StateTable name
	StateTable = "state"
)
View Source
const Token721ContractName = "token721.empow"

Token721ContractName name of basic token contract

View Source
const TokenContractName = "token.empow"

TokenContractName name of basic token contract

View Source
const VoteContractName = "vote.empow"

VoteContractName name of common vote contract

View Source
const VoteProducerContractName = "vote_producer.empow"

VoteProducerContractName name of vote producer contract

Variables

View Source
var GasImmediateReward = &common.Fixed{Value: 100000 * 100, Decimal: 2}

GasImmediateReward immediate reward per EMPOW

View Source
var GasIncreaseRate = GasLimit.Sub(GasImmediateReward).Div(GasFulfillSeconds)

GasIncreaseRate gas increase per EMPOW per second

View Source
var GasLimit = &common.Fixed{Value: 300000 * 100, Decimal: 2}

GasLimit gas limit per EMPOW

View Source
var GasMinPledgeOfUser = &common.Fixed{Value: 10 * EMPOWRatio, Decimal: 8}

GasMinPledgeOfUser Each user must pledge a minimum amount of EMPOW

View Source
var GasMinPledgePerAction = &common.Fixed{Value: 1 * EMPOWRatio, Decimal: 8}

GasMinPledgePerAction One must (un)pledge more than 1 EMPOW

Functions

func EmptyGas

func EmptyGas() *common.Fixed

EmptyGas ...

func LoadBlockhead

func LoadBlockhead(path string) (*block.BlockHead, error)

LoadBlockhead load block info as block.BlockHead from json file

func LoadTxInfo

func LoadTxInfo(path string) (*tx.Tx, error)

LoadTxInfo load tx info as tx.Tx from json file

func Marshal

func Marshal(in interface{}, extras ...string) (string, error)

Marshal marshal go types to value string

func MustMarshal

func MustMarshal(in interface{}, extra ...string) string

MustMarshal marshal go types to value string, panic on error

func MustUnmarshal

func MustUnmarshal(o string) interface{}

MustUnmarshal unmarshal value string to go types, panic on error

func MustUnmarshalWithExtra

func MustUnmarshalWithExtra(o string) (interface{}, string)

MustUnmarshalWithExtra unmarshal value string to go types, panic on error

func NewBatchVisitor

func NewBatchVisitor(lruDB *LRU) (*Visitor, Mapper)

NewBatchVisitor get visitor with mapper

func Unmarshal

func Unmarshal(o string) interface{}

Unmarshal unmarshal value string to go types

func UnmarshalWithExtra

func UnmarshalWithExtra(o string) (interface{}, string)

UnmarshalWithExtra unmarshal value string to go types

Types

type Access

type Access int

Access enum of type of access

const (
	Read Access = iota
	Write
)

const .

type AccountRAMInfo

type AccountRAMInfo struct {
	// Used ...
	Used int64
	// Available ...
	Available int64
	// Total ...
	Total int64
}

AccountRAMInfo ...

type AccountVoteInfo

type AccountVoteInfo struct {
	Option       string
	Votes        *common.Fixed
	ClearedVotes *common.Fixed
}

AccountVoteInfo ...

type BasicHandler

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

BasicHandler handler of basic type

func (*BasicHandler) Del

func (m *BasicHandler) Del(key string)

Del del key, if key is nil do nothing

func (*BasicHandler) Get

func (m *BasicHandler) Get(key string) (value string)

Get get v from k

func (*BasicHandler) Has

func (m *BasicHandler) Has(key string) bool

Has determine if k exist

func (*BasicHandler) Put

func (m *BasicHandler) Put(key, value string)

Put put to k-v

type ContractHandler

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

ContractHandler ...

func (*ContractHandler) Contract

func (m *ContractHandler) Contract(key string) (c *contract.Contract)

Contract get contract by key

func (*ContractHandler) DelContract

func (m *ContractHandler) DelContract(key string)

DelContract delete contract, if contract not exist, do nothing

func (*ContractHandler) HasContract

func (m *ContractHandler) HasContract(key string) bool

HasContract determine if contract existed

func (*ContractHandler) SetContract

func (m *ContractHandler) SetContract(contract *contract.Contract)

SetContract set contract to storage, will not do check

type DelaytxHandler

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

DelaytxHandler handler of delay tx

func (*DelaytxHandler) DelDelaytx

func (m *DelaytxHandler) DelDelaytx(txHash string)

DelDelaytx deletes the delaytx hash.

func (*DelaytxHandler) GetDelaytx

func (m *DelaytxHandler) GetDelaytx(txHash string) (string, string)

GetDelaytx gets the delay tx's publisher and deferTxHash.

func (*DelaytxHandler) HasDelaytx

func (m *DelaytxHandler) HasDelaytx(txHash string) bool

HasDelaytx checks whether the delaytx exists.

func (*DelaytxHandler) StoreDelaytx

func (m *DelaytxHandler) StoreDelaytx(txHash, publisher, deferTxHash string)

StoreDelaytx stores delaytx hash.

type FreezeItem

type FreezeItem struct {
	Amount int64
	Ftime  int64
}

FreezeItem represents freezed balance, will unfreeze after Ftime

type FreezeItemFixed

type FreezeItemFixed struct {
	Amount common.Fixed
	Ftime  int64
}

FreezeItemFixed ...

type GasHandler

type GasHandler struct {
	BasicHandler
	MapHandler
}

GasHandler easy to get balance of token.empow

func (*GasHandler) ChangeTGas

func (g *GasHandler) ChangeTGas(name string, delta *common.Fixed)

ChangeTGas ...

func (*GasHandler) GasLimit

func (g *GasHandler) GasLimit(name string) *common.Fixed

GasLimit ...

func (*GasHandler) GasPledge

func (g *GasHandler) GasPledge(name string, pledger string) *common.Fixed

GasPledge ...

func (*GasHandler) GasPledgeTotal

func (g *GasHandler) GasPledgeTotal(name string) *common.Fixed

GasPledgeTotal ...

func (*GasHandler) GasStock

func (g *GasHandler) GasStock(name string) *common.Fixed

GasStock `gasStock` means the gas amount at last update time.

func (*GasHandler) GasUpdateTime

func (g *GasHandler) GasUpdateTime(name string) int64

GasUpdateTime ...

func (*GasHandler) PGasAtTime

func (g *GasHandler) PGasAtTime(name string, t int64) (result *common.Fixed)

PGasAtTime return pledge gas at given time. It is min(limit, last_updated_gas + time_since_last_updated * increase_speed)

func (*GasHandler) PledgerInfo

func (g *GasHandler) PledgerInfo(name string) []PledgerInfo

PledgerInfo get I pledged how much coins for others

func (*GasHandler) TGas

func (g *GasHandler) TGas(name string) *common.Fixed

TGas ...

func (*GasHandler) TotalGasAtTime

func (g *GasHandler) TotalGasAtTime(name string, t int64) (result *common.Fixed)

TotalGasAtTime return total gas at given time.. It is pgas + tgas

type IMultiValue

type IMultiValue interface {
	Get(table string, key string) (string, error)
	Put(table string, key string, value string) error
	Del(table string, key string) error
	Has(table string, key string) (bool, error)
}

IMultiValue mvcc database interface

type LRU

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

LRU lru cache

func NewBatchVisitorRoot

func NewBatchVisitorRoot(cacheLength int, cb IMultiValue, rules *version.Rules) *LRU

NewBatchVisitorRoot get LRU to next step

func NewLRU

func NewLRU(length int, db database) *LRU

NewLRU make a new lru

func (*LRU) Del

func (m *LRU) Del(key string)

Del delete key from cache

func (*LRU) Get

func (m *LRU) Get(key string) (value string)

Get get from cache

func (*LRU) Has

func (m *LRU) Has(key string) bool

Has if key exist

func (*LRU) Purge

func (m *LRU) Purge()

Purge delete all keys

func (*LRU) Put

func (m *LRU) Put(key, value string)

Put put kv to cache

func (*LRU) Rules

func (m *LRU) Rules() *version.Rules

Rules get rules of db

type MapHandler

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

MapHandler handler of map

func (*MapHandler) MDel

func (m *MapHandler) MDel(key, field string)

MDel delete field of map o(1)

func (*MapHandler) MGet

func (m *MapHandler) MGet(key, field string) (value string)

MGet get value from storage o(1)

func (*MapHandler) MHas

func (m *MapHandler) MHas(key, field string) bool

MHas if has map and field

func (*MapHandler) MKeys

func (m *MapHandler) MKeys(key string) (fields []string)

MKeys list fields of map o(1)

func (*MapHandler) MPut

func (m *MapHandler) MPut(key, field, value string)

MPut put value in kfv storage o(1)

type Mapper

type Mapper interface {
	Map() map[string]Access
}

Mapper generator of conflict map

type MockIMultiValue

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

MockIMultiValue is a mock of IMultiValue interface

func NewMockIMultiValue

func NewMockIMultiValue(ctrl *gomock.Controller) *MockIMultiValue

NewMockIMultiValue creates a new mock instance

func (*MockIMultiValue) Commit

func (m *MockIMultiValue) Commit()

Commit mocks base method

func (*MockIMultiValue) Del

func (m *MockIMultiValue) Del(arg0, arg1 string) error

Del mocks base method

func (*MockIMultiValue) EXPECT

EXPECT returns an object that allows the caller to indicate expected use

func (*MockIMultiValue) Get

func (m *MockIMultiValue) Get(arg0, arg1 string) (string, error)

Get mocks base method

func (*MockIMultiValue) Has

func (m *MockIMultiValue) Has(arg0, arg1 string) (bool, error)

Has mocks base method

func (*MockIMultiValue) Keys

func (m *MockIMultiValue) Keys(arg0, arg1 string) ([]string, error)

Keys mocks base method

func (*MockIMultiValue) Put

func (m *MockIMultiValue) Put(arg0, arg1, arg2 string) error

Put mocks base method

func (*MockIMultiValue) Rollback

func (m *MockIMultiValue) Rollback()

Rollback mocks base method

type MockIMultiValueMockRecorder

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

MockIMultiValueMockRecorder is the mock recorder for MockIMultiValue

func (*MockIMultiValueMockRecorder) Commit

func (mr *MockIMultiValueMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit

func (*MockIMultiValueMockRecorder) Del

func (mr *MockIMultiValueMockRecorder) Del(arg0, arg1 interface{}) *gomock.Call

Del indicates an expected call of Del

func (*MockIMultiValueMockRecorder) Get

func (mr *MockIMultiValueMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockIMultiValueMockRecorder) Has

func (mr *MockIMultiValueMockRecorder) Has(arg0, arg1 interface{}) *gomock.Call

Has indicates an expected call of Has

func (*MockIMultiValueMockRecorder) Keys

func (mr *MockIMultiValueMockRecorder) Keys(arg0, arg1 interface{}) *gomock.Call

Keys indicates an expected call of Keys

func (*MockIMultiValueMockRecorder) Put

func (mr *MockIMultiValueMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call

Put indicates an expected call of Put

func (*MockIMultiValueMockRecorder) Rollback

func (mr *MockIMultiValueMockRecorder) Rollback() *gomock.Call

Rollback indicates an expected call of Rollback

type Mode

type Mode int

Mode of this record

const (
	Default Mode = iota
	Delete
)

const enum of Mode

type PledgerInfo

type PledgerInfo struct {
	Pledger string
	Amount  *common.Fixed
}

PledgerInfo ...

type ProducerVoteInfo

type ProducerVoteInfo struct {
	Pubkey     string
	Loc        string
	URL        string
	NetID      string
	IsProducer bool
	Status     string
	Online     bool
}

ProducerVoteInfo ...

type RAMHandler

type RAMHandler struct {
	BasicHandler
}

RAMHandler easy to get balance of token.empow

func (*RAMHandler) BuyPrice

func (r *RAMHandler) BuyPrice() float64

BuyPrice ...

func (*RAMHandler) ChangeUsedRAMInfo

func (r *RAMHandler) ChangeUsedRAMInfo(acc string, delta int64)

ChangeUsedRAMInfo ...

func (*RAMHandler) GetAccountRAMInfo

func (r *RAMHandler) GetAccountRAMInfo(acc string) *AccountRAMInfo

GetAccountRAMInfo ...

func (*RAMHandler) LeftRAM

func (r *RAMHandler) LeftRAM() int64

LeftRAM ...

func (*RAMHandler) SellPrice

func (r *RAMHandler) SellPrice() float64

SellPrice ...

func (*RAMHandler) TotalRAM

func (r *RAMHandler) TotalRAM() int64

TotalRAM ...

func (*RAMHandler) UsedRAM

func (r *RAMHandler) UsedRAM() int64

UsedRAM ...

type Record

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

Record of one access

type RollbackHandler

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

RollbackHandler rollback delegate

func (*RollbackHandler) Commit

func (m *RollbackHandler) Commit()

Commit commit a MVCC version

func (*RollbackHandler) Rollback

func (m *RollbackHandler) Rollback()

Rollback rollback to newest MVCC version

type SerializedJSON

type SerializedJSON []byte

SerializedJSON type of Serialized json

type SimpleDB

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

SimpleDB implements simple database interface

func NewDatabase

func NewDatabase() *SimpleDB

NewDatabase returns a SimpleDB with empty data and system contract

func NewDatabaseFromPath

func NewDatabaseFromPath(path string) *SimpleDB

NewDatabaseFromPath returns a SimpleDB with data loaded from json file

func (*SimpleDB) AddSystem

func (d *SimpleDB) AddSystem(path string)

AddSystem load system contract and data from json file

func (*SimpleDB) Commit

func (d *SimpleDB) Commit()

Commit do nothing

func (*SimpleDB) Del

func (d *SimpleDB) Del(table string, key string) error

Del delete key from db

func (*SimpleDB) Get

func (d *SimpleDB) Get(table string, key string) (string, error)

Get key-value from db with marshal

func (*SimpleDB) Has

func (d *SimpleDB) Has(table string, key string) (bool, error)

Has return if key exists in db

func (*SimpleDB) Keys

func (d *SimpleDB) Keys(table string, prefix string) ([]string, error)

Keys do nothing

func (*SimpleDB) Load

func (d *SimpleDB) Load(path string) error

Load load db data from json file

func (*SimpleDB) Put

func (d *SimpleDB) Put(table string, key string, value string) error

Put key-value into db with unmarshal

func (*SimpleDB) Rollback

func (d *SimpleDB) Rollback()

Rollback do nothing

func (*SimpleDB) Save

func (d *SimpleDB) Save(path string) error

Save save db data to json file

type Token721Handler

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

Token721Handler easy to get balance of token.empow

func (*Token721Handler) Token721Balance

func (m *Token721Handler) Token721Balance(tokenName, acc string) int64

Token721Balance get token balance of acc

func (*Token721Handler) Token721IDList

func (m *Token721Handler) Token721IDList(tokenName, acc string) []string

Token721IDList get token balance of acc

func (*Token721Handler) Token721Metadata

func (m *Token721Handler) Token721Metadata(tokenName, tokenID string) (string, error)

Token721Metadata get token balance of acc

func (*Token721Handler) Token721Owner

func (m *Token721Handler) Token721Owner(tokenName, tokenID string) (string, error)

Token721Owner get token owner of tokenID

type TokenHandler

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

TokenHandler easy to get balance of token.empow

func (*TokenHandler) AllFreezedTokenBalance

func (m *TokenHandler) AllFreezedTokenBalance(tokenName, acc string) []FreezeItem

AllFreezedTokenBalance get freezed token balance of acc

func (*TokenHandler) AllFreezedTokenBalanceFixed

func (m *TokenHandler) AllFreezedTokenBalanceFixed(tokenName, acc string) []FreezeItemFixed

AllFreezedTokenBalanceFixed get freezed token balance of acc

func (*TokenHandler) Decimal

func (m *TokenHandler) Decimal(tokenName string) int

Decimal get decimal in token info

func (*TokenHandler) FreezedTokenBalance

func (m *TokenHandler) FreezedTokenBalance(tokenName, acc string) int64

FreezedTokenBalance get freezed token balance of acc

func (*TokenHandler) FreezedTokenBalanceFixed

func (m *TokenHandler) FreezedTokenBalanceFixed(tokenName, acc string) *common.Fixed

FreezedTokenBalanceFixed get token balance of acc

func (*TokenHandler) SetTokenBalance

func (m *TokenHandler) SetTokenBalance(tokenName, acc string, amount int64)

SetTokenBalance set token balance of acc, used for test

func (*TokenHandler) SetTokenBalanceFixed

func (m *TokenHandler) SetTokenBalanceFixed(tokenName, acc string, amountStr string)

SetTokenBalanceFixed set token balance of acc, used for test

func (*TokenHandler) TokenBalance

func (m *TokenHandler) TokenBalance(tokenName, acc string) int64

TokenBalance get token balance of acc

func (*TokenHandler) TokenBalanceFixed

func (m *TokenHandler) TokenBalanceFixed(tokenName, acc string) *common.Fixed

TokenBalanceFixed get token balance of acc

type Visitor

Visitor combine of every handler, to be api of database

func NewVisitor

func NewVisitor(cacheLength int, cb IMultiValue, rules *version.Rules) *Visitor

NewVisitor get a visitor of a DB, with cache length determined

type VoteHandler

type VoteHandler struct {
	BasicHandler
	MapHandler
}

VoteHandler easy to get info of vote.empow and vote_producer.empow

func (*VoteHandler) GetAccountVoteInfo

func (v *VoteHandler) GetAccountVoteInfo(account string) []*AccountVoteInfo

GetAccountVoteInfo ...

func (*VoteHandler) GetProducerVoteInfo

func (v *VoteHandler) GetProducerVoteInfo(account string) (*ProducerVoteInfo, error)

GetProducerVoteInfo ...

func (*VoteHandler) GetProducerVotes

func (v *VoteHandler) GetProducerVotes(account string) (*common.Fixed, error)

GetProducerVotes ...

type Watcher

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

Watcher of db access

func NewWatcher

func NewWatcher(db database) *Watcher

NewWatcher ...

func (*Watcher) Del

func (r *Watcher) Del(key string)

Del ...

func (*Watcher) Get

func (r *Watcher) Get(key string) (value string)

Get record and get

func (*Watcher) Has

func (r *Watcher) Has(key string) bool

Has ...

func (*Watcher) Map

func (r *Watcher) Map() map[string]Access

Map map the access of this watcher

func (*Watcher) Put

func (r *Watcher) Put(key, value string)

Put ...

type WriteCache

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

WriteCache ...

func NewWriteCache

func NewWriteCache(db database) *WriteCache

NewWriteCache ...

func (*WriteCache) Del

func (w *WriteCache) Del(key string)

Del ...

func (*WriteCache) Drop

func (w *WriteCache) Drop()

Drop ...

func (*WriteCache) Flush

func (w *WriteCache) Flush()

Flush ...

func (*WriteCache) Get

func (w *WriteCache) Get(key string) (value string)

Get ...

func (*WriteCache) Has

func (w *WriteCache) Has(key string) bool

Has ...

func (*WriteCache) Put

func (w *WriteCache) Put(key, value string)

Put ...

func (*WriteCache) Rules

func (w *WriteCache) Rules() *version.Rules

Rules ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL