store

Dec 11, 2019

Changes in this version

type DataEntryPrefix

+ const DPOSCheckPointHeights

+ const DPOSSingleCheckPoint

Jun 2, 2019

Changes in this version

type DataEntryPrefix

+ const DPOSCheckPoints

+ const DPOSCurrentReward

+ const DPOSDutyIndex

+ const DPOSNextReward

+ const DPOSState

type DposStore

+ func (s *DposStore) GetCheckPoint(height uint32) (*state.CheckPoint, error)

+ func (s *DposStore) GetHeightsDesc() ([]uint32, error)

+ func (s *DposStore) SaveArbitersState(point *state.CheckPoint) (err error)

type EventStoreAnalyzer

+ func (e *EventStoreAnalyzer) AppendConsensusVote(vote *payload.DPOSProposalVote)

+ func (e *EventStoreAnalyzer) Clear()

+ func (e *EventStoreAnalyzer) GetLastConsensusViewCount() uint32

+ func (e *EventStoreAnalyzer) GetLastConsensusVoteSignerHistory() []string

+ func (e *EventStoreAnalyzer) IncreaseLastConsensusViewCount()

Mar 28, 2019

Changes in this version

+ const DefaultMaxDataSize

+ const FieldBool

+ const FieldBytes

+ const FieldIn64

+ const FieldInt

+ const FieldInt32

+ const FieldString

+ const FieldUint16

+ const FieldUint168

+ const FieldUint256

+ const FieldUint32

+ const FieldUint64

+ const FieldUint8

+ func BytesToUint64(b []byte) uint64

+ func BytesToUint64List(b []byte) ([]uint64, error)

+ func GetIndexKey(tableName string, index uint64, columnValue []byte) []byte

+ func GetRowKey(tableName string, rowID uint64) []byte

+ func GetTableIDKey(tableName string) []byte

+ func GetTableKey(tableName string) []byte

+ func Uint64ListToBytes(indexes []uint64) ([]byte, error)

+ func Uint64ToBytes(value uint64) []byte

+ type DBTable struct

+ Fields []string

+ Indexes []uint64

+ Name string

+ PrimaryKey uint64

+ func (d *DBTable) Column(fieldName string) uint64

+ func (d *DBTable) Data(fields []*Field) ([]byte, error)

+ func (d *DBTable) Deserialize(r io.Reader) error

+ func (d *DBTable) GetFields(data []byte) ([]*Field, error)

+ func (d *DBTable) Serialize(w io.Writer) error

type DataEntryPrefix

+ const DPOSEmergencyData

+ type DirectPeers struct

+ Address string

+ PublicKey []byte

+ Sequence uint32

type DposStore

+ func (s *DposStore) Close() error

+ func (s *DposStore) StartEventRecord()

+ type EventStoreAnalyzer struct

+ func NewEventStoreAnalyzer(cfg EventStoreAnalyzerConfig) *EventStoreAnalyzer

+ func (e *EventStoreAnalyzer) ParseInactiveArbitrators() (result []string)

+ type EventStoreAnalyzerConfig struct

+ Arbitrators state.Arbitrators

+ InactiveEliminateCount uint32

+ Store IDposStore

+ type Field struct

+ Name string

+ Value interface{}

+ func (f *Field) Data() []byte

+ type IDBOperator interface

+ Close func() error

+ Create func(table *DBTable) error

+ Insert func(table *DBTable, fields []*Field) (uint64, error)

+ Select func(table *DBTable, inputFields []*Field) ([][]*Field, error)

+ SelectID func(table *DBTable, inputFields []*Field) ([]uint64, error)

+ Update func(table *DBTable, inputFields []*Field, updateFields []*Field) ([]uint64, error)

+ type IDposStore interface

+ type IEventRecord interface

+ AddConsensusEvent func(event interface{}) error

+ AddProposalEvent func(event interface{}) error

+ AddViewEvent func(event interface{}) error

+ AddVoteEvent func(event interface{}) error

+ StartEventRecord func()

+ UpdateConsensusEvent func(event interface{}) error

+ UpdateProposalEvent func(event interface{}) error

Feb 19, 2019

Changes in this version

+ const BITSPERKEY

+ const MaxEvnetTaskNumber

+ var ConsensusEventTable = &interfaces.DBTable

+ var ProposalEventTable = &interfaces.DBTable

+ var ViewEventTable = &interfaces.DBTable

+ var VoteEventTable = &interfaces.DBTable

+ func InitArbitrators(arConfig ArbitratorsConfig)

+ func NewDposStore(filePath string) (interfaces.IDposStore, error)

+ type Arbitrators struct

+ DutyChangedCount uint32

+ func (a *Arbitrators) ForceChange() error

+ func (a *Arbitrators) GetArbitrators() [][]byte

+ func (a *Arbitrators) GetArbitratorsProgramHashes() []*common.Uint168

