ragedisco

Documentation

Index

• Constants
• type Announcement
  • func (ann Announcement) PeerID() (ragetypes.PeerID, error)
  • func (ann Announcement) String() string
• type Ragep2pDiscoverer
  • func NewRagep2pDiscoverer(deltaReconcile time.Duration, announceAddresses []string, ...) *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

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.

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) PeerID

func (ann Announcement) PeerID() (ragetypes.PeerID, error)

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) FindPeer

func (r *Ragep2pDiscoverer) FindPeer(peer ragetypes.PeerID) ([]ragetypes.Address, 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
}