meerdag

package

Go to main page

Versions in this module

v1

v1.2.0

May 22, 2024

Changes in this version

+ const CONFLUX

+ const PHANTOM

+ const SPECTRE

+ func CreateMockBlockState(id uint64) model.BlockState

+ func CreateMockBlockStateFromBytes(data []byte) (model.BlockState, error)

+ func NewDAGErrorByStr(e string) error

+ func SetBlockStateFactory(createBS CreateBlockState, createBSB CreateBlockStateFromBytes)

+ type FilterType byte

+ const All

+ const Blue

+ const Red

type MeerDAG

+ func (bd *MeerDAG) CanPrune(block IBlock, mainTip IBlock) bool

+ func (bd *MeerDAG) DB() model.DataBase

+ func (bd *MeerDAG) Foreach(start IBlock, depth uint, filter FilterType, ...) error

+ func (bd *MeerDAG) GetAnticone(b IBlock, exclude *IdSet) *IdSet

+ func (bd *MeerDAG) GetFutureSet(fs *IdSet, b IBlock)

+ func (bd *MeerDAG) GetLastBlockID() uint

+ func (bd *MeerDAG) GetTipsDisLimit() int64

+ func (bd *MeerDAG) GetTipsSet() *IdSet

+ func (bd *MeerDAG) HasBlocks(hs []*hash.Hash) bool

+ func (bd *MeerDAG) LocateBlocks(gs *GraphState, maxHashes uint) []*hash.Hash

+ func (bd *MeerDAG) Rollback() error

type Phantom

+ func (ph *Phantom) AnticoneSize() int

type PhantomBlock

+ func (pb *PhantomBlock) Bytes() []byte

+ func (pb *PhantomBlock) GetDiffAnticoneList(filterType FilterType) []uint

type SyncMode

+ const ContinueMode

v1.0.24

Jun 20, 2023

v1.0.23

Jun 16, 2023

v1.0.22

Jun 3, 2023

v1.0.21

May 30, 2023

Changes in this version

type Block

+ func (b *Block) Bytes() []byte

+ func (b *Block) GetState() model.BlockState

+ type CreateBlockState func(id uint64) model.BlockState

+ type CreateBlockStateFromBytes func(data []byte) (model.BlockState, error)

type IBlock

+ Bytes func() []byte

+ GetState func() model.BlockState

type IBlockData

+ GetMainParent func() *hash.Hash

type MeerDAG

+ func (bd *MeerDAG) AddToCommit(block IBlock)

type OldBlock

+ func (b *OldBlock) Bytes() []byte

+ func (b *OldBlock) GetState() model.BlockState

+ func (b *OldBlock) RemoveParent(id uint)

type OldPhantomBlock

+ func (pb *OldPhantomBlock) AddBlueDiffAnticone(id uint)

+ func (pb *OldPhantomBlock) AddRedDiffAnticone(id uint)

+ func (pb *OldPhantomBlock) CleanDiffAnticone()

+ func (pb *OldPhantomBlock) GetBlueDiffAnticone() *IdSet

+ func (pb *OldPhantomBlock) GetBlueNum() uint

+ func (pb *OldPhantomBlock) GetDiffAnticoneSize() int

+ func (pb *OldPhantomBlock) GetRedDiffAnticone() *IdSet

+ func (pb *OldPhantomBlock) GetRedDiffAnticoneSize() int

+ func (pb *OldPhantomBlock) HasBlueDiffAnticone(id uint) bool

+ func (pb *OldPhantomBlock) HasRedDiffAnticone(id uint) bool

type SpectreBlockData

+ func (sd *SpectreBlockData) GetMainParent() *hash.Hash

v1.0.20

Apr 11, 2023

v1.0.19

Feb 20, 2023

Changes in this version

+ func DBGetDAGBlockHashByID(dbTx database.Tx, id uint64) (*hash.Hash, error)

v1.0.18

Nov 28, 2022

Changes in this version

+ const GHOSTDAG

+ const MinBlockDataCache

+ const MinBlockPruneSize

+ var DiffAnticoneBucketName = []byte("diffanticone")

+ func DBDelDiffAnticone(dbTx database.Tx, id uint) error

+ func DBGetDiffAnticone(dbTx database.Tx) ([]uint, error)

+ func DBPutDiffAnticone(dbTx database.Tx, id uint) error

type Block

+ func (b *Block) AddParent(parent IBlock)

+ func (b *Block) AttachChild(ib IBlock)

+ func (b *Block) AttachParent(ib IBlock)

+ func (b *Block) DetachChild(ib IBlock)

+ func (b *Block) DetachParent(ib IBlock)

+ func (b *Block) IsLoaded() bool

+ func (b *Block) RemoveParent(id uint)

+ func (b *Block) SetData(data IBlockData)

+ type GhostDAG struct

+ func (gd *GhostDAG) AddBlock(ib IBlock) (*list.List, *list.List)

+ func (gd *GhostDAG) BlockHeader(dbContext model.DBReader, stagingArea *model.StagingArea, blockHash *hash.Hash) (model.BlockHeader, error)

