hashgraph

package

Go to main page

Versions in this module

v0

v0.6.2

Feb 7, 2020

v0.6.1

Jan 30, 2020

v0.6.0

Dec 20, 2019

v0.5.12

Nov 27, 2019

v0.5.11

Nov 14, 2019

Changes in this version

type BadgerStore

+ func (s *BadgerStore) GetMaintenanceMode() bool

+ func (s *BadgerStore) SetMaintenanceMode(val bool)

v0.5.10

Nov 7, 2019

Changes in this version

type Event

+ func (e *Event) MarshalDB() ([]byte, error)

+ func (e *Event) UnmarshalDB(data []byte) error

type EventCoordinates

+ Hash string

+ Index int

type Hashgraph

+ func (h *Hashgraph) SetWireInfo(event *Event) error

v0.5.9

Oct 25, 2019

v0.5.8

Oct 15, 2019

v0.5.7

Oct 2, 2019

v0.5.5

Sep 13, 2019

Changes in this version

+ func IsNormalSelfParentError(err error) bool

+ type SelfParentError struct

+ func NewSelfParentError(msg string, normal bool) SelfParentError

+ func (e SelfParentError) Error() string

v0.5.4

Sep 6, 2019

v0.5.3

Aug 29, 2019

v0.5.2

Aug 8, 2019

v0.5.1

Jul 23, 2019

v0.5.0

Jul 15, 2019

Changes in this version

type BadgerStore

+ func (s *BadgerStore) FirstRound(id uint32) (int, bool)

+ func (s *BadgerStore) GetAllPeerSets() (map[int][]*peers.Peer, error)

type Block

+ func (b *Block) InternalTransactionReceipts() []InternalTransactionReceipt

+ func (b *Block) InternalTransactions() []InternalTransaction

type BlockBody

+ InternalTransactionReceipts []InternalTransactionReceipt

+ InternalTransactions []InternalTransaction

type Event

+ func (e *Event) InternalTransactions() []InternalTransaction

type EventBody

+ InternalTransactions []InternalTransaction

type Frame

+ PeerSets map[int][]*peers.Peer

+ func (f *Frame) SortedFrameEvents() []*FrameEvent

+ type FrameEvent struct

+ Core *Event

+ LamportTimestamp int

+ Round int

+ Witness bool

type Hashgraph

+ func (h *Hashgraph) InsertFrameEvent(frameEvent *FrameEvent) error

type InmemStore

+ func (s *InmemStore) FirstRound(id uint32) (int, bool)

+ func (s *InmemStore) GetAllPeerSets() (map[int][]*peers.Peer, error)

+ type InternalTransaction struct

+ Body InternalTransactionBody

+ Signature string

+ func NewInternalTransaction(tType TransactionType, peer peers.Peer) InternalTransaction

+ func NewInternalTransactionJoin(peer peers.Peer) InternalTransaction

+ func NewInternalTransactionLeave(peer peers.Peer) InternalTransaction

+ func (t *InternalTransaction) AsAccepted() InternalTransactionReceipt

+ func (t *InternalTransaction) AsRefused() InternalTransactionReceipt

+ func (t *InternalTransaction) HashString() string

+ func (t *InternalTransaction) Marshal() ([]byte, error)

+ func (t *InternalTransaction) Sign(privKey *ecdsa.PrivateKey) error

+ func (t *InternalTransaction) Unmarshal(data []byte) error

+ func (t *InternalTransaction) Verify() (bool, error)

+ type InternalTransactionBody struct

+ Peer peers.Peer

+ Type TransactionType

+ func (i *InternalTransactionBody) Hash() ([]byte, error)

+ func (i *InternalTransactionBody) Marshal() ([]byte, error)

+ type InternalTransactionReceipt struct

+ Accepted bool

+ InternalTransaction InternalTransaction

type PeerSetCache

+ func (c *PeerSetCache) FirstRound(id uint32) (int, bool)

+ func (c *PeerSetCache) GetAll() (map[int][]*peers.Peer, error)

+ func (c *PeerSetCache) RepertoireByID() map[uint32]*peers.Peer

+ func (c *PeerSetCache) RepertoireByPubKey() map[string]*peers.Peer

