phasebundle

Documentation

Index

• func NewJoinerPhaseBundle(factories BundleFactories, config BundleConfig) core.PhaseControllersBundle
• func NewRegularPhaseBundle(factories BundleFactories, config BundleConfig) core.PhaseControllersBundle
• func NewStandardBundleFactory(factoryConfig BundleFactoryConfig, config BundleConfig) core.PhaseControllersBundleFactory
• func NewStandardBundleFactoryDefault() core.PhaseControllersBundleFactory
• type BundleConfig
  • func CreateDefaultBundleConfig() BundleConfig
• type BundleFactories
• type BundleFactoryConfig
  • func CreateDefaultBundleFactoryConfig() BundleFactoryConfig
• type JoinerPhaseBundle
  • func (r *JoinerPhaseBundle) CreateFullPhaseControllers(nodeCount int) ([]core.PhaseController, core.NodeUpdateCallback)
  • func (r *JoinerPhaseBundle) CreatePrepPhaseControllers() []core.PrepPhaseController
  • func (r *JoinerPhaseBundle) IsDynamicPopulationRequired() bool
  • func (r JoinerPhaseBundle) String() string
• type RegularPhaseBundle
  • func (r *RegularPhaseBundle) CreateFullPhaseControllers(nodeCount int) ([]core.PhaseController, core.NodeUpdateCallback)
  • func (r *RegularPhaseBundle) CreatePrepPhaseControllers() []core.PrepPhaseController
  • func (r *RegularPhaseBundle) IsDynamicPopulationRequired() bool
  • func (r RegularPhaseBundle) String() string

Functions

func NewJoinerPhaseBundle

func NewJoinerPhaseBundle(factories BundleFactories, config BundleConfig) core.PhaseControllersBundle

func NewRegularPhaseBundle

func NewRegularPhaseBundle(factories BundleFactories, config BundleConfig) core.PhaseControllersBundle

func NewStandardBundleFactory

func NewStandardBundleFactory(factoryConfig BundleFactoryConfig, config BundleConfig) core.PhaseControllersBundleFactory

func NewStandardBundleFactoryDefault

func NewStandardBundleFactoryDefault() core.PhaseControllersBundleFactory

Types

type BundleConfig

type BundleConfig struct {
	LoopingMinimalDelay time.Duration

	MemberPacketOptions             transport.PacketPrepareOptions
	JoinerPacketOptions             transport.PacketPrepareOptions
	VectorInspectInliningLimit      int
	DisableVectorInspectionOnJoiner bool
	EnableFastPhase3                bool
	IgnoreVectorHashes              bool
	DisableAggressivePhasing        bool
	IgnoreHostVerificationForPulses bool
	LockOSThreadForWorker           bool
	RetrySendPhase3                 bool
}

func CreateDefaultBundleConfig

func CreateDefaultBundleConfig() BundleConfig

type BundleFactories

type BundleFactories struct {
	PulseSelectionStrategy pulsectl.PulseSelectionStrategy
	ConsensusStrategy      consensus.SelectionStrategy
	VectorInspection       inspectors.VectorInspection
}

type BundleFactoryConfig

type BundleFactoryConfig struct {
	PulseSelectionStrategyFactory pulsectl.PulseSelectionStrategyFactory
	ConsensusStrategyFactory      consensus.SelectionStrategyFactory
	VectorInspectionFactory       inspectors.VectorInspectionFactory
}

func CreateDefaultBundleFactoryConfig

func CreateDefaultBundleFactoryConfig() BundleFactoryConfig

type JoinerPhaseBundle

type JoinerPhaseBundle struct {
	BundleFactories
	BundleConfig
}

func (*JoinerPhaseBundle) CreateFullPhaseControllers

func (r *JoinerPhaseBundle) CreateFullPhaseControllers(nodeCount int) ([]core.PhaseController, core.NodeUpdateCallback)

func (*JoinerPhaseBundle) CreatePrepPhaseControllers

func (r *JoinerPhaseBundle) CreatePrepPhaseControllers() []core.PrepPhaseController

func (*JoinerPhaseBundle) IsDynamicPopulationRequired

func (r *JoinerPhaseBundle) IsDynamicPopulationRequired() bool

func (JoinerPhaseBundle) String

func (r JoinerPhaseBundle) String() string

type RegularPhaseBundle

type RegularPhaseBundle struct {
	BundleFactories
	BundleConfig
}

func (*RegularPhaseBundle) CreateFullPhaseControllers

func (r *RegularPhaseBundle) CreateFullPhaseControllers(nodeCount int) ([]core.PhaseController, core.NodeUpdateCallback)

func (*RegularPhaseBundle) CreatePrepPhaseControllers

func (r *RegularPhaseBundle) CreatePrepPhaseControllers() []core.PrepPhaseController

func (*RegularPhaseBundle) IsDynamicPopulationRequired

func (r *RegularPhaseBundle) IsDynamicPopulationRequired() bool

func (RegularPhaseBundle) String

func (r RegularPhaseBundle) String() string