+ func (gd *GhostDAG) BlockHeaders(dbContext model.DBReader, stagingArea *model.StagingArea, ...) ([]model.BlockHeader, error)

+ func (gd *GhostDAG) ChildInSelectedParentChainOf(stagingArea *model.StagingArea, lowHash, highHash *hash.Hash) (*hash.Hash, error)

+ func (gd *GhostDAG) Children(stagingArea *model.StagingArea, blockHash *hash.Hash) ([]*hash.Hash, error)

+ func (gd *GhostDAG) Count(stagingArea *model.StagingArea) uint64

+ func (gd *GhostDAG) CreateBlock(b *Block) IBlock

+ func (gd *GhostDAG) Decode(r io.Reader) error

+ func (gd *GhostDAG) Delete(stagingArea *model.StagingArea, blockHash *hash.Hash)

+ func (gd *GhostDAG) Encode(w io.Writer) error

+ func (gd *GhostDAG) Get(dbContext model.DBReader, stagingArea *model.StagingArea, blockHash *hash.Hash, ...) (*model.BlockGHOSTDAGData, error)

+ func (gd *GhostDAG) GetBlueSet() *IdSet

+ func (gd *GhostDAG) GetBlues(parents *IdSet) uint

+ func (gd *GhostDAG) GetMainChainTip() IBlock

+ func (gd *GhostDAG) GetMainChainTipId() uint

+ func (gd *GhostDAG) GetMainParent(parents *IdSet) IBlock

+ func (gd *GhostDAG) GetMainParentConcurrency(b IBlock) int

+ func (gd *GhostDAG) GetName() string

+ func (gd *GhostDAG) GetTipsList() []IBlock

+ func (gd *GhostDAG) HasBlockHeader(dbContext model.DBReader, stagingArea *model.StagingArea, blockHash *hash.Hash) (bool, error)

+ func (gd *GhostDAG) Init(bd *MeerDAG) bool

+ func (gd *GhostDAG) IsAncestorOf(stagingArea *model.StagingArea, blockHashA *hash.Hash, blockHashB *hash.Hash) (bool, error)

+ func (gd *GhostDAG) IsAncestorOfAny(stagingArea *model.StagingArea, blockHash *hash.Hash, ...) (bool, error)

+ func (gd *GhostDAG) IsAnyAncestorOf(stagingArea *model.StagingArea, potentialAncestors []*hash.Hash, ...) (bool, error)

+ func (gd *GhostDAG) IsBlue(id uint) bool

+ func (gd *GhostDAG) IsChildOf(stagingArea *model.StagingArea, blockHashA *hash.Hash, blockHashB *hash.Hash) (bool, error)

+ func (gd *GhostDAG) IsDAG(parents []IBlock) bool

+ func (gd *GhostDAG) IsInSelectedParentChainOf(stagingArea *model.StagingArea, blockHashA *hash.Hash, blockHashB *hash.Hash) (bool, error)

+ func (gd *GhostDAG) IsParentOf(stagingArea *model.StagingArea, blockHashA *hash.Hash, blockHashB *hash.Hash) (bool, error)

+ func (gd *GhostDAG) IsStaged(stagingArea *model.StagingArea) bool

+ func (gd *GhostDAG) Load() error

+ func (gd *GhostDAG) Parents(stagingArea *model.StagingArea, blockHash *hash.Hash) ([]*hash.Hash, error)

+ func (gd *GhostDAG) SetParents(stagingArea *model.StagingArea, blockHash *hash.Hash, ...) error

+ func (gd *GhostDAG) Stage(stagingArea *model.StagingArea, blockHash *hash.Hash, ...)

+ func (gd *GhostDAG) UnstageAll(stagingArea *model.StagingArea)

+ func (gd *GhostDAG) UpdateOrders() error

type IBlock

+ AddParent func(parent IBlock)

+ AttachChild func(ib IBlock)

+ AttachParent func(ib IBlock)

+ DetachChild func(ib IBlock)

+ DetachParent func(ib IBlock)

+ IsLoaded func() bool

+ SetData func(data IBlockData)

type IdSet

+ func (s *IdSet) IsDataEmpty(elem uint) bool

type MeerDAG

+ func New(dagType string, calcWeight CalcWeight, blockRate float64, db database.DB, ...) *MeerDAG

+ func (bd *MeerDAG) GetBlockCacheSize() uint64

+ func (bd *MeerDAG) GetBlockData(ib IBlock) IBlockData

+ func (bd *MeerDAG) GetBlockDataCacheSize() uint64

+ func (bd *MeerDAG) GetChildren(ib IBlock) *IdSet

+ func (bd *MeerDAG) GetMinBlockCacheSize() uint64

+ func (bd *MeerDAG) GetMinBlockDataCacheSize() uint64

+ func (bd *MeerDAG) GetParents(ib IBlock) *IdSet

+ func (bd *MeerDAG) HasLoadedBlock(id uint) bool

+ func (bd *MeerDAG) LoadBlockDataSet(sets *IdSet)

+ func (bd *MeerDAG) SetCacheSize(dag uint64, data uint64)

+ func (bd *MeerDAG) Start() error

+ func (bd *MeerDAG) Stop() error

+ type OldBlock struct

+ func (b *OldBlock) AddChild(child IBlock)

+ func (b *OldBlock) AddParent(parent IBlock)

+ func (b *OldBlock) AttachChild(ib IBlock)

+ func (b *OldBlock) AttachParent(ib IBlock)

+ func (b *OldBlock) Decode(r io.Reader) error

+ func (b *OldBlock) DetachChild(ib IBlock)

+ func (b *OldBlock) DetachParent(ib IBlock)

+ func (b *OldBlock) Encode(w io.Writer) error

+ func (b *OldBlock) GetBackParent() *Block

+ func (b *OldBlock) GetChildren() *IdSet

+ func (b *OldBlock) GetData() IBlockData

+ func (b *OldBlock) GetForwardParent() *Block

+ func (b *OldBlock) GetHash() *hash.Hash

+ func (b *OldBlock) GetHeight() uint

+ func (b *OldBlock) GetID() uint

+ func (b *OldBlock) GetLayer() uint

+ func (b *OldBlock) GetMainParent() uint

+ func (b *OldBlock) GetOrder() uint

+ func (b *OldBlock) GetParents() *IdSet

+ func (b *OldBlock) GetStatus() BlockStatus

+ func (b *OldBlock) GetWeight() uint64

+ func (b *OldBlock) HasChildren() bool

+ func (b *OldBlock) HasParents() bool

+ func (b *OldBlock) Invalid()

+ func (b *OldBlock) IsLoaded() bool

+ func (b *OldBlock) IsOrdered() bool

+ func (b *OldBlock) RemoveChild(child uint)

+ func (b *OldBlock) SetData(data IBlockData)

+ func (b *OldBlock) SetHeight(h uint)

+ func (b *OldBlock) SetID(id uint)

+ func (b *OldBlock) SetLayer(layer uint)

+ func (b *OldBlock) SetOrder(o uint)

+ func (b *OldBlock) SetStatus(status BlockStatus)

+ func (b *OldBlock) SetStatusFlags(flags BlockStatus)

+ func (b *OldBlock) SetWeight(weight uint64)

+ func (b *OldBlock) UnsetStatusFlags(flags BlockStatus)

+ func (b *OldBlock) Valid()

+ type OldPhantomBlock struct

+ func (pb *OldPhantomBlock) AddPairBlueDiffAnticone(id uint, order uint)

+ func (pb *OldPhantomBlock) AddPairRedDiffAnticone(id uint, order uint)

+ func (pb *OldPhantomBlock) Decode(r io.Reader) error

+ func (pb *OldPhantomBlock) Encode(w io.Writer) error

+ func (pb *OldPhantomBlock) GetBlueDiffAnticoneSize() int

+ func (pb *OldPhantomBlock) IsBluer(other *OldPhantomBlock) bool

type Phantom

+ func (ph *Phantom) CheckBlockOrderDB(maxDepth uint64) error

type PhantomBlock

+ func (pb *PhantomBlock) AddBlueDiffAnticone(id uint)

+ func (pb *PhantomBlock) AddPairBlueDiffAnticone(id uint, order uint)

+ func (pb *PhantomBlock) AddPairRedDiffAnticone(id uint, order uint)

+ func (pb *PhantomBlock) AddRedDiffAnticone(id uint)

+ func (pb *PhantomBlock) CleanDiffAnticone()

+ func (pb *PhantomBlock) GetBlueDiffAnticoneSize() int

+ func (pb *PhantomBlock) GetDiffAnticoneSize() int

+ func (pb *PhantomBlock) GetRedDiffAnticoneSize() int

+ func (pb *PhantomBlock) HasBlueDiffAnticone(id uint) bool

+ func (pb *PhantomBlock) HasRedDiffAnticone(id uint) bool

v1.0.17

Sep 19, 2022

v1.0.16

Sep 4, 2022

v1.0.15

Aug 30, 2022

v1.0.14

Aug 28, 2022

v1.0.13

Aug 27, 2022

Changes in this version

+ const DAGErrorEmpty

+ const GenesisId

+ const MaxBlockOrder

+ const MaxId

+ const MaxMainLocatorNum

+ const MaxPriority

+ const MaxTipLayerGap

+ const MaxTips

+ const RET_KEY

+ const StableConfirmations

+ const VMK_KEY

+ var BlockIdBucketName = []byte("blockid")

+ var BlockIndexBucketName = []byte("blockidx")

+ var BlockRate = anticone.DefaultBlockRate

+ var ByteOrder = binary.LittleEndian

+ var DAGTipsBucketName = []byte("dagtips")

+ var DagInfoBucketName = []byte("daginfo")

+ var DagMainChainBucketName = []byte("dagmainchain")

+ var OrderIdBucketName = []byte("orderid")

+ func DBDelBlockIdByHash(dbTx database.Tx, h *hash.Hash) error

+ func DBDelDAGBlock(dbTx database.Tx, id uint) error

+ func DBDelDAGTip(dbTx database.Tx, id uint) error

