node

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2019 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	HeartbeatTimeout time.Duration `mapstructure:"heartbeat"`
	TCPTimeout       time.Duration `mapstructure:"timeout"`
	CacheSize        int           `mapstructure:"cache-size"`
	SyncLimit        int           `mapstructure:"sync-limit"`
	Logger           *logrus.Logger
}

func DefaultConfig 

func DefaultConfig() *Config

func NewConfig 

func NewConfig(heartbeat time.Duration,
	timeout time.Duration,
	cacheSize int,
	syncLimit int,
	logger *logrus.Logger) *Config

func TestConfig 

func TestConfig(t *testing.T) *Config

type ControlTimer 

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

func NewControlTimer 

func NewControlTimer(timerFactory timerFactory) *ControlTimer

func NewRandomControlTimer 

func NewRandomControlTimer() *ControlTimer

func (*ControlTimer) Run 

func (c *ControlTimer) Run(init time.Duration)

func (*ControlTimer) Shutdown 

func (c *ControlTimer) Shutdown()

type Core 

type Core struct {

	//Hash and Index of this instance's head Event
	Head string
	Seq  int

	//AcceptedRound is the first Round to which this peer belongs. A node will
	//not create SelfEvents before reaching AcceptedRound.
	AcceptedRound int
	// contains filtered or unexported fields
}

func NewCore 

func NewCore(
	id uint32,
	key *ecdsa.PrivateKey,
	peers *peers.PeerSet,
	store hg.Store,
	proxyCommitCallback proxy.CommitCallback,
	logger *logrus.Logger) *Core

func (*Core) AddSelfEvent 

func (c *Core) AddSelfEvent(otherHead string) error

func (*Core) AddTransactions 

func (c *Core) AddTransactions(txs [][]byte)

func (*Core) Bootstrap 

func (c *Core) Bootstrap() error

func (*Core) Commit added in v0.4.1 

func (c *Core) Commit(block *hg.Block) error

func (*Core) EventDiff 

func (c *Core) EventDiff(known map[uint32]int) (events []*hg.Event, err error)

returns events that c knowns about and are not in 'known'

func (*Core) FastForward 

func (c *Core) FastForward(peer string, block *hg.Block, frame *hg.Frame) error

func (*Core) FromWire 

func (c *Core) FromWire(wireEvents []hg.WireEvent) ([]hg.Event, error)

func (*Core) GetAnchorBlockWithFrame 

func (c *Core) GetAnchorBlockWithFrame() (*hg.Block, *hg.Frame, error)

func (*Core) GetConsensusEvents 

func (c *Core) GetConsensusEvents() []string

func (*Core) GetConsensusEventsCount 

func (c *Core) GetConsensusEventsCount() int

func (*Core) GetConsensusTransactions 

func (c *Core) GetConsensusTransactions() ([][]byte, error)

func (*Core) GetConsensusTransactionsCount 

func (c *Core) GetConsensusTransactionsCount() int

func (*Core) GetEvent 

func (c *Core) GetEvent(hash string) (*hg.Event, error)

func (*Core) GetEventTransactions 

func (c *Core) GetEventTransactions(hash string) ([][]byte, error)

func (*Core) GetHead 

func (c *Core) GetHead() (*hg.Event, error)

func (*Core) GetLastBlockIndex 

func (c *Core) GetLastBlockIndex() int

func (*Core) GetLastCommitedRoundEventsCount 

func (c *Core) GetLastCommitedRoundEventsCount() int

func (*Core) GetLastConsensusRoundIndex 

func (c *Core) GetLastConsensusRoundIndex() *int

func (*Core) GetPendingLoadedEvents 

func (c *Core) GetPendingLoadedEvents() int

func (*Core) GetUndeterminedEvents 

func (c *Core) GetUndeterminedEvents() []string

func (*Core) HexID 

func (c *Core) HexID() string

func (*Core) ID 

func (c *Core) ID() uint32

func (*Core) InsertEventAndRunConsensus added in v0.4.1 

func (c *Core) InsertEventAndRunConsensus(event *hg.Event, setWireInfo bool) error

func (*Core) KnownEvents 