type Root

+ Events []*FrameEvent

+ func (root *Root) Hash() (string, error)

+ type SortedFrameEvents []*FrameEvent

+ func (a SortedFrameEvents) Len() int

+ func (a SortedFrameEvents) Less(i, j int) bool

+ func (a SortedFrameEvents) Swap(i, j int)

type Store

+ FirstRound func(uint32) (int, bool)

+ GetAllPeerSets func() (map[int][]*peers.Peer, error)

+ type TransactionType uint8

+ const PEER_ADD

+ const PEER_REMOVE

+ func (t TransactionType) String() string

type WireBody

+ InternalTransactions []InternalTransaction

v0.4.1

Jan 28, 2019

Changes in this version

+ const COIN_ROUND_FREQ

+ const ROOT_DEPTH

+ func DummyInternalCommitCallback(b *Block) error

type BadgerStore

+ func (s *BadgerStore) AddParticipant(p *peers.Peer) error

+ func (s *BadgerStore) GetFuturePeerSets(baseRound int) (map[int][]*peers.Peer, error)

+ func (s *BadgerStore) GetPeerSet(round int) (peerSet *peers.PeerSet, err error)

+ func (s *BadgerStore) RepertoireByID() map[uint32]*peers.Peer

+ func (s *BadgerStore) RepertoireByPubKey() map[string]*peers.Peer

+ func (s *BadgerStore) SetPeerSet(round int, peerSet *peers.PeerSet) error

type Block

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

type BlockBody

+ PeersHash []byte

type BlockSignature

+ func (bs *BlockSignature) Key() string

+ type CoordinatesMap map[string]EventCoordinates

+ func NewCoordinatesMap() CoordinatesMap

+ func (c CoordinatesMap) Copy() CoordinatesMap

type Event

+ func (e *Event) GetRound() *int

type Frame

+ FuturePeerSets map[int][]*peers.Peer

+ Peers []*peers.Peer

type Hashgraph

+ PendingSignatures *SigPool

+ func (h *Hashgraph) Init(peerSet *peers.PeerSet) error

+ func (h *Hashgraph) InsertEventAndRunConsensus(event *Event, setWireInfo bool) error

+ func (h *Hashgraph) SetAnchorBlock(block *Block) error

type InmemStore

+ func (s *InmemStore) AddParticipant(p *peers.Peer) error

+ func (s *InmemStore) GetFuturePeerSets(baseRound int) (map[int][]*peers.Peer, error)

+ func (s *InmemStore) GetPeerSet(round int) (*peers.PeerSet, error)

+ func (s *InmemStore) RepertoireByID() map[uint32]*peers.Peer

+ func (s *InmemStore) RepertoireByPubKey() map[string]*peers.Peer

+ func (s *InmemStore) SetPeerSet(round int, peerSet *peers.PeerSet) error

+ type InternalCommitCallback func(*Block) error

+ type OrderedPendingRounds []*PendingRound

+ func (a OrderedPendingRounds) Len() int

+ func (a OrderedPendingRounds) Less(i, j int) bool

+ func (a OrderedPendingRounds) Swap(i, j int)

type ParticipantEventsCache

+ func (pec *ParticipantEventsCache) AddPeer(peer *peers.Peer) error

+ type PeerSetCache struct

+ func NewPeerSetCache() *PeerSetCache

+ func (c *PeerSetCache) Get(round int) (*peers.PeerSet, error)

+ func (c *PeerSetCache) GetFuture(baseRound int) (map[int][]*peers.Peer, error)

+ func (c *PeerSetCache) Set(round int, peerSet *peers.PeerSet) error

+ type PendingRound struct

+ Decided bool

+ Index int

+ type PendingRoundsCache struct

+ func NewPendingRoundsCache() *PendingRoundsCache

+ func (c *PendingRoundsCache) Clean(processedRounds []int)

+ func (c *PendingRoundsCache) GetOrderedPendingRounds() OrderedPendingRounds

+ func (c *PendingRoundsCache) Queued(round int) bool

+ func (c *PendingRoundsCache) Set(pendingRound *PendingRound)

+ func (c *PendingRoundsCache) Update(decidedRounds []int)

