long_running

package

v0.0.0-...-357059b Latest Latest Go to latest Published: May 20, 2026 License: BSD-3-Clause Imports: 8 Imported by: 0

Details

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

Repository

github.com/ava-labs/simplex

Links

Open Source Insights

Documentation ¶

Index ¶

type LongRunningBlockBuilder
- func NewNetworkBlockBuilder(t *testing.T) *LongRunningBlockBuilder
type LongRunningInMemoryNetwork
- func NewDefaultLongRunningNetwork(t *testing.T, numNodes int) *LongRunningInMemoryNetwork
type LongRunningNode
- func NewLongRunningNode(t *testing.T, nodeID simplex.NodeID, ...) *LongRunningNode

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type LongRunningBlockBuilder ¶

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

func NewNetworkBlockBuilder ¶

func NewNetworkBlockBuilder(t *testing.T) *LongRunningBlockBuilder

func (*LongRunningBlockBuilder) BuildBlock ¶

func (b *LongRunningBlockBuilder) BuildBlock(
	ctx context.Context,
	metadata simplex.ProtocolMetadata,
	blacklist simplex.Blacklist,
) (simplex.VerifiedBlock, bool)

func (*LongRunningBlockBuilder) TriggerBlockShouldBeBuilt ¶

func (b *LongRunningBlockBuilder) TriggerBlockShouldBeBuilt()

func (*LongRunningBlockBuilder) TriggerBlockShouldNotBeBuilt ¶

func (b *LongRunningBlockBuilder) TriggerBlockShouldNotBeBuilt()

func (*LongRunningBlockBuilder) WaitForPendingBlock ¶

func (b *LongRunningBlockBuilder) WaitForPendingBlock(ctx context.Context)

type LongRunningInMemoryNetwork ¶

type LongRunningInMemoryNetwork struct {
	*testutil.BasicInMemoryNetwork
	// contains filtered or unexported fields
}

func NewDefaultLongRunningNetwork ¶

func NewDefaultLongRunningNetwork(t *testing.T, numNodes int) *LongRunningInMemoryNetwork

func (*LongRunningInMemoryNetwork) ConnectNodes ¶

func (n *LongRunningInMemoryNetwork) ConnectNodes(nodeIndexes ...uint64)

func (*LongRunningInMemoryNetwork) ContinueBlocks ¶

func (n *LongRunningInMemoryNetwork) ContinueBlocks()

func (*LongRunningInMemoryNetwork) CrashNodes ¶

func (n *LongRunningInMemoryNetwork) CrashNodes(nodeIndexes ...uint64)

func (*LongRunningInMemoryNetwork) DisconnectNodes ¶

func (n *LongRunningInMemoryNetwork) DisconnectNodes(nodeIndexes ...uint64)

func (*LongRunningInMemoryNetwork) GetInstance ¶

func (n *LongRunningInMemoryNetwork) GetInstance(index int) *LongRunningNode

func (*LongRunningInMemoryNetwork) NoMoreBlocks ¶

func (n *LongRunningInMemoryNetwork) NoMoreBlocks()

func (*LongRunningInMemoryNetwork) StartInstances ¶

func (n *LongRunningInMemoryNetwork) StartInstances()

func (*LongRunningInMemoryNetwork) StartNodes ¶

func (n *LongRunningInMemoryNetwork) StartNodes(nodeIndexes ...uint64)

func (*LongRunningInMemoryNetwork) StopAndAssert ¶

func (n *LongRunningInMemoryNetwork) StopAndAssert(tailingMessages bool)

StopAndAssert stops all nodes and asserts their storage and WALs are consistent. If tailingMessages is true, it will also assert that no extra messages are being sent after telling the network no more blocks should be built. TailingMessages is useful for debugging, but is currently flakey because NoMoreBlocks does not stop block building atomically for all nodes in the network. Therefore, some nodes may timeout on a block they think should be built, and keep resending empty votes.

func (*LongRunningInMemoryNetwork) UpdateTime ¶

func (n *LongRunningInMemoryNetwork) UpdateTime(frequency time.Duration, increment time.Duration)

func (*LongRunningInMemoryNetwork) WaitForNodesToEnterRound ¶

func (n *LongRunningInMemoryNetwork) WaitForNodesToEnterRound(round uint64, nodeIndexes ...uint64)

type LongRunningNode ¶

type LongRunningNode struct {
	*testutil.BasicNode

	Storage *testutil.InMemStorage
	// contains filtered or unexported fields
}

func NewLongRunningNode ¶

func NewLongRunningNode(t *testing.T, nodeID simplex.NodeID, basicNetwork *testutil.BasicInMemoryNetwork, options longRunningNodeConfig) *LongRunningNode

Source Files ¶

View all Source files

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