Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

consistent

package

Go to main page

Versions in this module

v3

v3.0.1

Dec 27, 2023

Changes in this version

+ type ConsistentDecoder struct

+ func NewConsistentDecoder(log protocol.Logger) *ConsistentDecoder

+ func (d *ConsistentDecoder) Decode(in interface{}) interface{}

+ func (d *ConsistentDecoder) MsgType() int8

type MessageStation

+ func (s *MessageStation) Start() error

+ func (s *MessageStation) Stop() error

v3.0.0

Dec 23, 2022

Changes in this version

+ const HeartBeat

+ const NodeLink

+ const RaftConsistentDecoder

+ type ConsistenDecoder struct

+ func NewConsistenDecoder(log protocol.Logger) *ConsistenDecoder

+ func (d *ConsistenDecoder) Decode(in interface{}) interface{}

+ func (d *ConsistenDecoder) MsgType() int8

+ type MessageStation struct

+ func NewMessageStation(bus msgbus.MessageBus, log protocol.Logger) *MessageStation

+ func (s *MessageStation) Close()

+ func (s *MessageStation) OnMessage(m *msgbus.Message)

+ func (s *MessageStation) OnQuit()

+ func (s *MessageStation) Receive() interface{}

+ func (s *MessageStation) Send(payload interface{})

+ type NoopConsistentBroadcaster struct

+ func NewNoopConsistentBroadcaster(id string, interval time.Duration, log protocol.Logger) *NoopConsistentBroadcaster

+ func (b *NoopConsistentBroadcaster) ID() string

+ func (b *NoopConsistentBroadcaster) IsRunning() bool

+ func (b *NoopConsistentBroadcaster) NoopBroadcast(local consistent_service.Node, remote consistent_service.Node) (interface{}, error)

+ func (b *NoopConsistentBroadcaster) PreBroadcaster() consistent_service.Broadcast

+ func (b *NoopConsistentBroadcaster) Start() error

+ func (b *NoopConsistentBroadcaster) Stop() error

+ func (b *NoopConsistentBroadcaster) TimePattern() interface{}

+ type RaftHeartbeatBroadcaster struct

+ func NewRaftStatusBroadcaster(interval time.Duration, log protocol.Logger) *RaftHeartbeatBroadcaster

+ func (b *RaftHeartbeatBroadcaster) Broadcast(local consistent_service.Node, remote consistent_service.Node) (interface{}, error)

+ func (b *RaftHeartbeatBroadcaster) PreBroadcaster() consistent_service.Broadcast

+ type RaftLinkBroadcaster struct

+ func NewRaftLinkBroadcaster(stub *StatusConsistentStub, interval time.Duration, log protocol.Logger) *RaftLinkBroadcaster

+ func (b *RaftLinkBroadcaster) Broadcast(local consistent_service.Node, remote consistent_service.Node) (interface{}, error)

+ func (b *RaftLinkBroadcaster) PreBroadcaster() consistent_service.Broadcast

+ type RaftNode struct

+ func NewRaftNode(id string, status ...RaftNodeStatus) *RaftNode

+ func (n *RaftNode) ID() string

+ func (n *RaftNode) StatusByType(tpy int8) RaftNodeStatus

+ func (n *RaftNode) Statuses() map[int8]consistent_service.Status

+ func (n *RaftNode) UpdateStatus(status consistent_service.Status)

+ type RaftNodeHeartBeat struct

+ func (s *RaftNodeHeartBeat) Data() interface{}

+ func (s *RaftNodeHeartBeat) Type() int8

+ func (s *RaftNodeHeartBeat) Update(status consistent_service.Status)

+ type RaftNodeLink struct

+ func (s *RaftNodeLink) Data() interface{}

+ func (s *RaftNodeLink) Type() int8

+ func (s *RaftNodeLink) Update(status consistent_service.Status)

+ type RaftNodeStatus = consistent_service.Status

+ type StatusConsistentStub struct

+ func NewStatusConsistentStub(nodeID string, msgbus msgbus.MessageBus, log protocol.Logger) (*StatusConsistentStub, error)

+ func (c *StatusConsistentStub) AddNode(nodeIDs ...string) error

+ func (c *StatusConsistentStub) DeleteNode(nodeIDs ...string) error

+ func (c *StatusConsistentStub) GetNodesWithActiveState() []protocol.ConsensusNodeInfo

+ func (c *StatusConsistentStub) IsRunning() bool

+ func (c *StatusConsistentStub) ResetNodes(nodes []string)

+ func (c *StatusConsistentStub) Start() error

+ func (c *StatusConsistentStub) Stop() error