get plugin service from cluster

testing/framework/cluster/service.go

@@ -0,0 +1,20 @@
+package cluster
+
+import (
+	"context"
+	corev1 "k8s.io/api/core/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+)
+
+func Service(ctx context.Context, clt client.Client, name string) (*corev1.Service, error) {
+	services := &corev1.ServiceList{}
+
+	if err := clt.List(ctx, services, client.MatchingLabels{"plugin": name}); err != nil {
+		return nil, err
+	}
+
+	if len(services.Items) > 0 {
+		return &services.Items[0], nil
+	}
+	return nil, nil
+}