type Root

+ Head string

+ Past map[string]RootEvent

+ Precomputed map[string]RootEvent

+ func NewRoot(head RootEvent) *Root

+ func (root *Root) GetHead() RootEvent

+ func (root *Root) Init()

+ func (root *Root) Insert(re RootEvent)

+ func (root *Root) PastByIndex(index int) (RootEvent, bool)

type RoundInfo

+ CreatedEvents map[string]RoundEvent

+ ReceivedEvents []string

+ func (r *RoundInfo) AddCreatedEvent(x string, witness bool)

+ func (r *RoundInfo) AddReceivedEvent(x string)

+ func (r *RoundInfo) IsQueued() bool

+ type SigPool struct

+ func NewSigPool() *SigPool

+ func (sp *SigPool) Add(blockSignature BlockSignature)

+ func (sp *SigPool) Items() map[string]BlockSignature

+ func (sp *SigPool) Len() int

+ func (sp *SigPool) Remove(key string)

+ func (sp *SigPool) RemoveSlice(sigs []BlockSignature)

+ func (sp *SigPool) Slice() []BlockSignature

type Store

+ AddParticipant func(*peers.Peer) error

+ GetFuturePeerSets func(int) (map[int][]*peers.Peer, error)

+ GetPeerSet func(int) (*peers.PeerSet, error)

+ RepertoireByID func() map[uint32]*peers.Peer

+ RepertoireByPubKey func() map[string]*peers.Peer

+ SetPeerSet func(int, *peers.PeerSet) error

+ type TreKey struct

+ func (k TreKey) ToString() string

v0.4.0

Oct 14, 2018

Changes in this version

+ type BadgerStore struct

+ func LoadBadgerStore(cacheSize int, path string) (*BadgerStore, error)

+ func LoadOrCreateBadgerStore(participants *peers.Peers, cacheSize int, path string) (*BadgerStore, error)

+ func NewBadgerStore(participants *peers.Peers, cacheSize int, path string) (*BadgerStore, error)

+ func (s *BadgerStore) AddConsensusEvent(event Event) error

+ func (s *BadgerStore) CacheSize() int

+ func (s *BadgerStore) Close() error

+ func (s *BadgerStore) ConsensusEvents() []string

+ func (s *BadgerStore) ConsensusEventsCount() int

+ func (s *BadgerStore) GetBlock(rr int) (Block, error)

+ func (s *BadgerStore) GetEvent(key string) (event Event, err error)

+ func (s *BadgerStore) GetFrame(rr int) (Frame, error)

+ func (s *BadgerStore) GetRoot(participant string) (Root, error)

+ func (s *BadgerStore) GetRound(r int) (RoundInfo, error)

+ func (s *BadgerStore) KnownEvents() map[int]int

+ func (s *BadgerStore) LastBlockIndex() int

+ func (s *BadgerStore) LastConsensusEventFrom(participant string) (last string, isRoot bool, err error)

+ func (s *BadgerStore) LastEventFrom(participant string) (last string, isRoot bool, err error)

+ func (s *BadgerStore) LastRound() int

+ func (s *BadgerStore) NeedBoostrap() bool

+ func (s *BadgerStore) ParticipantEvent(participant string, index int) (string, error)

+ func (s *BadgerStore) ParticipantEvents(participant string, skip int) ([]string, error)

+ func (s *BadgerStore) Participants() (*peers.Peers, error)

+ func (s *BadgerStore) Reset(roots map[string]Root) error

+ func (s *BadgerStore) RootsBySelfParent() (map[string]Root, error)

+ func (s *BadgerStore) RoundEvents(r int) int

+ func (s *BadgerStore) RoundWitnesses(r int) []string

+ func (s *BadgerStore) SetBlock(block Block) error

+ func (s *BadgerStore) SetEvent(event Event) error

+ func (s *BadgerStore) SetFrame(frame Frame) error

+ func (s *BadgerStore) SetRound(r int, round RoundInfo) error

+ func (s *BadgerStore) StorePath() string

+ type Block struct

+ Body BlockBody

+ Signatures map[string]string

+ func NewBlock(blockIndex, roundReceived int, frameHash []byte, txs [][]byte) Block

