Function RunReplicationScripts

pgserver/logrepl/replication_test.go:648–691

RunScripts runs the given collection of scripts.

(t *testing.T, scripts []ReplicationTest)

// RunScripts runs the given collection of scripts.
func RunReplicationScripts(t *testing.T, scripts []ReplicationTest) {
	// First, we'll run through the scripts to check for the Focus variable. If it's true, then append it to the new slice.
	focusScripts := make([]ReplicationTest, 0, len(scripts))
	for _, script := range scripts {
		if script.Focus {
			// If this is running in GitHub Actions, then we'll panic, because someone forgot to disable it before committing
			if _, ok := os.LookupEnv("GITHUB_ACTION"); ok {
				panic(fmt.Sprintf("The script `%s` has Focus set to `true`. GitHub Actions requires that "+
					"all tests are run, which Focus circumvents, leading to this error. Please disable Focus on "+
					"all tests.", script.Name))
			}
			focusScripts = append(focusScripts, script)
		}
	}
	// If we have scripts with Focus set, then we replace the normal script slice with the new slice.
	if len(focusScripts) > 0 {
		scripts = focusScripts
	}

	// start the docker container
	containerName, dsn, _, err := StartPostgresServer()
	require.NoError(t, err)
	defer func() {
		err := exec.Command("docker", "kill", containerName).Run()
		require.NoError(t, err)
	}()

	primaryDns := dsn + "?sslmode=disable"

	// We drop and recreate the replication slot once at the beginning of the test suite. Postgres seems to do a little
	// work in the background with a publication, so we need to wait a little bit before running any test scripts.
	require.NoError(t, logrepl.DropPublication(primaryDns, slotName))
	require.NoError(t, logrepl.CreatePublicationIfNotExists(primaryDns, slotName))
	time.Sleep(500 * time.Millisecond)

	// for i, script := range scripts {
	// 	if i == 10 {
	// 		RunReplicationScript(t, dsn, script)
	// 	}
	// }
	for _, script := range scripts {
		RunReplicationScript(t, dsn, script)
	}
}

const slotName = "myduck_slot"
const subscriptionName = "my_sub_test"