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

network

package

Go to main page

Versions in this module

v0

v0.10.1

Mar 15, 2019

v0.10.0

Mar 6, 2019

Changes in this version

+ const ResolvingTimeDuration

+ const StateClear

+ const StateMax

+ func LogMsg(msg interface{})

+ func LogStage(stage string, isDone bool)

+ func PrintNode(node *Node)

+ type MsgBuffer struct

+ CommitMsgs []*consensus.VoteMsg

+ PrePrepareMsgs []*consensus.PrePrepareMsg

+ PrepareMsgs []*consensus.VoteMsg

+ ReqMsgs []*consensus.RequestMsg

+ type Node struct

+ Alarm chan bool

+ CWLock sync.Mutex

+ CommitLock sync.Mutex

+ CommitWaitQueue *prque.Prque

+ CommittedMsgs []*consensus.RequestMsg

+ CurrentHeight int64

+ Finish consensus.ConsensusFinish

+ FinishChan chan int64

+ ID *big.Int

+ MsgBackward chan interface{}

+ MsgBuffer *MsgBuffer

+ MsgDelivery chan interface{}

+ MsgEntrance chan interface{}

+ NTLock sync.RWMutex

+ NodeID string

+ NodeTable map[string]string

+ PrePareLock sync.Mutex

+ RetryPrePrepareMsg map[int64]*consensus.PrePrepareMsg

+ States map[int64]*consensus.State

+ Stop bool

+ Verify consensus.ConsensusVerify

+ View *View

+ func NewNode(nodeID string, verify consensus.ConsensusVerify, ...) *Node

+ func (node *Node) Broadcast(msg interface{}, path string) map[string]error

+ func (node *Node) BroadcastOne(msg interface{}, path string, node_id string) (err error)

+ func (node *Node) ClearStatus(height int64)

+ func (node *Node) CommitWaitQueuePush(msg *consensus.VoteMsg)

+ func (node *Node) GetCommit(commitMsg *consensus.VoteMsg) error

+ func (node *Node) GetPrePrepare(prePrepareMsg *consensus.PrePrepareMsg) error

+ func (node *Node) GetPrepare(prepareMsg *consensus.VoteMsg) error

+ func (node *Node) GetReply(msg *consensus.ReplyMsg)

+ func (node *Node) GetReq(reqMsg *consensus.RequestMsg) error

+ func (node *Node) GetStatus(height int64) *consensus.State

+ func (node *Node) PutStatus(height int64, state *consensus.State)

+ func (node *Node) Reply(msg *consensus.ReplyMsg) error

+ func (node *Node) ReplyResult(msgHeight int64)

+ func (node *Node) UpdateStatus(msg *consensus.RequestMsg)

+ type Server struct

+ ActionChan chan *consensus.ActionIn

+ ID *big.Int

+ Node *Node

+ func NewServer(nodeID string, id *big.Int, help consensus.ConsensusHelp, ...) *Server

+ func (server *Server) ConsensusFinish()

+ func (server *Server) PutRequest(msg *consensus.RequestMsg)

+ func (server *Server) Start(work func(cid *big.Int, acChan <-chan *consensus.ActionIn))

+ func (server *Server) Stop()

+ type View struct

+ ID int64

+ Primary string

v0.9.6

Jan 3, 2019

v0.8.6

Nov 2, 2018

v0.8.0

Sep 27, 2018