k8s

sCtx := &pluginsCoreMock.SetupContext{}
fakeKubeClient := mocks.NewFakeKubeClient()
sCtx.On("KubeClient").Return(fakeKubeClient)
sCtx.On("OwnerKind").Return("test")
sCtx.On("EnqueueOwner").Return(pluginsCore.EnqueueOwner(func(name k8stypes.NamespacedName) error { return nil }))
sCtx.On("MetricsScope").Return(promutils.NewTestScope())
exec, err := NewPluginManager(
	context.TODO(),
	sCtx,
	k8s.PluginEntry{
		ID:                  "SampleHandler",
		RegisteredTaskTypes: []pluginsCore.TaskType{"container"},
		ResourceToWatch:     &v1.Pod{},
		Plugin:              k8sSampleHandler{},
	})
if err == nil {
	fmt.Printf("Created executor: %v\n", exec.GetID())
} else {
	fmt.Printf("Error in creating executor: %s\n", err.Error())
}

Output:

Created executor: SampleHandler