scheduler

package

v0.11.0 Latest Latest Go to latest Published: Mar 24, 2026 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/wavesplatform/gowaves

Links

Open Source Insights

Documentation ¶

Index ¶

func IsBlockObsolete(ntpTime types.Time, obsolescencePeriod time.Duration, ...) (bool, time.Time, error)
type Default
- func NewScheduler(state state.State, seeder seeder, settings *settings.BlockchainSettings, ...) (*Default, error)
type DisabledScheduler
type Emit
type MinerConsensusImpl
- func NewMinerConsensus(c connectedCount, atLeastConnectedPeers int) MinerConsensusImpl
- func (a MinerConsensusImpl) IsMiningAllowed() bool
type StubConsensus
- func (s StubConsensus) IsMiningAllowed() bool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsBlockObsolete ¶ added in v0.11.0

func IsBlockObsolete(ntpTime types.Time,
	obsolescencePeriod time.Duration, lastBlockTimestamp uint64) (bool, time.Time, error)

Types ¶

type Default ¶ added in v0.10.4

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

func NewScheduler ¶

func NewScheduler(
	state state.State,
	seeder seeder,
	settings *settings.BlockchainSettings,
	tm types.Time,
	consensus types.MinerConsensus,
	minerDelay time.Duration,
	generateInPast bool) (*Default, error)

func (*Default) Emits ¶ added in v0.10.4

func (a *Default) Emits() []Emit

func (*Default) Mine ¶ added in v0.10.4

func (a *Default) Mine() chan Emit

func (*Default) Reschedule ¶ added in v0.10.4

func (a *Default) Reschedule()

type DisabledScheduler ¶ added in v0.8.0

type DisabledScheduler struct {
}

func (DisabledScheduler) Emits ¶ added in v0.8.0

func (d DisabledScheduler) Emits() []Emit

func (DisabledScheduler) Mine ¶ added in v0.8.0

func (d DisabledScheduler) Mine() chan Emit

func (DisabledScheduler) Reschedule ¶ added in v0.8.0

func (d DisabledScheduler) Reschedule()

type Emit ¶

type Emit struct {
	Timestamp    uint64
	KeyPair      proto.KeyPair
	GenSignature []byte
	VRF          []byte
	BaseTarget   types.BaseTarget
	Parent       proto.BlockID
}

type MinerConsensusImpl ¶ added in v0.5.0

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

func NewMinerConsensus ¶ added in v0.5.0

func NewMinerConsensus(c connectedCount, atLeastConnectedPeers int) MinerConsensusImpl

func (MinerConsensusImpl) IsMiningAllowed ¶ added in v0.5.0

func (a MinerConsensusImpl) IsMiningAllowed() bool

type StubConsensus ¶ added in v0.5.0

type StubConsensus struct {
}

func (StubConsensus) IsMiningAllowed ¶ added in v0.5.0

func (s StubConsensus) IsMiningAllowed() bool

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL