state

package

Go to main page

Versions in this module

v1

v1.10.1

Nov 30, 2023

v1.10.0

Nov 9, 2023

Changes in this version

type State

+ func (v *State) CommittedHash() []byte

+ func (v *State) PrepareCommit() ([]byte, error)

v1.9.0

Sep 8, 2023

Changes in this version

+ const SIKROOT_HYSTERESIS_BLOCKS

+ const TreeSIK

+ var ErrRegisteredValidSIK = fmt.Errorf("address already has a valid sik")

+ var ErrSIKAlreadyInvalid = fmt.Errorf("sik is already invalidated")

+ var ErrSIKDelete = fmt.Errorf("error deleting new SIK")

+ var ErrSIKGet = fmt.Errorf("error getting SIK")

+ var ErrSIKIterate = fmt.Errorf("error iterating over SIKs")

+ var ErrSIKNotFound = fmt.Errorf("SIK not found")

+ var ErrSIKRootsDelete = fmt.Errorf("error deleting old SIK roots")

+ var ErrSIKRootsGet = fmt.Errorf("error getting current valid SIK root")

+ var ErrSIKRootsSet = fmt.Errorf("error setting new SIK roots")

+ var ErrSIKSet = fmt.Errorf("error setting new SIK")

+ var ErrSIKSubTree = fmt.Errorf("error getting SIK deep sub tree")

+ func ExportNoStateDB(w io.Writer, reader *NoState) (uint32, error)

+ func ImportNoStateDB(r io.Reader, db *NoState) error

+ type BeginBlock struct

+ DataHash []byte

+ Height int64

+ Time time.Time

+ type DBPair struct

+ Key []byte

+ Value []byte

+ type DiskSnapshotInfo struct

+ Height uint32

+ ModTime time.Time

+ Size int64

type EventListener

+ OnBeginBlock func(BeginBlock)

+ OnCensusUpdate func(pid, censusRoot []byte, censusURI string)

+ OnSpendTokens func(addr []byte, txType models.TxType, cost uint64, reference string)

+ type NoState struct

+ func (ns *NoState) Delete(key []byte) error

+ func (ns *NoState) Get(key []byte) ([]byte, error)

+ func (ns *NoState) Has(key []byte) (bool, error)

+ func (ns *NoState) Iterate(prefix []byte, callback func(k, v []byte) bool) error

+ func (ns *NoState) Set(key, value []byte) error

+ type ProcessBlockRegistry struct

+ func (pbr *ProcessBlockRegistry) DeleteStartBlock(pid []byte) error

+ func (pbr *ProcessBlockRegistry) MaxEndBlock(fromBlock uint32) (uint32, error)

+ func (pbr *ProcessBlockRegistry) MinStartBlock(fromBlock uint32) (uint32, error)

+ func (pbr *ProcessBlockRegistry) SetStartBlock(pid []byte, startBlock uint32) error

+ type SIK []byte

+ func (s SIK) DecodeInvalidatedHeight() uint32

+ func (s SIK) InvalidateAt(height uint32) SIK

+ func (s SIK) String() string

+ func (s SIK) Valid() bool

type SnapshotHeader

+ NoStateSize uint32

type State

+ ProcessBlockRegistry *ProcessBlockRegistry

+ func (s *State) NoState(withTxLock bool) *NoState

+ func (v *State) AssignSIKToElection(pid []byte, address common.Address) error

+ func (v *State) CountAccounts(committed bool) (uint64, error)

+ func (v *State) CountRegisterSIK(pid []byte) (uint32, error)

+ func (v *State) CountSIKs(committed bool) (uint64, error)

+ func (v *State) ExpiredSIKRoot(candidateRoot []byte) bool

+ func (v *State) FetchValidSIKRoots() error

+ func (v *State) IncreaseRegisterSIKCounter(pid []byte) error

+ func (v *State) InvalidateSIK(address common.Address) error

+ func (v *State) OnBeginBlock(bb BeginBlock)

+ func (v *State) PurgeRegisterSIK(pid []byte) error

+ func (v *State) PurgeSIKsByElection(pid []byte) error

+ func (v *State) SIKFromAddress(address common.Address) (SIK, error)

+ func (v *State) SIKGenProof(address common.Address) ([]byte, []byte, error)

+ func (v *State) SIKRoot() ([]byte, error)

+ func (v *State) SetAddressSIK(address common.Address, newSIK SIK) error

+ func (v *State) UpdateSIKRoots() error

+ func (v *State) ValidSIKRoots() [][]byte

type StateSnapshot

+ func (s *StateSnapshot) SetNoStateSize(size uint32)

v1.8.0

