isaacstates

type BallotBroadcaster interface {
	Broadcast(base.Ballot) error
	Ballot(_ base.Point, _ base.Stage, isSuffrageConfirm bool) (base.Ballot, bool, error)
}

type BallotStuckResolver interface {
	NewPoint(context.Context, base.StagePoint) bool
	Voteproof() <-chan base.Voteproof
	Clean()
	Cancel(base.StagePoint)
}

type Ballotbox struct {
	*util.ContextDaemon
	*logging.Logging
	// contains filtered or unexported fields
}

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

type BootingHandlerArgs struct {
	LastManifestFunc         func() (base.Manifest, bool, error)
	NodeInConsensusNodesFunc isaac.NodeInConsensusNodesFunc
}

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

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

type ConsensusHandlerArgs struct {
	ProposalProcessors    *isaac.ProposalProcessors
	GetManifestFunc       func(base.Height) (base.Manifest, error)
	WhenNewBlockSaved     func(base.Height)
	WhenNewBlockConfirmed func(base.Height)
	// contains filtered or unexported fields
}

type DefaultBallotBroadcaster struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type DefaultBallotStuckResolver struct {
	*logging.Logging
	// contains filtered or unexported fields
}

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

type JoiningHandlerArgs struct {
	LastManifestFunc    func() (base.Manifest, bool, error)
	JoinMemberlistFunc  func(context.Context, base.Suffrage) error
	LeaveMemberlistFunc func(time.Duration) error
	WaitFirstVoteproof  time.Duration
	// contains filtered or unexported fields
}

type LastPoint struct {
	base.StagePoint
	// contains filtered or unexported fields
}

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

type LastVoteproofsHandler struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MissingBallotsRequestMessage struct {
	hint.BaseHinter
	// contains filtered or unexported fields
}

type NewBlockImporterFunc func(base.BlockMap) (isaac.BlockImporter, error)

type NewBootingHandlerType struct {
	*BootingHandler
}

type NewBrokenHandlerType struct {
	*BrokenHandler
}

type NewConsensusHandlerType struct {
	*ConsensusHandler
}

type NewImportBlocksFunc func(
	_ context.Context,
	from, to base.Height,
	batchlimit int64,
	blockMapFunc func(context.Context, base.Height) (base.BlockMap, bool, error),
) error

type NewJoiningHandlerType struct {
	*JoiningHandler
}

type NewStoppedHandlerType struct {
	*StoppedHandler
}

type NewSyncingHandlerType struct {
	*SyncingHandler
}

type StateType string

type States struct {
	*logging.Logging

	*util.ContextDaemon
	// contains filtered or unexported fields
}

type StatesArgs struct {
	Ballotbox              *Ballotbox
	BallotStuckResolver    BallotStuckResolver
	LastVoteproofsHandler  *LastVoteproofsHandler
	IsInSyncSourcePoolFunc func(base.Address) bool
	BallotBroadcaster      BallotBroadcaster
	WhenStateSwitchedFunc  func(StateType)
}

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

type SuffrageVotingFindFunc func(context.Context, base.Height, base.Suffrage) ([]base.SuffrageWithdrawOperation, error)

type Syncer struct {
	*logging.Logging
	*util.ContextDaemon
	// contains filtered or unexported fields
}

type SyncerArgs struct {
	LastBlockMapFunc     SyncerLastBlockMapFunc
	BlockMapFunc         SyncerBlockMapFunc
	TempSyncPool         isaac.TempSyncPool
	WhenStoppedFunc      func() error
	RemovePrevBlockFunc  func(base.Height) (bool, error)
	NewImportBlocksFunc  NewImportBlocksFunc
	BatchLimit           int64
	LastBlockMapInterval time.Duration
	LastBlockMapTimeout  time.Duration
}

type SyncerBlockMapFunc func(context.Context, base.Height) (base.BlockMap, bool, error)

type SyncerBlockMapItemFunc func(
	context.Context, base.Height, base.BlockMapItemType) (io.ReadCloser, func() error, bool, error)

type SyncerLastBlockMapFunc func(_ context.Context, manifest util.Hash) (

	_ base.BlockMap, updated bool, _ error) // NOTE BlockMap.IsValid() should be called

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

type SyncingHandlerArgs struct {
	NodeInConsensusNodesFunc isaac.NodeInConsensusNodesFunc
	NewSyncerFunc            func(base.Height) (isaac.Syncer, error)
	WhenFinishedFunc         func(base.Height)
	JoinMemberlistFunc       func(context.Context, base.Suffrage) error
	LeaveMemberlistFunc      func(time.Duration) error
	WhenNewBlockSavedFunc    func(base.Height)
	WaitStuckInterval        time.Duration
}

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