Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

node

package

Go to main page

Versions in this module

v0

v0.3.0

Sep 4, 2018

Changes in this version

+ type Config struct

+ CacheSize int

+ HeartbeatTimeout time.Duration

+ Logger *logrus.Logger

+ StorePath string

+ StoreType string

+ SyncLimit int

+ TCPTimeout time.Duration

+ func DefaultConfig() *Config

+ func NewConfig(heartbeat time.Duration, timeout time.Duration, cacheSize int, syncLimit int, ...) *Config

+ func TestConfig(t *testing.T) *Config

+ type ControlTimer struct

+ func NewControlTimer(timerFactory timerFactory) *ControlTimer

+ func NewRandomControlTimer(base time.Duration) *ControlTimer

+ func (c *ControlTimer) Run()

+ func (c *ControlTimer) Shutdown()

+ type Core struct

+ Head string

+ Seq int

+ func NewCore(id int, key *ecdsa.PrivateKey, participants map[string]int, store hg.Store, ...) Core

+ func (c *Core) AddBlockSignature(bs hg.BlockSignature)

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

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

+ func (c *Core) Bootstrap() error

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

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

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

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

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

+ func (c *Core) GetConsensusEventsCount() int

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

+ func (c *Core) GetConsensusTransactionsCount() int

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

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

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

+ func (c *Core) GetLastBlockIndex() int

+ func (c *Core) GetLastCommitedRoundEventsCount() int

+ func (c *Core) GetLastConsensusRoundIndex() *int

+ func (c *Core) GetPendingLoadedEvents() int

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

+ func (c *Core) HexID() string

+ func (c *Core) ID() int

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

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

+ func (c *Core) NeedGossip() bool

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

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

+ func (c *Core) RunConsensus() error

+ func (c *Core) SetHeadAndSeq() error

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

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

+ func (c *Core) Sync(unknownEvents []hg.WireEvent) error

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

+ type Node struct

+ func NewNode(conf *Config, id int, key *ecdsa.PrivateKey, participants []net.Peer, ...) *Node

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

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

+ func (n *Node) Init(bootstrap bool) error

+ func (n *Node) Run(gossip bool)

+ func (n *Node) RunAsync(gossip bool)

+ func (n *Node) Shutdown()

+ func (n *Node) SyncRate() float64

+ type NodeState uint32

+ const Babbling

+ const CatchingUp

+ const Shutdown

+ func (s NodeState) String() string

+ type PeerSelector interface

+ Next func() net.Peer

+ Peers func() []net.Peer

+ UpdateLast func(peer string)

+ type RandomPeerSelector struct

+ func NewRandomPeerSelector(participants []net.Peer, localAddr string) *RandomPeerSelector

+ func (ps *RandomPeerSelector) Next() net.Peer

+ func (ps *RandomPeerSelector) Peers() []net.Peer

+ func (ps *RandomPeerSelector) UpdateLast(peer string)

v0.2.1

Mar 1, 2018

v0.2.0

Jan 30, 2018

v0.1.4

Jan 6, 2018

v0.1.3

Jan 5, 2018

v0.1.2

Dec 4, 2017

v0.1.1

Nov 6, 2017

v0.1.0

Nov 4, 2017