May 31, 2023

Changes in this version

type State

+ ElectionPriceCalc *electionprice.Calculator

+ func (s *State) CountTotalVotes(committed bool) (uint64, error)

+ func (v *State) NetworkCapacity() (uint64, error)

+ func (v *State) SetElectionPriceCalc() error

+ func (v *State) SetNetworkCapacity(capacity uint64) error

+ func (v *State) SetTxBaseCost(txType models.TxType, cost uint64) error

+ func (v *State) TxBaseCost(txType models.TxType, committed bool) (uint64, error)

+ type VotePackage struct

+ Nonce string

+ Votes []int

+ func NewVotePackage(votes []int) *VotePackage

+ func (vp *VotePackage) Decode(data []byte) error

+ func (vp *VotePackage) Encode() ([]byte, error)

v1.7.0

Apr 11, 2023

Changes in this version

type VoterID

+ func NewVoterID(voterIDType VoterIDType, key []byte) VoterID

+ func (v VoterID) Bytes() []byte

type VoterIDType

+ const VoterIDTypeZkSnark

v1.6.0

Mar 21, 2023

Changes in this version

type State

+ func (v *State) MaxProcessSize() (uint64, error)

+ func (v *State) SetMaxProcessSize(size uint64) error

v1.5.2

Mar 20, 2023

v1.5.1

Mar 16, 2023

v1.5.0

Mar 13, 2023

v1.4.0

Mar 10, 2023

Changes in this version

+ const ChildTreeCensus

+ const ChildTreeCensusPoseidon

+ const ChildTreePreRegisterNullifiers

+ const ChildTreeVotes

+ const TreeAccounts

+ const TreeExtra

+ const TreeFaucet

+ const TreeOracles

+ const TreeProcess

+ const TreeValidators

+ var BurnAddress = common.HexToAddress("0xffffffffffffffffffffffffffffffffffffffff")

+ var CensusOrigins = map[models.CensusOrigin]CensusProperties

+ var ChildTrees = map[string]*statedb.TreeNonSingletonConfig

+ var ErrAccountAlreadyExists = fmt.Errorf("account already exists")

+ var ErrAccountBalanceZero = fmt.Errorf("zero balance account not valid")

+ var ErrAccountNonceInvalid = fmt.Errorf("invalid account nonce")

+ var ErrAccountNotExist = fmt.Errorf("account does not exist")

+ var ErrBalanceOverflow = fmt.Errorf("balance overflow")

+ var ErrInvalidURILength = fmt.Errorf("invalid URI length")

+ var ErrNotEnoughBalance = fmt.Errorf("not enough balance to transfer")

+ var ErrProcessChildLeafRootUnknown = fmt.Errorf("process child leaf root is unkown")

+ var ErrProcessNotFound = fmt.Errorf("process not found")

+ var ErrTxCostNotFound = fmt.Errorf("transaction cost is not set")

+ var ErrVoteNotFound = fmt.Errorf("vote not found")

+ var MainTrees = map[string]statedb.TreeConfig

+ var TxTypeCostToStateKey = map[models.TxType]string

+ func CheckDuplicateDelegates(delegates [][]byte, addr *ethcommon.Address) error

+ func GenerateNullifier(address ethcommon.Address, processID []byte) []byte

+ func GetFriendlyResults(results []*models.QuestionResult) [][]*types.BigInt

+ func StateChildTreeCfg(name string) *statedb.TreeNonSingletonConfig

+ func StateParentChildTreeCfg(parent, child string, key []byte) (statedb.TreeConfig, statedb.TreeConfig)

+ func StateTreeCfg(name string) statedb.TreeConfig

+ type Account struct

+ func (a *Account) AddDelegate(addr common.Address) error

+ func (a *Account) DelDelegate(addr common.Address) error

+ func (a *Account) IsDelegate(addr common.Address) bool

+ func (a *Account) Marshal() ([]byte, error)

+ func (a *Account) Transfer(dest *Account, amount uint64) error

+ func (a *Account) Unmarshal(data []byte) error

+ type CensusProperties struct

+ AllowCensusUpdate bool

+ Name string

+ NeedsDownload bool

+ NeedsIndexSlot bool

+ NeedsURI bool

+ WeightedSupport bool

+ type ErrHaltVochain struct

+ func (e ErrHaltVochain) Error() string

+ func (e ErrHaltVochain) Unwrap() error

+ type EventListener interface

+ Commit func(height uint32) (err error)

+ OnCancel func(pid []byte, txIndex int32)

+ OnNewTx func(tx *vochaintx.VochainTx, blockHeight uint32, txIndex int32)