+ func (a *Arbitrators) GetCandidates() [][]byte

+ func (a *Arbitrators) GetCandidatesProgramHashes() []*common.Uint168

+ func (a *Arbitrators) GetNextArbitrators() [][]byte

+ func (a *Arbitrators) GetNextCandidates() [][]byte

+ func (a *Arbitrators) GetNextOnDutyArbitrator(offset uint32) []byte

+ func (a *Arbitrators) GetOnDutyArbitrator() []byte

+ func (a *Arbitrators) HasArbitersMajorityCount(num uint32) bool

+ func (a *Arbitrators) HasArbitersMinorityCount(num uint32) bool

+ func (a *Arbitrators) OnBlockReceived(b *types.Block, confirmed bool)

+ func (a *Arbitrators) OnConfirmReceived(p *types.DPosProposalVoteSlot)

+ func (a *Arbitrators) RegisterListener(listener interfaces.ArbitratorsListener)

+ func (a *Arbitrators) StartUp() error

+ func (a *Arbitrators) UnregisterListener(listener interfaces.ArbitratorsListener)

+ type ArbitratorsConfig struct

+ ArbitratorsCount uint32

+ CandidatesCount uint32

+ MajorityCount uint32

+ Store interfaces.IDposStore

+ type Batch interface

+ Commit func() error

+ Delete func(key []byte) error

+ Put func(key []byte, value []byte) error

+ Rollback func() error

+ type DataEntryPrefix byte

+ const DPOSCurrentArbitrators

+ const DPOSCurrentCandidates

+ const DPOSDirectPeers

+ const DPOSDutyChangedCount

+ const DPOSNextArbitrators

+ const DPOSNextCandidates

+ type Database interface

+ Close func() error

+ Delete func(key []byte) error

+ Get func(key []byte) ([]byte, error)

+ NewBatch func() Batch

+ NewIterator func(prefix []byte) blockchain.IIterator

+ Put func(key []byte, value []byte) error

+ type DposStore struct

+ func (s *DposStore) AddConsensusEvent(event interface{}) error

+ func (s *DposStore) AddProposalEvent(event interface{}) error

+ func (s *DposStore) AddViewEvent(event interface{}) error

+ func (s *DposStore) AddVoteEvent(event interface{}) error

+ func (s *DposStore) Create(table *interfaces.DBTable) error

+ func (s *DposStore) Disconnect() error

+ func (s *DposStore) GetArbitrators(a interfaces.Arbitrators) error

+ func (s *DposStore) GetDirectPeers() ([]*interfaces.DirectPeers, error)

+ func (s *DposStore) InitConnection(connParams ...interface{}) error

+ func (s *DposStore) Insert(table *interfaces.DBTable, fields []*interfaces.Field) (uint64, error)

+ func (s *DposStore) SaveCurrentArbitrators(a interfaces.Arbitrators)

+ func (s *DposStore) SaveDirectPeers(p []*interfaces.DirectPeers)

+ func (s *DposStore) SaveDposDutyChangedCount(c uint32)

+ func (s *DposStore) SaveNextArbitrators(a interfaces.Arbitrators)

+ func (s *DposStore) Select(table *interfaces.DBTable, inputFields []*interfaces.Field) ([][]*interfaces.Field, error)

+ func (s *DposStore) SelectID(table *interfaces.DBTable, inputFields []*interfaces.Field) ([]uint64, error)

+ func (s *DposStore) StartRecordArbitrators()

+ func (s *DposStore) StartRecordEvent() error

+ func (s *DposStore) Update(table *interfaces.DBTable, inputFields []*interfaces.Field, ...) ([]uint64, error)

+ func (s *DposStore) UpdateConsensusEvent(event interface{}) error

+ func (s *DposStore) UpdateProposalEvent(event interface{}) error

+ type EventRecord struct

+ func (e *EventRecord) Initialize(store interfaces.IEventRecord)

+ func (e *EventRecord) OnConsensusFinished(cons *log.ConsensusEvent)

+ func (e *EventRecord) OnConsensusStarted(cons *log.ConsensusEvent)

+ func (e *EventRecord) OnProposalArrived(prop *log.ProposalEvent)

+ func (e *EventRecord) OnProposalFinished(prop *log.ProposalEvent)

+ func (e *EventRecord) OnViewStarted(view *log.ViewEvent)

+ func (e *EventRecord) OnVoteArrived(vote *log.VoteEvent)

+ type LevelDB struct

+ func NewLevelDB(file string) (*LevelDB, error)

+ func (l *LevelDB) Close() error

+ func (l *LevelDB) Delete(key []byte) error

+ func (l *LevelDB) Get(key []byte) ([]byte, error)

+ func (l *LevelDB) NewBatch() Batch

+ func (l *LevelDB) NewIterator(prefix []byte) blockchain.IIterator

+ func (l *LevelDB) Put(key []byte, value []byte) error