pulsectl

Documentation

Index

• type PulseController
  • func NewPulseController(ignoreHostVerificationForPulses bool) *PulseController
  • func (p *PulseController) CreatePacketDispatcher(pt phases.PacketType, ctlIndex int, realm *core.FullRealm) (population.PacketDispatcher, core.PerNodePacketDispatcherFactory)
  • func (p *PulseController) DispatchHostPacket(ctx context.Context, packet transport.PacketParser, from endpoints.Inbound, ...) error
  • func (*PulseController) GetPacketType() []phases.PacketType
  • func (p *PulseController) HasCustomVerifyForHost(from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags) bool
• type PulsePrepController
  • func NewPulsePrepController(s PulseSelectionStrategy, ignoreHostVerificationForPulses bool) *PulsePrepController
  • func (p *PulsePrepController) CreatePacketDispatcher(pt phases.PacketType, realm *core.PrepRealm) population.PacketDispatcher
  • func (p *PulsePrepController) DispatchHostPacket(ctx context.Context, packet transport.PacketParser, from endpoints.Inbound, ...) error
  • func (*PulsePrepController) GetPacketType() []phases.PacketType
  • func (p *PulsePrepController) HasCustomVerifyForHost(from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags) bool
• type PulseSelectionStrategy
• type PulseSelectionStrategyFactory
  • func NewTakeFirstSelectionStrategyFactory() PulseSelectionStrategyFactory

Types

type PulseController

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

func NewPulseController

func NewPulseController(ignoreHostVerificationForPulses bool) *PulseController

func (*PulseController) CreatePacketDispatcher

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

func (*PulseController) DispatchHostPacket

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

func (*PulseController) GetPacketType

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

func (*PulseController) HasCustomVerifyForHost

func (p *PulseController) HasCustomVerifyForHost(from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags) bool

type PulsePrepController

type PulsePrepController struct {
	core.PrepPhaseControllerTemplate
	core.HostPacketDispatcherTemplate
	R *core.PrepRealm
	// contains filtered or unexported fields
}

func NewPulsePrepController

func NewPulsePrepController(s PulseSelectionStrategy, ignoreHostVerificationForPulses bool) *PulsePrepController

func (*PulsePrepController) CreatePacketDispatcher

func (p *PulsePrepController) CreatePacketDispatcher(pt phases.PacketType, realm *core.PrepRealm) population.PacketDispatcher

func (*PulsePrepController) DispatchHostPacket

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

func (*PulsePrepController) GetPacketType

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

func (*PulsePrepController) HasCustomVerifyForHost

func (p *PulsePrepController) HasCustomVerifyForHost(from endpoints.Inbound, verifyFlags coreapi.PacketVerifyFlags) bool

type PulseSelectionStrategy

type PulseSelectionStrategy interface {
	HandlePulsarPacket(ctx context.Context, p transport.PulsePacketReader,
		from endpoints.Inbound, fromPulsar bool) (bool, error)
}

type PulseSelectionStrategyFactory

type PulseSelectionStrategyFactory interface {
	CreatePulseSelectionStrategy(population census.OnlinePopulation, config api.LocalNodeConfiguration) PulseSelectionStrategy
}

func NewTakeFirstSelectionStrategyFactory

func NewTakeFirstSelectionStrategyFactory() PulseSelectionStrategyFactory