This repository has been archived by the owner on Nov 30, 2023. It is now read-only.
/
factory.go
87 lines (72 loc) · 2.51 KB
/
factory.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package tenantcluster
import (
"context"
"fmt"
"github.com/giantswarm/certs/v4/pkg/certs"
"github.com/giantswarm/errors/tenant"
"github.com/giantswarm/k8sclient/v7/pkg/k8sclient"
"github.com/giantswarm/microerror"
"github.com/giantswarm/micrologger"
"github.com/giantswarm/tenantcluster/v6/pkg/tenantcluster"
"k8s.io/client-go/rest"
capi "sigs.k8s.io/cluster-api/api/v1beta1"
"sigs.k8s.io/controller-runtime/pkg/client"
"github.com/giantswarm/azure-operator/v6/pkg/project"
"github.com/giantswarm/azure-operator/v6/service/controller/key"
)
type tenantClientFactory struct {
logger micrologger.Logger
tenantRestConfigProvider tenantcluster.Interface
}
func NewFactory(certsSearcher certs.Interface, logger micrologger.Logger) (Factory, error) {
if certsSearcher == nil {
return nil, microerror.Maskf(invalidConfigError, "certsSearcher must not be empty")
}
if logger == nil {
return nil, microerror.Maskf(invalidConfigError, "logger must not be empty")
}
c := tenantcluster.Config{
CertsSearcher: certsSearcher,
Logger: logger,
CertID: certs.APICert,
}
tenantRestConfigProvider, err := tenantcluster.New(c)
if err != nil {
return nil, microerror.Mask(err)
}
f := &tenantClientFactory{
logger: logger,
tenantRestConfigProvider: tenantRestConfigProvider,
}
return f, nil
}
func (tcf *tenantClientFactory) GetAllClients(ctx context.Context, cr *capi.Cluster) (k8sclient.Interface, error) {
tcf.logger.Debugf(ctx, "creating tenant cluster k8s client for cluster %#q", key.ClusterID(cr))
var k8sClient k8sclient.Interface
{
restConfig, err := tcf.tenantRestConfigProvider.NewRestConfig(ctx, key.ClusterID(cr), cr.Spec.ControlPlaneEndpoint.String())
if tenant.IsAPINotAvailable(err) || tenantcluster.IsTimeout(err) {
return nil, microerror.Mask(apiNotAvailableError)
} else if err != nil {
return nil, microerror.Mask(err)
}
restConfig.UserAgent = fmt.Sprintf("%s/%s", project.Name(), project.Version())
k8sClient, err = k8sclient.NewClients(k8sclient.ClientsConfig{
Logger: tcf.logger,
RestConfig: rest.CopyConfig(restConfig),
})
if tenant.IsAPINotAvailable(err) {
return nil, microerror.Mask(apiNotAvailableError)
} else if err != nil {
return nil, microerror.Mask(err)
}
}
return k8sClient, nil
}
func (tcf *tenantClientFactory) GetClient(ctx context.Context, cr *capi.Cluster) (client.Client, error) {
all, err := tcf.GetAllClients(ctx, cr)
if err != nil {
return nil, microerror.Mask(err)
}
return all.CtrlClient(), nil
}