+ func DBGetBlockIdByHash(dbTx database.Tx, h *hash.Hash) (uint32, error)

+ func DBGetBlockIdByOrder(dbTx database.Tx, order uint) (uint32, error)

+ func DBGetDAGBlock(dbTx database.Tx, block IBlock) error

+ func DBGetDAGTips(dbTx database.Tx) ([]uint, error)

+ func DBHasMainChainBlock(dbTx database.Tx, id uint) bool

+ func DBPutBlockIdByOrder(dbTx database.Tx, order uint, id uint) error

+ func DBPutDAGBlock(dbTx database.Tx, block IBlock) error

+ func DBPutDAGBlockIdByHash(dbTx database.Tx, block IBlock) error

+ func DBPutDAGInfo(dbTx database.Tx, bd *MeerDAG) error

+ func DBPutDAGTip(dbTx database.Tx, id uint, isMain bool) error

+ func DBPutMainChainBlock(dbTx database.Tx, id uint) error

+ func DBRemoveMainChainBlock(dbTx database.Tx, id uint) error

+ func GetDAGTypeByIndex(dagType byte) string

+ func GetDAGTypeIndex(dagType string) byte

+ func GetMaxLenHashSet(bsm map[hash.Hash]*HashSet) *hash.Hash

+ func GetOrderLogStr(order uint) string

+ func GetRisk(N int, alpha float64, lambda float64, delay float64, waitingTime uint, ...) float64

+ func NewDAGError(e error) error

+ func UseLogger(logger l.Logger)

+ type Block struct

+ func (b *Block) AddChild(child IBlock)

+ func (b *Block) Decode(r io.Reader) error

+ func (b *Block) Encode(w io.Writer) error

+ func (b *Block) GetBackParent() *Block

+ func (b *Block) GetChildren() *IdSet

+ func (b *Block) GetData() IBlockData

+ func (b *Block) GetForwardParent() *Block

+ func (b *Block) GetHash() *hash.Hash

+ func (b *Block) GetHeight() uint

+ func (b *Block) GetID() uint

+ func (b *Block) GetLayer() uint

+ func (b *Block) GetMainParent() uint

+ func (b *Block) GetOrder() uint

+ func (b *Block) GetParents() *IdSet

+ func (b *Block) GetStatus() BlockStatus

+ func (b *Block) GetWeight() uint64

+ func (b *Block) HasChildren() bool

+ func (b *Block) HasParents() bool

+ func (b *Block) Invalid()

+ func (b *Block) IsOrdered() bool

+ func (b *Block) RemoveChild(child uint)

+ func (b *Block) SetHeight(h uint)

+ func (b *Block) SetID(id uint)

+ func (b *Block) SetLayer(layer uint)

+ func (b *Block) SetOrder(o uint)

+ func (b *Block) SetStatus(status BlockStatus)

+ func (b *Block) SetStatusFlags(flags BlockStatus)

+ func (b *Block) SetWeight(weight uint64)

+ func (b *Block) UnsetStatusFlags(flags BlockStatus)

+ func (b *Block) Valid()

+ type BlockHashSlice []IBlock

+ func (bn BlockHashSlice) Len() int

+ func (bn BlockHashSlice) Less(i, j int) bool

+ func (bn BlockHashSlice) Swap(i, j int)

+ type BlockHeightSlice []IBlock

+ func (bs BlockHeightSlice) Len() int

+ func (bs BlockHeightSlice) Less(i, j int) bool

+ func (bs BlockHeightSlice) Swap(i, j int)

+ type BlockOrderHelp struct

+ Block IBlock

+ OldOrder uint

+ type BlockOrderSlice []IBlock

+ func (bs BlockOrderSlice) Len() int

+ func (bs BlockOrderSlice) Less(i, j int) bool

+ func (bs BlockOrderSlice) Swap(i, j int)

+ type BlockPrioritySlice []IBlock

+ func (bn BlockPrioritySlice) Len() int

+ func (bn BlockPrioritySlice) Less(i, j int) bool

+ func (bn BlockPrioritySlice) Swap(i, j int)

+ type BlockSlice []IBlock

+ func (bn BlockSlice) Len() int

+ func (bn BlockSlice) Less(i, j int) bool

+ func (bn BlockSlice) Swap(i, j int)

+ type BlockStatus byte

+ const StatusBadSide

+ const StatusInvalid

+ const StatusNone

+ func (status BlockStatus) IsBadSide() bool

+ func (status BlockStatus) KnownInvalid() bool

+ type BlueInfo struct

+ func NewBlueInfo(num uint, rate int64, weight int64, height int64) *BlueInfo

+ func (bi *BlueInfo) GetHeight() int64

+ func (bi *BlueInfo) GetNum() uint

+ func (bi *BlueInfo) GetRate() int64

+ func (bi *BlueInfo) GetWeight() int64

+ func (bi *BlueInfo) String() string

+ type CalcWeight func(ib IBlock, bi *BlueInfo) int64

+ type Conflux struct

+ func (con *Conflux) AddBlock(b IBlock) (*list.List, *list.List)

