Function TestClientPilotPlugin

plugin_test.go:88–132

(t *testing.T)

}

func TestClientPilotPlugin(t *testing.T) {
	t.Parallel()

	ctx := context.Background()

	type testBundle struct {
		pluginDriver *TestDriverWithPlugin
		pluginPilot  *TestPilotWithPlugin
	}

	setup := func(t *testing.T) (*Client[pgx.Tx], *testBundle) {
		t.Helper()

		var (
			dbPool       = riversharedtest.DBPool(ctx, t)
			driver       = riverpgxv5.New(dbPool)
			schema       = riverdbtest.TestSchema(ctx, t, driver, nil)
			config       = newTestConfig(t, schema)
			pluginDriver = newDriverWithPlugin(t, dbPool)
			pluginPilot  = newPilotWithPlugin(t)
		)
		pluginDriver.pilot = pluginPilot

		client, err := NewClient(pluginDriver, config)
		require.NoError(t, err)

		return client, &testBundle{
			pluginDriver: pluginDriver,
			pluginPilot:  pluginPilot,
		}
	}

	t.Run("ServicesStart", func(t *testing.T) {
		t.Parallel()

		client, bundle := setup(t)

		startClient(ctx, t, client)

		riversharedtest.WaitOrTimeout(t, startstop.WaitAllStartedC(
			bundle.pluginPilot.maintenanceService,
			bundle.pluginPilot.service,
		))
	})
}

var _ pilotPlugin = &TestPilotWithPlugin{}