packetdispatch

Documentation

Index

• type MemberPacketReceiver
• type PacketRecorder
  • func NewPacketRecorder(recordingSize int) PacketRecorder
  • func (p *PacketRecorder) Playback(to PostponedPacketFunc)
  • func (p *PacketRecorder) Record(packet transport.PacketParser, from endpoints.Inbound, ...)
• type PostponedPacket
• type PostponedPacketFunc
• type UnsafePacketRecorder
  • func NewUnsafePacketRecorder(recordingSize int) UnsafePacketRecorder
  • func (p *UnsafePacketRecorder) IsRecording() bool
  • func (p *UnsafePacketRecorder) Playback(to PostponedPacketFunc)
  • func (p *UnsafePacketRecorder) Record(packet transport.PacketParser, from endpoints.Inbound, ...)

Types

type MemberPacketReceiver

type MemberPacketReceiver interface {
	GetNodeID() node.ShortNodeID
	CanReceivePacket(pt phases.PacketType) bool
	VerifyPacketAuthenticity(packetSignature cryptkit.SignedDigest, from endpoints.Inbound, strictFrom bool) error
	SetPacketReceived(pt phases.PacketType) bool
	DispatchMemberPacket(ctx context.Context, packet transport.PacketParser, from endpoints.Inbound, flags coreapi.PacketVerifyFlags,
		pd population.PacketDispatcher) error
}

type PacketRecorder

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

func NewPacketRecorder

func NewPacketRecorder(recordingSize int) PacketRecorder

func (*PacketRecorder) Playback

func (p *PacketRecorder) Playback(to PostponedPacketFunc)

func (*PacketRecorder) Record

func (p *PacketRecorder) Record(packet transport.PacketParser, from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags)

type PostponedPacket

type PostponedPacket struct {
	Packet      transport.PacketParser
	From        endpoints.Inbound
	VerifyFlags coreapi.PacketVerifyFlags
}

type PostponedPacketFunc

type PostponedPacketFunc func(packet transport.PacketParser, from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags) bool

type UnsafePacketRecorder

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

func NewUnsafePacketRecorder

func NewUnsafePacketRecorder(recordingSize int) UnsafePacketRecorder

func (*UnsafePacketRecorder) IsRecording

func (p *UnsafePacketRecorder) IsRecording() bool

func (*UnsafePacketRecorder) Playback

func (p *UnsafePacketRecorder) Playback(to PostponedPacketFunc)

func (*UnsafePacketRecorder) Record

func (p *UnsafePacketRecorder) Record(packet transport.PacketParser, from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags)