Function TestGetCandidateMembers_OfflineNode

internal/server/db/node_test.go:333–358

If there are nodes, and one of them is offline, return the name of the online node, even if the offline one has more instances.

(t *testing.T)

// If there are nodes, and one of them is offline, return the name of the
// online node, even if the offline one has more instances.
func TestGetCandidateMembers_OfflineNode(t *testing.T) {
	tx, cleanup := db.NewTestClusterTx(t)
	defer cleanup()

	id, err := tx.CreateNode("buzz", "1.2.3.4:666")
	require.NoError(t, err)

	// Add an instance to the newly created node.
	_, err = tx.Tx().Exec(`
INSERT INTO instances (id, node_id, name, architecture, type, project_id, description) VALUES (1, ?, 'foo', 1, 1, 1, '')
`, id)
	require.NoError(t, err)

	// Mark the default node has offline.
	err = tx.SetNodeHeartbeat("0.0.0.0", time.Now().Add(-time.Minute))
	require.NoError(t, err)

	allMembers, err := tx.GetNodes(context.Background())
	require.NoError(t, err)

	members, err := tx.GetCandidateMembers(context.Background(), allMembers, nil, "", nil, time.Duration(db.DefaultOfflineThreshold)*time.Second)
	require.NoError(t, err)
	require.Len(t, members, 1)

	assert.Equal(t, "buzz", members[0].Name)
}

// If there are 2 online nodes, and an instance is pending on one of them,
// return the address of the other one number of instances.