+ func (con *Conflux) CreateBlock(b *Block) IBlock

+ func (con *Conflux) Decode(r io.Reader) error

+ func (con *Conflux) Encode(w io.Writer) error

+ func (con *Conflux) GetBlues(parents *IdSet) uint

+ func (con *Conflux) GetMainChain() []uint

+ func (con *Conflux) GetMainChainTip() IBlock

+ func (con *Conflux) GetMainChainTipId() uint

+ func (con *Conflux) GetMainParent(parents *IdSet) IBlock

+ func (con *Conflux) GetMainParentConcurrency(b IBlock) int

+ func (con *Conflux) GetName() string

+ func (con *Conflux) GetTipsList() []IBlock

+ func (con *Conflux) Init(bd *MeerDAG) bool

+ func (con *Conflux) IsBlue(id uint) bool

+ func (con *Conflux) IsDAG(parents []IBlock) bool

+ func (con *Conflux) IsOnMainChain(b IBlock) bool

+ func (con *Conflux) Load(dbTx database.Tx) error

+ type ConsensusAlgorithm interface

+ AddBlock func(ib IBlock) (*list.List, *list.List)

+ CreateBlock func(b *Block) IBlock

+ Decode func(r io.Reader) error

+ Encode func(w io.Writer) error

+ GetBlues func(parents *IdSet) uint

+ GetMainChainTip func() IBlock

+ GetMainChainTipId func() uint

+ GetMainParent func(parents *IdSet) IBlock

+ GetMainParentConcurrency func(b IBlock) int

+ GetName func() string

+ GetTipsList func() []IBlock

+ Init func(bd *MeerDAG) bool

+ IsBlue func(id uint) bool

+ IsDAG func(parents []IBlock) bool

+ IsOnMainChain func(ib IBlock) bool

+ Load func(dbTx database.Tx) error

+ func NewBlockDAG(dagType string) ConsensusAlgorithm

+ type DAGError struct

+ func (e *DAGError) Error() string

+ func (e *DAGError) IsEmpty() bool

+ type DAGSnapshot struct

+ func NewDAGSnapshot() *DAGSnapshot

+ func (d *DAGSnapshot) AddOrder(ib IBlock)

+ func (d *DAGSnapshot) Clean()

+ func (d *DAGSnapshot) IsValid() bool

+ type DAGSync struct

+ func NewDAGSync(bd *MeerDAG) *DAGSync

+ func (ds *DAGSync) CalcSyncBlocks(gs *GraphState, locator []*hash.Hash, mode SyncMode, maxHashes uint) ([]*hash.Hash, *hash.Hash)

+ func (ds *DAGSync) GetMainLocator(point *hash.Hash) []*hash.Hash

+ func (ds *DAGSync) SetGraphState(gs *GraphState)

+ type Empty struct

+ type Epoch struct

+ func (e *Epoch) GetSequence() []IBlock

+ func (e *Epoch) HasBlock(h *hash.Hash) bool

+ func (e *Epoch) HasDepends() bool

+ type GetBlockData func(*hash.Hash) IBlockData

+ type GraphState struct

+ func NewGraphState() *GraphState

+ func (gs *GraphState) Clone() *GraphState

+ func (gs *GraphState) Decode(r io.Reader, pver uint32) error

+ func (gs *GraphState) Encode(w io.Writer, pver uint32) error

+ func (gs *GraphState) Equal(other *GraphState)

+ func (gs *GraphState) GetLayer() uint

+ func (gs *GraphState) GetMainChainTip() *hash.Hash

+ func (gs *GraphState) GetMainHeight() uint

+ func (gs *GraphState) GetMainOrder() uint

+ func (gs *GraphState) GetTips() *HashSet

+ func (gs *GraphState) GetTipsList() []*hash.Hash

+ func (gs *GraphState) GetTotal() uint

+ func (gs *GraphState) IsEqual(other *GraphState) bool

+ func (gs *GraphState) IsExcellent(other *GraphState) bool

+ func (gs *GraphState) IsGenesis() bool

+ func (gs *GraphState) MaxPayloadLength() uint32

+ func (gs *GraphState) SetLayer(layer uint)

+ func (gs *GraphState) SetMainHeight(mainHeight uint)

+ func (gs *GraphState) SetMainOrder(order uint)

+ func (gs *GraphState) SetTips(tips []*hash.Hash)

+ func (gs *GraphState) SetTotal(total uint)

+ func (gs *GraphState) String() string

+ type HashSet struct

+ func NewHashSet() *HashSet

+ func (s *HashSet) Add(elem *hash.Hash)

+ func (s *HashSet) AddList(list []*hash.Hash)

+ func (s *HashSet) AddPair(elem *hash.Hash, data interface{})

+ func (s *HashSet) AddSet(other *HashSet)

+ func (s *HashSet) Clean()

+ func (s *HashSet) Clone() *HashSet

+ func (s *HashSet) Contain(other *HashSet) bool

+ func (s *HashSet) Exclude(other *HashSet)

+ func (s *HashSet) Get(elem *hash.Hash) interface{}

