announce

Documentation

Index

• func AnnouncementFromReaderNotForJoiner(senderID node.ShortNodeID, ma transport.MembershipAnnouncementReader, ...) (profiles.MemberAnnouncement, node.ShortNodeID)
• func ApplyMemberAnnouncement(ctx context.Context, reader transport.AnnouncementPacketReader, ...) (bool, profiles.StaticProfile, error)
• func ApplyUnknownAnnouncement(ctx context.Context, announcerID node.ShortNodeID, ...) (bool, error)
• func ValidateIntrosOnMember(reader transport.ExtendedIntroReader, brief transport.BriefIntroductionReader, ...) error
• type ResolvedNeighbour
  • func VerifyNeighbourhood(ctx context.Context, neighbourhood []transport.MembershipAnnouncementReader, ...) ([]ResolvedNeighbour, error)

Functions

func AnnouncementFromReaderNotForJoiner

func AnnouncementFromReaderNotForJoiner(senderID node.ShortNodeID, ma transport.MembershipAnnouncementReader,
	announcerID node.ShortNodeID, pf profiles.Factory) (profiles.MemberAnnouncement, node.ShortNodeID)

func ApplyMemberAnnouncement

func ApplyMemberAnnouncement(ctx context.Context, reader transport.AnnouncementPacketReader, brief transport.BriefIntroductionReader,
	fullIntroRequired bool, n *population.NodeAppearance, realm *core.FullRealm) (bool, profiles.StaticProfile, error)

func ApplyUnknownAnnouncement

func ApplyUnknownAnnouncement(ctx context.Context, announcerID node.ShortNodeID,
	reader transport.AnnouncementPacketReader, briefReader transport.BriefIntroductionReader,
	_ bool, realm *core.FullRealm) (bool, error)

func ValidateIntrosOnMember

func ValidateIntrosOnMember(reader transport.ExtendedIntroReader, brief transport.BriefIntroductionReader,
	fullIntroRequired bool, n purgatory.AnnouncingMember) error

Types

type ResolvedNeighbour

type ResolvedNeighbour struct {
	Neighbour    purgatory.AnnouncingMember
	Announcement profiles.MemberAnnouncement
}

func VerifyNeighbourhood

func VerifyNeighbourhood(ctx context.Context, neighbourhood []transport.MembershipAnnouncementReader,
	n *population.NodeAppearance, announcedJoiner profiles.StaticProfile, realm *core.FullRealm) ([]ResolvedNeighbour, error)