+ func NewBlockFromFrame(blockIndex int, frame Frame) (Block, error)

+ func (b *Block) AppendTransactions(txs [][]byte)

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

+ func (b *Block) GetSignature(validator string) (res BlockSignature, err error)

+ func (b *Block) GetSignatures() []BlockSignature

+ func (b *Block) Hash() ([]byte, error)

+ func (b *Block) Hex() string

+ func (b *Block) Index() int

+ func (b *Block) Marshal() ([]byte, error)

+ func (b *Block) RoundReceived() int

+ func (b *Block) SetSignature(bs BlockSignature) error

+ func (b *Block) Sign(privKey *ecdsa.PrivateKey) (bs BlockSignature, err error)

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

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

+ func (b *Block) Unmarshal(data []byte) error

+ func (b *Block) Verify(sig BlockSignature) (bool, error)

+ type BlockBody struct

+ FrameHash []byte

+ Index int

+ RoundReceived int

+ StateHash []byte

+ Transactions [][]byte

+ func (bb *BlockBody) Hash() ([]byte, error)

+ func (bb *BlockBody) Marshal() ([]byte, error)

+ func (bb *BlockBody) Unmarshal(data []byte) error

+ type BlockSignature struct

+ Index int

+ Signature string

+ Validator []byte

+ func (bs *BlockSignature) Marshal() ([]byte, error)

+ func (bs *BlockSignature) ToWire() WireBlockSignature

+ func (bs *BlockSignature) Unmarshal(data []byte) error

+ func (bs *BlockSignature) ValidatorHex() string

+ type ByLamportTimestamp []Event

+ func (a ByLamportTimestamp) Len() int

+ func (a ByLamportTimestamp) Less(i, j int) bool

+ func (a ByLamportTimestamp) Swap(i, j int)

+ type ByTopologicalOrder []Event

+ func (a ByTopologicalOrder) Len() int

+ func (a ByTopologicalOrder) Less(i, j int) bool

+ func (a ByTopologicalOrder) Swap(i, j int)

+ type Event struct

+ Body EventBody

+ Signature string

+ func NewEvent(transactions [][]byte, blockSignatures []BlockSignature, parents []string, ...) Event

+ func (e *Event) BlockSignatures() []BlockSignature

+ func (e *Event) Creator() string

+ func (e *Event) Hash() ([]byte, error)

+ func (e *Event) Hex() string

+ func (e *Event) Index() int

+ func (e *Event) IsLoaded() bool

+ func (e *Event) Marshal() ([]byte, error)

+ func (e *Event) OtherParent() string

+ func (e *Event) SelfParent() string

+ func (e *Event) SetLamportTimestamp(t int)

+ func (e *Event) SetRound(r int)

+ func (e *Event) SetRoundReceived(rr int)

+ func (e *Event) SetWireInfo(selfParentIndex, otherParentCreatorID, otherParentIndex, creatorID int)

+ func (e *Event) Sign(privKey *ecdsa.PrivateKey) error

+ func (e *Event) ToWire() WireEvent

+ func (e *Event) Transactions() [][]byte

+ func (e *Event) Unmarshal(data []byte) error

+ func (e *Event) Verify() (bool, error)

+ func (e *Event) WireBlockSignatures() []WireBlockSignature

+ type EventBody struct

+ BlockSignatures []BlockSignature

+ Creator []byte

+ Index int

+ Parents []string

+ Transactions [][]byte

+ func (e *EventBody) Hash() ([]byte, error)

+ func (e *EventBody) Marshal() ([]byte, error)

+ func (e *EventBody) Unmarshal(data []byte) error

+ type EventCoordinates struct

+ type Frame struct

+ Events []Event

+ Roots []Root

+ Round int

+ func (f *Frame) Hash() ([]byte, error)

+ func (f *Frame) Marshal() ([]byte, error)

+ func (f *Frame) Unmarshal(data []byte) error

+ type Hashgraph struct

+ AnchorBlock *int

+ ConsensusTransactions int

+ FirstConsensusRound *int

+ LastCommitedRoundEvents int

+ LastConsensusRound *int

+ Participants *peers.Peers

