/
local-cluster.go
47 lines (36 loc) · 1.17 KB
/
local-cluster.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
package target
import (
"context"
"net/http"
sigsk8sclient "sigs.k8s.io/controller-runtime/pkg/client"
sigsk8sconfig "sigs.k8s.io/controller-runtime/pkg/client/config"
"github.com/tsuru/rpaas-operator/internal/pkg/rpaas"
"github.com/tsuru/rpaas-operator/pkg/observability"
extensionsruntime "github.com/tsuru/rpaas-operator/pkg/runtime"
)
var _ Factory = &localClusterFactory{}
type localClusterFactory struct {
manager rpaas.RpaasManager
}
func (l *localClusterFactory) Manager(ctx context.Context, header http.Header) (rpaas.RpaasManager, error) {
return l.manager, nil
}
func NewKubeConfigFactory() (Factory, error) {
restConfig, err := sigsk8sconfig.GetConfig()
if err != nil {
return nil, err
}
restConfig.WrapTransport = observability.OpentracingTransport
k8sClient, err := sigsk8sclient.New(restConfig, sigsk8sclient.Options{Scheme: extensionsruntime.NewScheme()})
if err != nil {
return nil, err
}
manager, err := rpaas.NewK8S(restConfig, k8sClient, "", "")
if err != nil {
return nil, err
}
return &localClusterFactory{manager: manager}, nil
}
func NewLocalFactory(manager rpaas.RpaasManager) Factory {
return &localClusterFactory{manager: manager}
}