+ func (s *HashSet) GetMap() map[hash.Hash]interface{}

+ func (s *HashSet) Has(elem *hash.Hash) bool

+ func (s *HashSet) HasOnly(elem *hash.Hash) bool

+ func (s *HashSet) Intersection(other *HashSet) *HashSet

+ func (s *HashSet) IsEmpty() bool

+ func (s *HashSet) IsEqual(other *HashSet) bool

+ func (s *HashSet) List() []*hash.Hash

+ func (s *HashSet) Remove(elem *hash.Hash)

+ func (s *HashSet) RemoveSet(other *HashSet)

+ func (s *HashSet) Size() int

+ func (s *HashSet) SortList(reverse bool) []*hash.Hash

+ func (s *HashSet) Union(other *HashSet) *HashSet

+ type HashSlice []*hash.Hash

+ func (sh HashSlice) Has(h *hash.Hash) bool

+ func (sh HashSlice) Len() int

+ func (sh HashSlice) Less(i, j int) bool

+ func (sh HashSlice) Swap(i, j int)

+ type IBlock interface

+ AddChild func(child IBlock)

+ Decode func(r io.Reader) error

+ Encode func(w io.Writer) error

+ GetChildren func() *IdSet

+ GetData func() IBlockData

+ GetHash func() *hash.Hash

+ GetHeight func() uint

+ GetID func() uint

+ GetLayer func() uint

+ GetMainParent func() uint

+ GetOrder func() uint

+ GetParents func() *IdSet

+ GetStatus func() BlockStatus

+ GetWeight func() uint64

+ HasChildren func() bool

+ HasParents func() bool

+ Invalid func()

+ IsOrdered func() bool

+ RemoveChild func(child uint)

+ SetOrder func(o uint)

+ SetStatus func(status BlockStatus)

+ SetWeight func(weight uint64)

+ Valid func()

+ type IBlockData interface

+ GetHash func() *hash.Hash

+ GetParents func() []*hash.Hash

+ GetPriority func() int

+ GetTimestamp func() int64

+ type ISpectre interface

+ Vote func(x IBlock, y IBlock) int

+ type IdSet struct

+ func NewIdSet() *IdSet

+ func (s *IdSet) Add(elem uint)

+ func (s *IdSet) AddList(list []uint)

+ func (s *IdSet) AddPair(elem uint, data interface{})

+ func (s *IdSet) AddSet(other *IdSet)

+ func (s *IdSet) Clean()

+ func (s *IdSet) Clone() *IdSet

+ func (s *IdSet) Contain(other *IdSet) bool

+ func (s *IdSet) Exclude(other *IdSet)

+ func (s *IdSet) Get(elem uint) interface{}

+ func (s *IdSet) GetMap() map[uint]interface{}

+ func (s *IdSet) Has(elem uint) bool

+ func (s *IdSet) HasOnly(elem uint) bool

+ func (s *IdSet) Intersection(other *IdSet) *IdSet

+ func (s *IdSet) IsEmpty() bool

+ func (s *IdSet) IsEqual(other *IdSet) bool

+ func (s *IdSet) List() []uint

+ func (s *IdSet) Remove(elem uint)

+ func (s *IdSet) RemoveSet(other *IdSet)

+ func (s *IdSet) Size() int

+ func (s *IdSet) SortHashList(reverse bool) []uint

+ func (s *IdSet) SortHeightList(reverse bool) []uint

+ func (s *IdSet) SortList(reverse bool) []uint

+ func (s *IdSet) SortPriorityList(reverse bool) []uint

+ func (s *IdSet) Union(other *IdSet) *IdSet

+ type IdSlice []uint

+ func (sh IdSlice) Has(id uint) bool

+ func (sh IdSlice) Len() int

+ func (sh IdSlice) Less(i, j int) bool

+ func (sh IdSlice) Swap(i, j int)

+ type KChain struct

+ type LazySet struct

+ func NewLazySet() *LazySet

+ func (ls *LazySet) Add(elem *hash.Hash)

+ func (ls *LazySet) Clear()

+ func (ls *LazySet) Clone() *LazySet

+ func (ls *LazySet) Intersection(other *HashSet) *LazySet

+ func (ls *LazySet) Remove(elem *hash.Hash)

+ func (ls *LazySet) Union(other *HashSet) *LazySet

+ type MainChain struct

+ func (mc *MainChain) Add(id uint) error

+ func (mc *MainChain) Has(id uint) bool

+ func (mc *MainChain) Remove(id uint) error

+ type MeerDAG struct

+ func (bd *MeerDAG) AddBlock(b IBlockData) (*list.List, *list.List, IBlock, bool)

+ func (bd *MeerDAG) BuildMerkleTreeStoreFromTips() []*hash.Hash

+ func (bd *MeerDAG) CheckBlueAndMature(targets []uint, views []uint, max uint) error

+ func (bd *MeerDAG) CheckBlueAndMatureMT(targets []uint, views []uint, max uint) error

+ func (bd *MeerDAG) CheckMainBlueAndMature(target IBlock, targetMainFork IBlock, max uint) (bool, IBlock)