+ PendingLoadedEvents int

+ PendingRounds []*pendingRound

+ SigPool []BlockSignature

+ Store Store

+ UndeterminedEvents []string

+ func NewHashgraph(participants *peers.Peers, store Store, commitCh chan Block, ...) *Hashgraph

+ func (h *Hashgraph) Bootstrap() error

+ func (h *Hashgraph) CheckBlock(block Block) error

+ func (h *Hashgraph) DecideFame() error

+ func (h *Hashgraph) DecideRoundReceived() error

+ func (h *Hashgraph) DivideRounds() error

+ func (h *Hashgraph) GetAnchorBlockWithFrame() (Block, Frame, error)

+ func (h *Hashgraph) GetFrame(roundReceived int) (Frame, error)

+ func (h *Hashgraph) InsertEvent(event Event, setWireInfo bool) error

+ func (h *Hashgraph) ProcessDecidedRounds() error

+ func (h *Hashgraph) ProcessSigPool() error

+ func (h *Hashgraph) ReadWireInfo(wevent WireEvent) (*Event, error)

+ func (h *Hashgraph) Reset(block Block, frame Frame) error

+ type Index struct

+ type InmemStore struct

+ func NewInmemStore(participants *peers.Peers, cacheSize int) *InmemStore

+ func (s *InmemStore) AddConsensusEvent(event Event) error

+ func (s *InmemStore) CacheSize() int

+ func (s *InmemStore) Close() error

+ func (s *InmemStore) ConsensusEvents() []string

+ func (s *InmemStore) ConsensusEventsCount() int

+ func (s *InmemStore) GetBlock(index int) (Block, error)

+ func (s *InmemStore) GetEvent(key string) (Event, error)

+ func (s *InmemStore) GetFrame(index int) (Frame, error)

+ func (s *InmemStore) GetRoot(participant string) (Root, error)

+ func (s *InmemStore) GetRound(r int) (RoundInfo, error)

+ func (s *InmemStore) KnownEvents() map[int]int

+ func (s *InmemStore) LastBlockIndex() int

+ func (s *InmemStore) LastConsensusEventFrom(participant string) (last string, isRoot bool, err error)

+ func (s *InmemStore) LastEventFrom(participant string) (last string, isRoot bool, err error)

+ func (s *InmemStore) LastRound() int

+ func (s *InmemStore) NeedBoostrap() bool

+ func (s *InmemStore) ParticipantEvent(participant string, index int) (string, error)

+ func (s *InmemStore) ParticipantEvents(participant string, skip int) ([]string, error)

+ func (s *InmemStore) Participants() (*peers.Peers, error)

+ func (s *InmemStore) Reset(roots map[string]Root) error

+ func (s *InmemStore) RootsBySelfParent() (map[string]Root, error)

+ func (s *InmemStore) RoundEvents(r int) int

+ func (s *InmemStore) RoundWitnesses(r int) []string

+ func (s *InmemStore) SetBlock(block Block) error

+ func (s *InmemStore) SetEvent(event Event) error

+ func (s *InmemStore) SetFrame(frame Frame) error

+ func (s *InmemStore) SetRound(r int, round RoundInfo) error

+ func (s *InmemStore) StorePath() string

+ type Key struct

+ func (k Key) ToString() string

+ type OrderedEventCoordinates []Index

+ func (o *OrderedEventCoordinates) Add(id int, event EventCoordinates)

+ func (o OrderedEventCoordinates) GetByID(id int) (Index, bool)

+ func (o OrderedEventCoordinates) GetIDIndex(id int) int

+ type ParentRoundInfo struct

+ func NewBaseParentRoundInfo() ParentRoundInfo

+ type ParticipantBlockSignaturesCache struct

+ func NewParticipantBlockSignaturesCache(size int, participants *peers.Peers) *ParticipantBlockSignaturesCache

+ func (psc *ParticipantBlockSignaturesCache) Get(participant string, skipIndex int) ([]BlockSignature, error)

+ func (psc *ParticipantBlockSignaturesCache) GetItem(participant string, index int) (BlockSignature, error)

+ func (psc *ParticipantBlockSignaturesCache) GetLast(participant string) (BlockSignature, error)