+ OnProcess func(pid, eid []byte, censusRoot, censusURI string, txIndex int32)

+ OnProcessKeys func(pid []byte, encryptionPub string, txIndex int32)

+ OnProcessResults func(pid []byte, results *models.ProcessResult, txIndex int32)

+ OnProcessStatusChange func(pid []byte, status models.ProcessStatus, txIndex int32)

+ OnProcessesStart func(pids [][]byte)

+ OnRevealKeys func(pid []byte, encryptionPriv string, txIndex int32)

+ OnSetAccount func(addr []byte, account *Account)

+ OnTransferTokens func(tx *vochaintx.TokenTransfer)

+ OnVote func(vote *Vote, txIndex int32)

+ Rollback func()

+ type RollingCensus struct

+ CensusID string

+ DumpData []byte

+ DumpRoot []byte

+ Type models.Census_Type

+ type SnapshotHeader struct

+ ChainID string

+ Height uint32

+ Root []byte

+ Trees []SnapshotHeaderTree

+ Version int

+ type SnapshotHeaderTree struct

+ Name string

+ Parent string

+ Root []byte

+ Size uint32

+ type State struct

+ DisableVoteCache atomic.Bool

+ Store *statedb.StateDB

+ Tx treeTxWithMutex

+ func NewState(dbType, dataDir string) (*State, error)

+ func (s *State) AddVote(vote *Vote) error

+ func (s *State) PurgeRollingCensus(pid []byte) error

+ func (v *State) AccountFromSignature(message, signature []byte) (*common.Address, *Account, error)

+ func (v *State) AddEventListener(l EventListener)

+ func (v *State) AddOracle(address common.Address) error

+ func (v *State) AddProcess(p *models.Process) error

+ func (v *State) AddProcessKeys(tx *models.AdminTx) error

+ func (v *State) AddToRollingCensus(pid []byte, key []byte, weight *big.Int) error

+ func (v *State) AddValidator(validator *models.Validator) error

+ func (v *State) BurnTxCost(from common.Address, cost uint64) error

+ func (v *State) BurnTxCostIncrementNonce(accountAddress common.Address, txType models.TxType) error

+ func (v *State) CacheAdd(id [32]byte, vote *Vote)

+ func (v *State) CacheDel(id [32]byte)

+ func (v *State) CacheGet(id [32]byte) *Vote

+ func (v *State) CacheGetCopy(id [32]byte) *Vote

+ func (v *State) CacheHasNullifier(nullifier []byte) bool

+ func (v *State) CachePurge(height uint32)

+ func (v *State) CacheSize() int

+ func (v *State) CancelProcess(pid []byte) error

+ func (v *State) ChainID() string

+ func (v *State) CleanEventListeners()

+ func (v *State) Close() error

+ func (v *State) ConsumeFaucetPayload(from common.Address, faucetPayload *models.FaucetPayload) error

+ func (v *State) CountProcesses(committed bool) (uint64, error)

+ func (v *State) CountVotes(processID []byte, committed bool) uint32

+ func (v *State) CreateAccount(accountAddress common.Address, infoURI string, delegates [][]byte, ...) error

+ func (v *State) CurrentHeight() uint32

+ func (v *State) DumpRollingCensus(pid []byte) (*RollingCensus, error)

+ func (v *State) EnvelopeList(processID []byte, from, listSize int, committed bool) (nullifiers [][]byte)

+ func (v *State) EventListeners() []EventListener

+ func (v *State) FaucetNonce(key []byte, committed bool) (bool, error)

+ func (v *State) GetAccount(address common.Address, committed bool) (*Account, error)

+ func (v *State) GetPreRegisterAddrUsedWeight(pid []byte, addr common.Address) (*big.Int, error)

+ func (v *State) GetProcessResults(pid []byte) ([][]*types.BigInt, error)

+ func (v *State) GetRollingCensusRoot(pid []byte, committed bool) ([]byte, error)

+ func (v *State) GetRollingCensusSize(pid []byte, committed bool) (uint64, error)

+ func (v *State) IncrementAccountProcessIndex(accountAddress common.Address) error

+ func (v *State) IncrementTreasurerNonce() error

+ func (v *State) InitChainMintBalance(to common.Address, amount uint64) error

+ func (v *State) IsOracle(addr common.Address) (bool, error)

+ func (v *State) IsTreasurer(addr common.Address) (bool, error)

+ func (v *State) IterateVotes(processID []byte, committed bool, callback func(vote *models.StateDBVote) bool) error

+ func (v *State) LastHeight() (uint32, error)

+ func (v *State) ListProcessIDs(committed bool) ([][]byte, error)

