ph2ctl

Documentation

Index

• type Phase2Controller
  • func NewPhase2Controller(loopingMinimalDelay time.Duration, ...) *Phase2Controller
  • func (c *Phase2Controller) CreatePacketDispatcher(pt phases.PacketType, ctlIndex int, realm *core.FullRealm) (population.PacketDispatcher, core.PerNodePacketDispatcherFactory)
  • func (c *Phase2Controller) GetPacketType() []phases.PacketType
  • func (c *Phase2Controller) StartWorker(ctx context.Context, realm *core.FullRealm)
• type Phase2PacketDispatcher
  • func (c *Phase2PacketDispatcher) DispatchMemberPacket(ctx context.Context, reader transport.MemberPacketReader, ...) error
  • func (c *Phase2PacketDispatcher) TriggerUnknownMember(ctx context.Context, memberID node.ShortNodeID, ...) (bool, error)
• type Scaler
  • func NewScalerInt64(fullRange int64) Scaler
  • func NewScalerUint64(base uint64, fullRange uint64) Scaler
  • func (r Scaler) ScaleInt64(v int64) uint32
  • func (r Scaler) ScaleUint64(v uint64) uint32
• type UpdateSignal
  • func NewDynamicNodeCreated(n *population.NodeAppearance) UpdateSignal
  • func NewDynamicNodeReady(n *population.NodeAppearance) UpdateSignal
  • func NewTrustUpdateSignal(n *population.NodeAppearance, newLevel member.TrustLevel) UpdateSignal
  • func (v *UpdateSignal) IsPingSignal() bool

Types

type Phase2Controller

type Phase2Controller struct {
	core.PhaseControllerTemplate
	R *core.FullRealm
	// contains filtered or unexported fields
}

func NewPhase2Controller

func NewPhase2Controller(loopingMinimalDelay time.Duration, packetPrepareOptions transport.PacketPrepareOptions,
	queueNshReady <-chan *population.NodeAppearance, lockOSThread bool) *Phase2Controller

func (*Phase2Controller) CreatePacketDispatcher

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

func (*Phase2Controller) GetPacketType

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

func (*Phase2Controller) StartWorker

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

type Phase2PacketDispatcher

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

func (*Phase2PacketDispatcher) DispatchMemberPacket

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

func (*Phase2PacketDispatcher) TriggerUnknownMember

func (c *Phase2PacketDispatcher) TriggerUnknownMember(ctx context.Context, memberID node.ShortNodeID,
	packet transport.MemberPacketReader, from endpoints.Inbound) (bool, error)

type Scaler

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

func NewScalerInt64

func NewScalerInt64(fullRange int64) Scaler

func NewScalerUint64

func NewScalerUint64(base uint64, fullRange uint64) Scaler

func (Scaler) ScaleInt64

func (r Scaler) ScaleInt64(v int64) uint32

func (Scaler) ScaleUint64

func (r Scaler) ScaleUint64(v uint64) uint32

type UpdateSignal

type UpdateSignal struct {
	NewTrustLevel member.TrustLevel
	UpdatedNode   *population.NodeAppearance
	DynNode       bool
}

func NewDynamicNodeCreated

func NewDynamicNodeCreated(n *population.NodeAppearance) UpdateSignal

func NewDynamicNodeReady

func NewDynamicNodeReady(n *population.NodeAppearance) UpdateSignal

func NewTrustUpdateSignal

func NewTrustUpdateSignal(n *population.NodeAppearance, newLevel member.TrustLevel) UpdateSignal

func (*UpdateSignal) IsPingSignal

func (v *UpdateSignal) IsPingSignal() bool