+ func (psc *ParticipantBlockSignaturesCache) Known() map[int]int

+ func (psc *ParticipantBlockSignaturesCache) Reset() error

+ func (psc *ParticipantBlockSignaturesCache) Set(participant string, sig BlockSignature) error

+ type ParticipantEventsCache struct

+ func NewParticipantEventsCache(size int, participants *peers.Peers) *ParticipantEventsCache

+ func (pec *ParticipantEventsCache) Get(participant string, skipIndex int) ([]string, error)

+ func (pec *ParticipantEventsCache) GetItem(participant string, index int) (string, error)

+ func (pec *ParticipantEventsCache) GetLast(participant string) (string, error)

+ func (pec *ParticipantEventsCache) GetLastConsensus(participant string) (string, error)

+ func (pec *ParticipantEventsCache) Known() map[int]int

+ func (pec *ParticipantEventsCache) Reset() error

+ func (pec *ParticipantEventsCache) Set(participant string, hash string, index int) error

+ type Root struct

+ NextRound int

+ Others map[string]RootEvent

+ SelfParent RootEvent

+ func NewBaseRoot(creatorID int) Root

+ func (root *Root) Marshal() ([]byte, error)

+ func (root *Root) Unmarshal(data []byte) error

+ type RootEvent struct

+ CreatorID int

+ Hash string

+ Index int

+ LamportTimestamp int

+ Round int

+ func NewBaseRootEvent(creatorID int) RootEvent

+ type RoundEvent struct

+ Consensus bool

+ Famous Trilean

+ Witness bool

+ type RoundInfo struct

+ Events map[string]RoundEvent

+ func NewRoundInfo() *RoundInfo

+ func (r *RoundInfo) AddEvent(x string, witness bool)

+ func (r *RoundInfo) ConsensusEvents() []string

+ func (r *RoundInfo) FamousWitnesses() []string

+ func (r *RoundInfo) IsDecided(witness string) bool

+ func (r *RoundInfo) Marshal() ([]byte, error)

+ func (r *RoundInfo) RoundEvents() []string

+ func (r *RoundInfo) SetConsensusEvent(x string)

+ func (r *RoundInfo) SetFame(x string, f bool)

+ func (r *RoundInfo) Unmarshal(data []byte) error

+ func (r *RoundInfo) Witnesses() []string

+ func (r *RoundInfo) WitnessesDecided() bool

+ type Store interface

+ AddConsensusEvent func(Event) error

+ CacheSize func() int

+ Close func() error

+ ConsensusEvents func() []string

+ ConsensusEventsCount func() int

+ GetBlock func(int) (Block, error)

+ GetEvent func(string) (Event, error)

+ GetFrame func(int) (Frame, error)

+ GetRoot func(string) (Root, error)

+ GetRound func(int) (RoundInfo, error)

+ KnownEvents func() map[int]int

+ LastBlockIndex func() int

+ LastConsensusEventFrom func(string) (string, bool, error)

+ LastEventFrom func(string) (string, bool, error)

+ LastRound func() int

+ NeedBoostrap func() bool

+ ParticipantEvent func(string, int) (string, error)

+ ParticipantEvents func(string, int) ([]string, error)

+ Participants func() (*peers.Peers, error)

+ Reset func(map[string]Root) error

+ RootsBySelfParent func() (map[string]Root, error)

+ RoundEvents func(int) int

+ RoundWitnesses func(int) []string

+ SetBlock func(Block) error

+ SetEvent func(Event) error

+ SetFrame func(Frame) error

+ SetRound func(int, RoundInfo) error

+ StorePath func() string

+ type Trilean int

+ const False

+ const True

+ const Undefined

+ func (t Trilean) String() string

+ type WireBlockSignature struct

+ Index int

+ Signature string

+ type WireBody struct

+ BlockSignatures []WireBlockSignature

+ CreatorID int

+ Index int

+ OtherParentCreatorID int

+ OtherParentIndex int

+ SelfParentIndex int

+ Transactions [][]byte

+ type WireEvent struct

+ Body WireBody

+ Signature string

+ func (we *WireEvent) BlockSignatures(validator []byte) []BlockSignature

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