Function TestPluginInit

pkg/managers/pluginmanager/pluginmanager_test.go:297–334

(t *testing.T)

}

func TestPluginInit(t *testing.T) {
	log.SetupZapLogger(log.GetDefaultLogOpts())
	tel := telemetry.NewNoopTelemetry()
	tests := []struct {
		name       string
		cfg        kcfg.Config
		pluginName string
		wantErr    bool
	}{
		{
			name:       "Plugin init successes Pod Level Disabled",
			cfg:        cfgPodLevelDisabled,
			pluginName: "mockplugin",
			wantErr:    false,
		},
		{
			name:       "Plugin init successes Pod Level Enabled",
			cfg:        cfgPodLevelEnabled,
			pluginName: "mockplugin",
			wantErr:    false,
		},
	}
	for _, tt := range tests {
		tt.cfg.EnabledPlugin = append(tt.cfg.EnabledPlugin, tt.pluginName)
		mgr, err := NewPluginManager(&tt.cfg, tel, slog.Default())
		require.Nil(t, err, "Expected nil but got error:%w", err)
		for _, plugin := range mgr.plugins {
			if tt.wantErr {
				err := plugin.Init()
				require.NotNil(t, err, "Expected Init err but got nil")
				require.ErrorContains(t, err, "event channel is nil", "Expected event channel nil but got:%w", err)
			} else {
				err := plugin.Init()
				require.Nil(t, err, "Expected nil but got init error:%w", err)
			}
		}
	}
}

func TestPluginStartWithoutInit(t *testing.T) {
	log.SetupZapLogger(log.GetDefaultLogOpts())