ph3ctl

Documentation

Index

• type Phase3Controller
  • func NewPhase3Controller(loopingMinimalDelay time.Duration, ...) *Phase3Controller
  • func (c *Phase3Controller) CreatePacketDispatcher(pt phases.PacketType, ctlIndex int, realm *core.FullRealm) (population.PacketDispatcher, core.PerNodePacketDispatcherFactory)
  • func (*Phase3Controller) GetPacketType() []phases.PacketType
  • func (c *Phase3Controller) StartWorker(ctx context.Context, realm *core.FullRealm)
• type Phase3PacketDispatcher
  • func (c *Phase3PacketDispatcher) DispatchMemberPacket(ctx context.Context, reader transport.MemberPacketReader, ...) error

Types

type Phase3Controller

type Phase3Controller struct {
	core.PhaseControllerTemplate

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

func NewPhase3Controller

func NewPhase3Controller(loopingMinimalDelay time.Duration, packetPrepareOptions transport.PacketPrepareOptions,
	queueTrustUpdated <-chan ph2ctl.UpdateSignal, consensusStrategy consensus.SelectionStrategy,
	inspectionFactory inspectors.VectorInspection, enabledFast, lockOSThread, retrySendPhase3 bool) *Phase3Controller

func (*Phase3Controller) CreatePacketDispatcher

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

func (*Phase3Controller) GetPacketType

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

func (*Phase3Controller) StartWorker

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

type Phase3PacketDispatcher

type Phase3PacketDispatcher struct {
	core.MemberPacketDispatcherTemplate
	// contains filtered or unexported fields
}

func (*Phase3PacketDispatcher) DispatchMemberPacket

func (c *Phase3PacketDispatcher) DispatchMemberPacket(ctx context.Context, reader transport.MemberPacketReader, n *population.NodeAppearance) error