+ func (bd *MeerDAG) CheckSubMainChainTip(parents []*hash.Hash) error

+ func (bd *MeerDAG) Commit() error

+ func (bd *MeerDAG) CreateVirtualBlock(data IBlockData) IBlock

+ func (bd *MeerDAG) Decode(r io.Reader) error

+ func (bd *MeerDAG) Encode(w io.Writer) error

+ func (bd *MeerDAG) GetBlock(h *hash.Hash) IBlock

+ func (bd *MeerDAG) GetBlockById(id uint) IBlock

+ func (bd *MeerDAG) GetBlockByOrder(order uint) IBlock

+ func (bd *MeerDAG) GetBlockByOrderWithTx(dbTx database.Tx, order uint) IBlock

+ func (bd *MeerDAG) GetBlockConcurrency(h *hash.Hash) (uint, error)

+ func (bd *MeerDAG) GetBlockHash(id uint) *hash.Hash

+ func (bd *MeerDAG) GetBlockHashByOrder(order uint) *hash.Hash

+ func (bd *MeerDAG) GetBlockId(h *hash.Hash) uint

+ func (bd *MeerDAG) GetBlockTotal() uint

+ func (bd *MeerDAG) GetBlueInfo(ib IBlock) *BlueInfo

+ func (bd *MeerDAG) GetBlueInfoByHash(h *hash.Hash) *BlueInfo

+ func (bd *MeerDAG) GetBlues(parents *IdSet) uint

+ func (bd *MeerDAG) GetBluesByBlock(ib IBlock) uint

+ func (bd *MeerDAG) GetBluesByHash(h *hash.Hash) uint

+ func (bd *MeerDAG) GetConfirmations(id uint) uint

+ func (bd *MeerDAG) GetGenesisHash() *hash.Hash

+ func (bd *MeerDAG) GetGraphState() *GraphState

+ func (bd *MeerDAG) GetIdSet(hs []*hash.Hash) *IdSet

+ func (bd *MeerDAG) GetInstance() ConsensusAlgorithm

+ func (bd *MeerDAG) GetLastBlock() IBlock

+ func (bd *MeerDAG) GetLastTime() *time.Time

+ func (bd *MeerDAG) GetLayer(id uint) uint

+ func (bd *MeerDAG) GetMainAncestor(block IBlock, height int64) IBlock

+ func (bd *MeerDAG) GetMainChainTip() IBlock

+ func (bd *MeerDAG) GetMainParent(parents *IdSet) IBlock

+ func (bd *MeerDAG) GetMainParentAndList(parents []*hash.Hash) (IBlock, []*hash.Hash)

+ func (bd *MeerDAG) GetMainParentByHashs(parents []*hash.Hash) IBlock

+ func (bd *MeerDAG) GetMainParentConcurrency(b IBlock) int

+ func (bd *MeerDAG) GetMaturity(target uint, views []uint) uint

+ func (bd *MeerDAG) GetName() string

+ func (bd *MeerDAG) GetParentsMaxLayer(parents *IdSet) (uint, bool)

+ func (bd *MeerDAG) GetPrevious(id uint) (uint, error)

+ func (bd *MeerDAG) GetTips() *HashSet

+ func (bd *MeerDAG) GetTipsList() []IBlock

+ func (bd *MeerDAG) GetValidTips(expectPriority int) []*hash.Hash

+ func (bd *MeerDAG) HasBlock(h *hash.Hash) bool

+ func (bd *MeerDAG) HasBlockById(id uint) bool

+ func (bd *MeerDAG) Init(dagType string, calcWeight CalcWeight, blockRate float64, db database.DB, ...) ConsensusAlgorithm

+ func (bd *MeerDAG) InvalidBlock(block IBlock)

+ func (bd *MeerDAG) IsBlue(id uint) bool

+ func (bd *MeerDAG) IsHourglass(id uint) bool

+ func (bd *MeerDAG) IsOnMainChain(id uint) bool

+ func (bd *MeerDAG) Load(dbTx database.Tx, blockTotal uint, genesis *hash.Hash) error

+ func (bd *MeerDAG) RelativeMainAncestor(block IBlock, distance int64) IBlock

+ func (bd *MeerDAG) SetTipsDisLimit(limit int64)

+ func (bd *MeerDAG) SortBlock(src []*hash.Hash) []*hash.Hash

+ func (bd *MeerDAG) UpdateWeight(ib IBlock)

+ func (bd *MeerDAG) UpgradeDB(dbTx database.Tx, mainTip *hash.Hash, total uint64, genesis *hash.Hash) error

+ func (bd *MeerDAG) ValidBlock(block IBlock)

+ type Phantom struct

+ func (ph *Phantom) AddBlock(ib IBlock) (*list.List, *list.List)

+ func (ph *Phantom) CheckMainChainDB(dbTx database.Tx) error

+ func (ph *Phantom) CreateBlock(b *Block) IBlock

+ func (ph *Phantom) Decode(r io.Reader) error

+ func (ph *Phantom) Encode(w io.Writer) error

