Versions in this module Expand all Collapse all v0 v0.34.4 Jul 23, 2021 Changes in this version + var ErrIntOverflowRegistry = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRegistry = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRegistry = fmt.Errorf("proto: unexpected end of group") + type Cache struct + func NewCache(backend Reader) *Cache + func (cache *Cache) Backend() Reader + func (cache *Cache) GetNodeByID(id crypto.Address) (*NodeIdentity, error) + func (cache *Cache) GetNodeIDsByAddress(net string) ([]crypto.Address, error) + func (cache *Cache) GetNumPeers() int + func (cache *Cache) RemoveNode(id crypto.Address) error + func (cache *Cache) Reset(backend Reader) + func (cache *Cache) Sync(state Writer) error + func (cache *Cache) UpdateNode(id crypto.Address, node *NodeIdentity) error + type Iterable interface + IterateNodes func(consumer func(crypto.Address, *NodeIdentity) error) (err error) + type IterableReader interface + type IterableReaderWriter interface + type NodeFilter struct + func NewNodeFilter(state IterableReader) *NodeFilter + func (nf *NodeFilter) NumPeers() int + func (nf *NodeFilter) QueryPeerByAddress(addr string) bool + func (nf *NodeFilter) QueryPeerByID(id string) bool + type NodeIdentity struct + Moniker string + NetworkAddress string + TendermintNodeID github_com_hyperledger_burrow_crypto.Address + ValidatorPublicKey *github_com_hyperledger_burrow_crypto.PublicKey + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeIdentity) Descriptor() ([]byte, []int) + func (*NodeIdentity) ProtoMessage() + func (*NodeIdentity) XXX_MessageName() string + func (m *NodeIdentity) GetMoniker() string + func (m *NodeIdentity) GetNetworkAddress() string + func (m *NodeIdentity) Marshal() (dAtA []byte, err error) + func (m *NodeIdentity) MarshalTo(dAtA []byte) (int, error) + func (m *NodeIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeIdentity) Reset() + func (m *NodeIdentity) Size() (n int) + func (m *NodeIdentity) Unmarshal(dAtA []byte) error + func (m *NodeIdentity) XXX_DiscardUnknown() + func (m *NodeIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeIdentity) XXX_Merge(src proto.Message) + func (m *NodeIdentity) XXX_Size() int + func (m *NodeIdentity) XXX_Unmarshal(b []byte) error + func (rn *NodeIdentity) String() string + type NodeStats struct + Addresses map[string]map[crypto.Address]struct{} + func NewNodeStats() NodeStats + func (ns *NodeStats) GetAddresses(net string) []crypto.Address + func (ns *NodeStats) Insert(net string, id crypto.Address) + func (ns *NodeStats) Remove(node *NodeIdentity) bool + type Reader interface + GetNodeByID func(crypto.Address) (*NodeIdentity, error) + GetNodeIDsByAddress func(net string) ([]crypto.Address, error) + GetNumPeers func() int + type ReaderWriter interface + type Writer interface + RemoveNode func(crypto.Address) error + UpdateNode func(crypto.Address, *NodeIdentity) error