coreapi

Documentation

Index

• func FindHostProfile(memberID node.ShortNodeID, from endpoints.Inbound, ...) profiles.Host
• func LazyPacketParse(packet transport.PacketParser) (transport.PacketParser, error)
• func VerifyPacketAuthenticityBy(packetSignature cryptkit.SignedDigest, nr profiles.Host, ...) error
• func VerifyPacketRoute(ctx context.Context, packet transport.PacketParser, selfID node.ShortNodeID, ...) (bool, error)
• type PacketVerifyFlags
• type PollingWorker
  • func (p *PollingWorker) AddPoll(fn api.MaintenancePollFunc)
  • func (p *PollingWorker) Start(ctx context.Context, pollingInterval time.Duration)
• type SequentialCandidateFeeder
  • func NewSequentialCandidateFeeder(candidateQueueSize int) *SequentialCandidateFeeder
  • func (p *SequentialCandidateFeeder) AddJoinCandidate(candidate transport.FullIntroductionReader) error
  • func (p *SequentialCandidateFeeder) PickNextJoinCandidate() (profiles.CandidateProfile, cryptkit.DigestHolder)
  • func (p *SequentialCandidateFeeder) RemoveJoinCandidate(candidateAdded bool, nodeID node.ShortNodeID) bool

Functions

func FindHostProfile

func FindHostProfile(memberID node.ShortNodeID, from endpoints.Inbound, initialCensus census.Operational) profiles.Host

func LazyPacketParse

func LazyPacketParse(packet transport.PacketParser) (transport.PacketParser, error)

func VerifyPacketAuthenticityBy

func VerifyPacketAuthenticityBy(packetSignature cryptkit.SignedDigest, nr profiles.Host, sf cryptkit.SignatureVerifier,
	from endpoints.Inbound, strictFrom bool) error

func VerifyPacketRoute

func VerifyPacketRoute(ctx context.Context, packet transport.PacketParser, selfID node.ShortNodeID, from endpoints.Inbound) (bool, error)

Types

type PacketVerifyFlags

type PacketVerifyFlags uint32

const (
	SkipVerify PacketVerifyFlags = 1 << iota
	RequireStrictVerify
	AllowUnverified
	SuccessfullyVerified
)

const DefaultVerify PacketVerifyFlags = 0

type PollingWorker

type PollingWorker struct {
	// contains filtered or unexported fields
}

func (*PollingWorker) AddPoll

func (p *PollingWorker) AddPoll(fn api.MaintenancePollFunc)

func (*PollingWorker) Start

func (p *PollingWorker) Start(ctx context.Context, pollingInterval time.Duration)

type SequentialCandidateFeeder

type SequentialCandidateFeeder struct {
	// contains filtered or unexported fields
}

func NewSequentialCandidateFeeder

func NewSequentialCandidateFeeder(candidateQueueSize int) *SequentialCandidateFeeder

func (*SequentialCandidateFeeder) AddJoinCandidate

func (p *SequentialCandidateFeeder) AddJoinCandidate(candidate transport.FullIntroductionReader) error

func (*SequentialCandidateFeeder) PickNextJoinCandidate

func (p *SequentialCandidateFeeder) PickNextJoinCandidate() (profiles.CandidateProfile, cryptkit.DigestHolder)

func (*SequentialCandidateFeeder) RemoveJoinCandidate

func (p *SequentialCandidateFeeder) RemoveJoinCandidate(candidateAdded bool, nodeID node.ShortNodeID) bool