+ func (ph *Phantom) GetBlues(parents *IdSet) uint

+ func (ph *Phantom) GetDiffAnticone() *IdSet

+ func (ph *Phantom) GetDiffBlueSet() *IdSet

+ func (ph *Phantom) GetMainChainTip() IBlock

+ func (ph *Phantom) GetMainChainTipId() uint

+ func (ph *Phantom) GetMainParent(parents *IdSet) IBlock

+ func (ph *Phantom) GetMainParentConcurrency(b IBlock) int

+ func (ph *Phantom) GetName() string

+ func (ph *Phantom) GetTipsList() []IBlock

+ func (ph *Phantom) Init(bd *MeerDAG) bool

+ func (ph *Phantom) IsBlue(id uint) bool

+ func (ph *Phantom) IsDAG(parents []IBlock) bool

+ func (ph *Phantom) IsOnMainChain(b IBlock) bool

+ func (ph *Phantom) Load(dbTx database.Tx) error

+ func (ph *Phantom) UpdateVirtualBlockOrder() *PhantomBlock

+ func (ph *Phantom) UpdateWeight(ib IBlock)

+ type PhantomBlock struct

+ func (pb *PhantomBlock) Decode(r io.Reader) error

+ func (pb *PhantomBlock) Encode(w io.Writer) error

+ func (pb *PhantomBlock) GetBlueDiffAnticone() *IdSet

+ func (pb *PhantomBlock) GetBlueNum() uint

+ func (pb *PhantomBlock) GetRedDiffAnticone() *IdSet

+ func (pb *PhantomBlock) IsBluer(other *PhantomBlock) bool

+ type Phantom_v2 struct

+ func (ph *Phantom_v2) AddBlock(b IBlock) (*list.List, *list.List)

+ func (ph *Phantom_v2) CreateBlock(b *Block) IBlock

+ func (ph *Phantom_v2) Decode(r io.Reader) error

+ func (ph *Phantom_v2) Encode(w io.Writer) error

+ func (ph *Phantom_v2) GetBlues(parents *IdSet) uint

+ func (ph *Phantom_v2) GetMainChainTip() IBlock

+ func (ph *Phantom_v2) GetMainChainTipId() uint

+ func (ph *Phantom_v2) GetMainParent(parents *IdSet) IBlock

+ func (ph *Phantom_v2) GetMainParentConcurrency(b IBlock) int

+ func (ph *Phantom_v2) GetName() string

+ func (ph *Phantom_v2) GetTipsList() []IBlock

+ func (ph *Phantom_v2) Init(bd *MeerDAG) bool

+ func (ph *Phantom_v2) IsBlue(id uint) bool

+ func (ph *Phantom_v2) IsDAG(parents []IBlock) bool

+ func (ph *Phantom_v2) IsOnMainChain(b IBlock) bool

+ func (ph *Phantom_v2) Load(dbTx database.Tx) error

+ type Spectre struct

+ func (sp *Spectre) AddBlock(b IBlock) (*list.List, *list.List)

+ func (sp *Spectre) CreateBlock(b *Block) IBlock

+ func (sp *Spectre) Decode(r io.Reader) error

+ func (sp *Spectre) Encode(w io.Writer) error

+ func (sp *Spectre) GetBlues(parents *IdSet) uint

+ func (sp *Spectre) GetMainChainTip() IBlock

+ func (sp *Spectre) GetMainChainTipId() uint

+ func (sp *Spectre) GetMainParent(parents *IdSet) IBlock

+ func (sp *Spectre) GetMainParentConcurrency(b IBlock) int

+ func (sp *Spectre) GetName() string

+ func (sp *Spectre) GetTipsList() []IBlock

+ func (sp *Spectre) Init(bd *MeerDAG) bool

+ func (sp *Spectre) InitVote(b1 IBlock, b2 IBlock) (bool, error)

+ func (sp *Spectre) IsBlue(id uint) bool

+ func (sp *Spectre) IsDAG(parents []IBlock) bool

+ func (sp *Spectre) IsInPastOf(b1 IBlock, b2 IBlock) bool

+ func (sp *Spectre) IsOnMainChain(b IBlock) bool

+ func (sp *Spectre) Load(dbTx database.Tx) error

+ func (sp *Spectre) Vote(b1 IBlock, b2 IBlock) (bool, error)

+ func (sp *Spectre) VoteByBlock(virtualBlock IBlock) (bool, error)

+ func (sp *Spectre) Votes() map[hash.Hash]bool

+ type SpectreBlock struct

+ Votes1 int

+ Votes2 int

+ func (sb *SpectreBlock) GetHash() *hash.Hash

+ type SpectreBlockData struct

+ func (sd *SpectreBlockData) GetHash() *hash.Hash

+ func (sd *SpectreBlockData) GetParents() []*hash.Hash

+ func (sd *SpectreBlockData) GetPriority() int

+ func (sd *SpectreBlockData) GetTimestamp() int64

+ func (sd *SpectreBlockData) GetWeight() uint64

+ type SyncMode byte

+ const DirectMode

+ const SubDAGMode

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