mirror of
https://github.com/open-cluster-management-io/ocm.git
synced 2026-08-22 13:47:06 +00:00
Jian QiuandGitHub
c367622060
* Move addon api to beta in registration Signed-off-by: Jian Qiu <jqiu@redhat.com> * Update conversion e2e tests Signed-off-by: Jian Qiu <jqiu@redhat.com> * Add addon v1beta1 to supported type in grpc Signed-off-by: Jian Qiu <jqiu@redhat.com> * Fix flaky e2e in addon conversion Signed-off-by: Jian Qiu <jqiu@redhat.com> * Set subject for registration configuration when it is not set Signed-off-by: Jian Qiu <jqiu@redhat.com> --------- Signed-off-by: Jian Qiu <jqiu@redhat.com>
78 lines
2.8 KiB
Go
78 lines
2.8 KiB
Go
package grpc
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/openshift/library-go/pkg/controller/controllercmd"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
kubeinformers "k8s.io/client-go/informers"
|
|
"k8s.io/client-go/kubernetes"
|
|
|
|
addonclient "open-cluster-management.io/api/client/addon/clientset/versioned"
|
|
addoninformers "open-cluster-management.io/api/client/addon/informers/externalversions"
|
|
clusterv1client "open-cluster-management.io/api/client/cluster/clientset/versioned"
|
|
clusterv1informers "open-cluster-management.io/api/client/cluster/informers/externalversions"
|
|
workclientset "open-cluster-management.io/api/client/work/clientset/versioned"
|
|
workinformers "open-cluster-management.io/api/client/work/informers/externalversions"
|
|
clusterv1 "open-cluster-management.io/api/cluster/v1"
|
|
)
|
|
|
|
type Clients struct {
|
|
KubeClient kubernetes.Interface
|
|
ClusterClient clusterv1client.Interface
|
|
WorkClient workclientset.Interface
|
|
AddOnClient addonclient.Interface
|
|
KubeInformers kubeinformers.SharedInformerFactory
|
|
ClusterInformers clusterv1informers.SharedInformerFactory
|
|
WorkInformers workinformers.SharedInformerFactory
|
|
AddOnInformers addoninformers.SharedInformerFactory
|
|
}
|
|
|
|
func NewClients(controllerContext *controllercmd.ControllerContext) (*Clients, error) {
|
|
kubeClient, err := kubernetes.NewForConfig(controllerContext.KubeConfig)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
clusterClient, err := clusterv1client.NewForConfig(controllerContext.KubeConfig)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
addonClient, err := addonclient.NewForConfig(controllerContext.KubeConfig)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
workClient, err := workclientset.NewForConfig(controllerContext.KubeConfig)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &Clients{
|
|
KubeClient: kubeClient,
|
|
ClusterClient: clusterClient,
|
|
AddOnClient: addonClient,
|
|
WorkClient: workClient,
|
|
KubeInformers: kubeinformers.NewSharedInformerFactoryWithOptions(kubeClient, 30*time.Minute,
|
|
kubeinformers.WithTweakListOptions(func(listOptions *metav1.ListOptions) {
|
|
selector := &metav1.LabelSelector{
|
|
MatchExpressions: []metav1.LabelSelectorRequirement{
|
|
{
|
|
Key: clusterv1.ClusterNameLabelKey,
|
|
Operator: metav1.LabelSelectorOpExists,
|
|
},
|
|
},
|
|
}
|
|
listOptions.LabelSelector = metav1.FormatLabelSelector(selector)
|
|
})),
|
|
ClusterInformers: clusterv1informers.NewSharedInformerFactory(clusterClient, 30*time.Minute),
|
|
WorkInformers: workinformers.NewSharedInformerFactoryWithOptions(workClient, 30*time.Minute),
|
|
AddOnInformers: addoninformers.NewSharedInformerFactory(addonClient, 30*time.Minute),
|
|
}, nil
|
|
}
|
|
|
|
func (h *Clients) Run(ctx context.Context) {
|
|
go h.KubeInformers.Start(ctx.Done())
|
|
go h.ClusterInformers.Start(ctx.Done())
|
|
go h.WorkInformers.Start(ctx.Done())
|
|
go h.AddOnInformers.Start(ctx.Done())
|
|
}
|