func (c *Core) KnownEvents() map[uint32]int

func (*Core) OverSyncLimit 

func (c *Core) OverSyncLimit(knownEvents map[uint32]int, syncLimit int) bool

func (*Core) ProcessSigPool added in v0.4.1 

func (c *Core) ProcessSigPool() error

func (*Core) PubKey 

func (c *Core) PubKey() []byte

func (*Core) RecordHeads added in v0.4.1 

func (c *Core) RecordHeads() error

func (*Core) SetHeadAndSeq 

func (c *Core) SetHeadAndSeq() error

func (*Core) SignAndInsertSelfEvent 

func (c *Core) SignAndInsertSelfEvent(event *hg.Event) error

func (*Core) SignBlock 

func (c *Core) SignBlock(block *hg.Block) (hg.BlockSignature, error)

func (*Core) Sync 

func (c *Core) Sync(fromID uint32, unknownEvents []hg.WireEvent) error

Sync decodes and inserts new Events into the Hashgraph. UnknownEvents are expected to be in topoligical order.

func (*Core) ToWire 

func (c *Core) ToWire(events []*hg.Event) ([]hg.WireEvent, error)

type Graph added in v0.4.1 

type Graph struct {
	*Node
}

func NewGraph added in v0.4.1 

func NewGraph(n *Node) *Graph

func (*Graph) GetBlocks added in v0.4.1 

func (g *Graph) GetBlocks() []*hg.Block

func (*Graph) GetInfos added in v0.4.1 

func (g *Graph) GetInfos() (Infos, error)

func (*Graph) GetParticipantEvents added in v0.4.1 

func (g *Graph) GetParticipantEvents() (map[string]map[string]*hg.Event, error)

func (*Graph) GetRounds added in v0.4.1 

func (g *Graph) GetRounds() []*hg.RoundInfo

type Infos added in v0.4.1 

type Infos struct {
	ParticipantEvents map[string]map[string]*hg.Event
	Rounds            []*hg.RoundInfo
	Blocks            []*hg.Block
}

type Node 

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

func NewNode 

func NewNode(conf *Config,
	id uint32,
	key *ecdsa.PrivateKey,
	peers *peers.PeerSet,
	store hg.Store,
	trans net.Transport,
	proxy proxy.AppProxy,
) *Node

func (*Node) GetBlock 

func (n *Node) GetBlock(blockIndex int) (*hg.Block, error)

func (*Node) GetEvents added in v0.4.1 

func (n *Node) GetEvents() (map[uint32]int, error)

func (*Node) GetPeers added in v0.4.1 

func (n *Node) GetPeers() []*peers.Peer

func (*Node) GetStats 

func (n *Node) GetStats() map[string]string

func (*Node) ID 

func (n *Node) ID() uint32

func (*Node) Init 

func (n *Node) Init() error

func (*Node) Run 

func (n *Node) Run(gossip bool)

func (*Node) RunAsync 

func (n *Node) RunAsync(gossip bool)

func (*Node) Shutdown 

func (n *Node) Shutdown()

func (*Node) SyncRate 

func (n *Node) SyncRate() float64

type NodeState 

type NodeState uint32

NodeState captures the state of a Babble node: Babbling, CatchingUp, Joining, or Shutdown 

const (
	// Babbling is the initial state of a Babble node.
	Babbling NodeState = iota

	CatchingUp

	Joining

	Shutdown
)

func (NodeState) String 

func (s NodeState) String() string

type PeerSelector 

type PeerSelector interface {
	Peers() *peers.PeerSet
	UpdateLast(peer uint32)
	Next() *peers.Peer
}

type RandomPeerSelector 

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

func NewRandomPeerSelector 

func NewRandomPeerSelector(peerSet *peers.PeerSet, selfID uint32) *RandomPeerSelector

func (*RandomPeerSelector) Next 

func (ps *RandomPeerSelector) Next() *peers.Peer

func (*RandomPeerSelector) Peers 

func (ps *RandomPeerSelector) Peers() *peers.PeerSet

func (*RandomPeerSelector) UpdateLast 

func (ps *RandomPeerSelector) UpdateLast(peer uint32)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.