Function newPilotWithPlugin

plugin_test.go:143–170

(t *testing.T)

}

func newPilotWithPlugin(t *testing.T) *TestPilotWithPlugin {
	t.Helper()

	newService := func(name string) startstop.Service {
		return startstop.StartStopFunc(func(ctx context.Context, shouldStart bool, started, stopped func()) error {
			if !shouldStart {
				return nil
			}

			go func() {
				started()
				defer stopped() // this defer should come first so it's last out

				t.Logf("Test service started: %s", name)

				<-ctx.Done()
			}()

			return nil
		})
	}

	return &TestPilotWithPlugin{
		StandardPilot:      riverpilot.StandardPilot{},
		maintenanceService: newService("maintenance service"),
		service:            newService("other service"),
	}
}

func (d *TestPilotWithPlugin) PluginMaintenanceServices() []startstop.Service {
	return []startstop.Service{d.maintenanceService}