trivialsyncmanager

Documentation

Index

• func NewProvider(opts ...options.Option[SyncManager]) module.Provider[*engine.Engine, syncmanager.SyncManager]
• func WithBootstrappedThreshold(threshold time.Duration) options.Option[SyncManager]
• func WithIsBootstrappedFunc(isBootstrapped isBootstrappedFunc) options.Option[SyncManager]
• func WithSyncThreshold(threshold time.Duration) options.Option[SyncManager]
• type SyncManager
  • func New(subModule module.Module, e *engine.Engine, latestCommitment *model.Commitment, ...) *SyncManager
  • func (s *SyncManager) IsBootstrapped() bool
  • func (s *SyncManager) IsFinalizationDelayed() bool
  • func (s *SyncManager) IsNodeSynced() bool
  • func (s *SyncManager) LastAcceptedBlockSlot() iotago.SlotIndex
  • func (s *SyncManager) LastConfirmedBlockSlot() iotago.SlotIndex
  • func (s *SyncManager) LastPrunedEpoch() (iotago.EpochIndex, bool)
  • func (s *SyncManager) LatestCommitment() *model.Commitment
  • func (s *SyncManager) LatestFinalizedSlot() iotago.SlotIndex
  • func (s *SyncManager) Reset()
  • func (s *SyncManager) SyncStatus() *syncmanager.SyncStatus

Functions

func NewProvider

func NewProvider(opts ...options.Option[SyncManager]) module.Provider[*engine.Engine, syncmanager.SyncManager]

NewProvider creates a new SyncManager provider.

func WithBootstrappedThreshold

func WithBootstrappedThreshold(threshold time.Duration) options.Option[SyncManager]

func WithIsBootstrappedFunc

func WithIsBootstrappedFunc(isBootstrapped isBootstrappedFunc) options.Option[SyncManager]

func WithSyncThreshold

func WithSyncThreshold(threshold time.Duration) options.Option[SyncManager]

Types

type SyncManager

type SyncManager struct {
	module.Module
	// contains filtered or unexported fields
}

func New

func New(subModule module.Module, e *engine.Engine, latestCommitment *model.Commitment, finalizedSlot iotago.SlotIndex, opts ...options.Option[SyncManager]) *SyncManager

func (*SyncManager) IsBootstrapped

func (s *SyncManager) IsBootstrapped() bool

func (*SyncManager) IsFinalizationDelayed

func (s *SyncManager) IsFinalizationDelayed() bool

func (*SyncManager) IsNodeSynced

func (s *SyncManager) IsNodeSynced() bool

func (*SyncManager) LastAcceptedBlockSlot

func (s *SyncManager) LastAcceptedBlockSlot() iotago.SlotIndex

func (*SyncManager) LastConfirmedBlockSlot

func (s *SyncManager) LastConfirmedBlockSlot() iotago.SlotIndex

func (*SyncManager) LastPrunedEpoch

func (s *SyncManager) LastPrunedEpoch() (iotago.EpochIndex, bool)

func (*SyncManager) LatestCommitment

func (s *SyncManager) LatestCommitment() *model.Commitment

func (*SyncManager) LatestFinalizedSlot

func (s *SyncManager) LatestFinalizedSlot() iotago.SlotIndex

func (*SyncManager) Reset

func (s *SyncManager) Reset()

Reset resets the component to a clean state as if it was created at the last commitment.

func (*SyncManager) SyncStatus

func (s *SyncManager) SyncStatus() *syncmanager.SyncStatus