+ func (v *State) ListSnapshots() []diskSnapshotInfo

+ func (v *State) MainTreeView() *statedb.TreeView

+ func (v *State) MintBalance(tx *vochaintx.TokenTransfer) error

+ func (v *State) Oracles(committed bool) ([]common.Address, error)

+ func (v *State) Process(pid []byte, committed bool) (*models.Process, error)

+ func (v *State) RemoveOracle(address common.Address) error

+ func (v *State) RemoveValidator(address []byte) error

+ func (v *State) RevealProcessKeys(tx *models.AdminTx) error

+ func (v *State) Rollback()

+ func (v *State) Save() ([]byte, error)

+ func (v *State) SetAccount(accountAddress common.Address, account *Account) error

+ func (v *State) SetAccountDelegate(accountAddr common.Address, delegateAddrs [][]byte, txType models.TxType) error

+ func (v *State) SetAccountInfoURI(accountAddress common.Address, infoURI string) error

+ func (v *State) SetCacheSize(size int)

+ func (v *State) SetChainID(chID string)

+ func (v *State) SetFaucetNonce(key []byte) error

+ func (v *State) SetHeight(height uint32)

+ func (v *State) SetPreRegisterAddrUsedWeight(pid []byte, addr common.Address, weight *big.Int) error

+ func (v *State) SetProcessCensus(pid, censusRoot []byte, censusURI string, commit bool) error

+ func (v *State) SetProcessResults(pid []byte, result *models.ProcessResult, commit bool) error

+ func (v *State) SetProcessStatus(pid []byte, newstatus models.ProcessStatus, commit bool) error

+ func (v *State) SetTreasurer(address common.Address, nonce uint32) error

+ func (v *State) SetTxCost(txType models.TxType, cost uint64) error

+ func (v *State) Snapshot() (string, error)

+ func (v *State) TransferBalance(tx *vochaintx.TokenTransfer, burnTxCost bool) error

+ func (v *State) Treasurer(committed bool) (*models.Treasurer, error)

+ func (v *State) TxCost(txType models.TxType, committed bool) (uint64, error)

+ func (v *State) TxCounter() int32

+ func (v *State) TxCounterAdd()

+ func (v *State) UpdateProcess(p *models.Process, pid []byte) error

+ func (v *State) Validator(address common.Address, committed bool) (*models.Validator, error)

+ func (v *State) Validators(committed bool) (map[string]*models.Validator, error)

+ func (v *State) VerifyTreasurer(addr common.Address, txNonce uint32) error

+ func (v *State) Vote(processID, nullifier []byte, committed bool) (*models.StateDBVote, error)

+ func (v *State) VoteCount(committed bool) (uint64, error)

+ func (v *State) VoteExists(processID, nullifier []byte, committed bool) (bool, error)

+ func (v *State) WorkingHash() []byte

+ type StateSnapshot struct

+ func (s *StateSnapshot) AddTree(name, parent string, root []byte)

+ func (s *StateSnapshot) Create(filePath string) error

+ func (s *StateSnapshot) EndTree()

+ func (s *StateSnapshot) FetchNextTree() error

+ func (s *StateSnapshot) Header() *SnapshotHeader

+ func (s *StateSnapshot) Open(filePath string) error

+ func (s *StateSnapshot) Path() string

+ func (s *StateSnapshot) Read(b []byte) (int, error)

+ func (s *StateSnapshot) ReadAll() ([]byte, error)

+ func (s *StateSnapshot) Save() error

+ func (s *StateSnapshot) SetChainID(chainID string)

+ func (s *StateSnapshot) SetHeight(height uint32)

+ func (s *StateSnapshot) SetMainRoot(root []byte)

+ func (s *StateSnapshot) TreeHeader() *SnapshotHeaderTree

+ func (s *StateSnapshot) Write(b []byte) (int, error)

+ type Vote struct

+ EncryptionKeyIndexes []uint32

+ Height uint32

+ Nullifier types.HexBytes

+ Overwrites uint32

+ ProcessID types.HexBytes

+ VotePackage []byte

+ VoterID VoterID

+ Weight *big.Int

+ func (v *Vote) DeepCopy() *Vote

+ func (v *Vote) Hash() []byte

+ func (v *Vote) WeightBytes() []byte

+ type VoterID []byte

+ func (v VoterID) Address() ([]byte, error)

+ func (v VoterID) IsNil() bool

+ func (v VoterID) Nil() []byte

+ func (v VoterID) Type() VoterIDType

+ func (v VoterID) VoterIDTypeToString() string

+ type VoterIDType = uint8

+ const VoterIDTypeECDSA

+ const VoterIDTypeUndefined

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