Versions in this module Expand all Collapse all v22 v22.4.2 Apr 28, 2022 Changes in this version + type Address struct + Hostname string + Ip net.IP + NodeId enode.EnodeID + P2pPort enr.TCP + RaftId uint16 + RaftPort enr.RaftPort + Rest []rlp.RawValue + type AddressTxes map[common.Address]types.Transactions + type AddressWithoutHostname struct + Ip net.IP + NodeId enode.EnodeID + P2pPort enr.TCP + RaftId uint16 + RaftPort enr.RaftPort + type ByRaftId []Address + func (a ByRaftId) Len() int + func (a ByRaftId) Less(i, j int) bool + func (a ByRaftId) Swap(i, j int) + type ClusterInfo struct + NodeActive bool + Role string + type InvalidRaftOrdering struct + type Peer struct + type ProtocolManager struct + func NewProtocolManager(raftId uint16, raftPort uint16, blockchain *core.BlockChain, ...) (*ProtocolManager, error) + func (pm *ProtocolManager) FetchRaftId(enodeId string) (uint16, error) + func (pm *ProtocolManager) IsIDRemoved(id uint64) bool + func (pm *ProtocolManager) LeaderAddress() (*Address, error) + func (pm *ProtocolManager) NodeInfo() *RaftNodeInfo + func (pm *ProtocolManager) Process(ctx context.Context, m raftpb.Message) error + func (pm *ProtocolManager) PromoteToPeer(raftId uint16) (bool, error) + func (pm *ProtocolManager) ProposeNewPeer(enodeURL string, isLearner bool) (uint16, error) + func (pm *ProtocolManager) ProposePeerRemoval(raftId uint16) error + func (pm *ProtocolManager) ReportSnapshot(id uint64, status etcdRaft.SnapshotStatus) + func (pm *ProtocolManager) ReportUnreachable(id uint64) + func (pm *ProtocolManager) Start() + func (pm *ProtocolManager) Stop() + func (pm *ProtocolManager) WriteMsg(msg p2p.Msg) error + type PublicRaftAPI struct + func NewPublicRaftAPI(raftService *RaftService) *PublicRaftAPI + func (s *PublicRaftAPI) AddLearner(enodeId string) (uint16, error) + func (s *PublicRaftAPI) AddPeer(enodeId string) (uint16, error) + func (s *PublicRaftAPI) Cluster() ([]ClusterInfo, error) + func (s *PublicRaftAPI) GetRaftId(enodeId string) (uint16, error) + func (s *PublicRaftAPI) Leader() (string, error) + func (s *PublicRaftAPI) PromoteToPeer(raftId uint16) (bool, error) + func (s *PublicRaftAPI) RemovePeer(raftId uint16) error + func (s *PublicRaftAPI) Role() string + type RaftNodeInfo struct + Address *Address + AppliedIndex uint64 + ClusterSize int + PeerAddresses []*Address + RemovedPeerIds []uint16 + Role string + SnapshotIndex uint64 + type RaftService struct + func New(stack *node.Node, chainConfig *params.ChainConfig, raftId, raftPort uint16, ...) (*RaftService, error) + func (service *RaftService) AccountManager() *accounts.Manager + func (service *RaftService) BlockChain() *core.BlockChain + func (service *RaftService) ChainDb() ethdb.Database + func (service *RaftService) DappDb() ethdb.Database + func (service *RaftService) EventMux() *event.TypeMux + func (service *RaftService) Start() error + func (service *RaftService) Stop() error + func (service *RaftService) TxPool() *core.TxPool + type SnapshotWithHostnames struct + Addresses []Address + HeadBlockHash common.Hash + RemovedRaftIds []uint16 + func (snapshot *SnapshotWithHostnames) EncodeRLP(w io.Writer) error + type SnapshotWithoutHostnames struct + Addresses []AddressWithoutHostname + HeadBlockHash common.Hash + RemovedRaftIds []uint16 Other modules containing this package github.com/baptiste-b-pegasys/quorum