ph01ctl

Documentation

Index

• type JoinerPhase01PrepController
  • func NewJoinerPhase01PrepController(s pulsectl.PulseSelectionStrategy) *JoinerPhase01PrepController
  • func (c *JoinerPhase01PrepController) CreatePacketDispatcher(pt phases.PacketType, realm *core.PrepRealm) population.PacketDispatcher
  • func (c *JoinerPhase01PrepController) DispatchHostPacket(ctx context.Context, packet transport.PacketParser, from endpoints.Inbound, ...) error
  • func (c *JoinerPhase01PrepController) GetPacketType() []phases.PacketType
• type Phase01Controller
  • func NewPhase01Controller(packetPrepareOptions transport.PacketPrepareOptions, ...) *Phase01Controller
  • func (c *Phase01Controller) CreatePacketDispatcher(pt phases.PacketType, ctlIndex int, realm *core.FullRealm) (population.PacketDispatcher, core.PerNodePacketDispatcherFactory)
  • func (*Phase01Controller) GetPacketType() []phases.PacketType
  • func (c *Phase01Controller) StartWorker(ctx context.Context, realm *core.FullRealm)
• type Phase01PrepController
  • func NewPhase01PrepController(s pulsectl.PulseSelectionStrategy) *Phase01PrepController
  • func (c *Phase01PrepController) CreatePacketDispatcher(pt phases.PacketType, realm *core.PrepRealm) population.PacketDispatcher
  • func (c *Phase01PrepController) DispatchHostPacket(ctx context.Context, packet transport.PacketParser, from endpoints.Inbound, ...) error
  • func (c *Phase01PrepController) GetPacketType() []phases.PacketType

Types

type JoinerPhase01PrepController

type JoinerPhase01PrepController struct {
	core.PrepPhaseControllerTemplate
	core.HostPacketDispatcherTemplate
	// contains filtered or unexported fields
}

func NewJoinerPhase01PrepController

func NewJoinerPhase01PrepController(s pulsectl.PulseSelectionStrategy) *JoinerPhase01PrepController

func (*JoinerPhase01PrepController) CreatePacketDispatcher

func (c *JoinerPhase01PrepController) CreatePacketDispatcher(pt phases.PacketType, realm *core.PrepRealm) population.PacketDispatcher

func (*JoinerPhase01PrepController) DispatchHostPacket

func (c *JoinerPhase01PrepController) DispatchHostPacket(ctx context.Context, packet transport.PacketParser,
	from endpoints.Inbound, flags coreapi.PacketVerifyFlags) error

func (*JoinerPhase01PrepController) GetPacketType

func (c *JoinerPhase01PrepController) GetPacketType() []phases.PacketType

type Phase01Controller

type Phase01Controller struct {
	core.PhaseControllerTemplate

	R *core.FullRealm
	// contains filtered or unexported fields
}

func NewPhase01Controller

func NewPhase01Controller(packetPrepareOptions transport.PacketPrepareOptions, qIntro <-chan population.MemberPacketSender) *Phase01Controller

Does Phase0/Phase1/Phase1Rq processing

func (*Phase01Controller) CreatePacketDispatcher

func (c *Phase01Controller) CreatePacketDispatcher(pt phases.PacketType, ctlIndex int, realm *core.FullRealm) (population.PacketDispatcher, core.PerNodePacketDispatcherFactory)

func (*Phase01Controller) GetPacketType

func (*Phase01Controller) GetPacketType() []phases.PacketType

func (*Phase01Controller) StartWorker

func (c *Phase01Controller) StartWorker(ctx context.Context, realm *core.FullRealm)

type Phase01PrepController

type Phase01PrepController struct {
	core.PrepPhaseControllerTemplate
	core.HostPacketDispatcherTemplate
	// contains filtered or unexported fields
}

func NewPhase01PrepController

func NewPhase01PrepController(s pulsectl.PulseSelectionStrategy) *Phase01PrepController

func (*Phase01PrepController) CreatePacketDispatcher

func (c *Phase01PrepController) CreatePacketDispatcher(pt phases.PacketType, realm *core.PrepRealm) population.PacketDispatcher

func (*Phase01PrepController) DispatchHostPacket

func (c *Phase01PrepController) DispatchHostPacket(ctx context.Context, packet transport.PacketParser,
	from endpoints.Inbound, flags coreapi.PacketVerifyFlags) error

func (*Phase01PrepController) GetPacketType

func (c *Phase01PrepController) GetPacketType() []phases.PacketType