Documentation
¶
Index ¶
- Constants
- type Announcement
- type Ragep2pDiscoverer
- func (r *Ragep2pDiscoverer) AddGroup(digest types.ConfigDigest, onodes []ragetypes.PeerID, ...) error
- func (r *Ragep2pDiscoverer) Close() error
- func (r *Ragep2pDiscoverer) FindPeer(peer ragetypes.PeerID) ([]ragetypes.Address, error)
- func (r *Ragep2pDiscoverer) RemoveGroup(digest types.ConfigDigest) error
- func (r *Ragep2pDiscoverer) Start(host *ragep2p.Host, privKey ed25519.PrivateKey, ...) error
- type WrappableMessage
Constants ¶
View Source
const MaxOracles = 165
Maximum number of distinct oracles that we can have across groups. The exact number is chosen arbitrarily. Better to have an arbitrary limit than no limit.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Announcement ¶
type Announcement struct {
PublicKey ed25519.PublicKey // PublicKey used to verify Sig
Sig []byte // sig over unsignedAnnouncement
// contains filtered or unexported fields
}
Announcement is a signed message in which a peer attests to their network addresses. An Announcement needs to adhere to some syntactic validity rules, found in checkWellFormed(), which are enforced on calls to verify().
func (Announcement) String ¶
func (ann Announcement) String() string
type Ragep2pDiscoverer ¶
type Ragep2pDiscoverer struct {
// contains filtered or unexported fields
}
func NewRagep2pDiscoverer ¶
func NewRagep2pDiscoverer( deltaReconcile time.Duration, announceAddresses []string, db nettypes.DiscovererDatabase, metricsRegisterer prometheus.Registerer, ) *Ragep2pDiscoverer
func (*Ragep2pDiscoverer) AddGroup ¶
func (r *Ragep2pDiscoverer) AddGroup(digest types.ConfigDigest, onodes []ragetypes.PeerID, bnodes []ragetypes.PeerInfo) error
func (*Ragep2pDiscoverer) Close ¶
func (r *Ragep2pDiscoverer) Close() error
func (*Ragep2pDiscoverer) RemoveGroup ¶
func (r *Ragep2pDiscoverer) RemoveGroup(digest types.ConfigDigest) error
RemoveGroup should not block or panic even if the discoverer is closed.
func (*Ragep2pDiscoverer) Start ¶
func (r *Ragep2pDiscoverer) Start(host *ragep2p.Host, privKey ed25519.PrivateKey, logger loghelper.LoggerWithContext) error
type WrappableMessage ¶
type WrappableMessage interface {
// contains filtered or unexported methods
}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.