/
sproxy.go
59 lines (46 loc) · 1.55 KB
/
sproxy.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
package main
import (
goflag "flag"
"net/http"
_ "github.com/k3s-io/k3s/pkg/cloudprovider" // duct-tape on klipper-lb
"github.com/k3s-io/k3s/pkg/version"
"github.com/spf13/pflag"
"k8s.io/apiserver/pkg/server/healthz"
"k8s.io/cloud-provider/app"
"k8s.io/klog/v2"
"k8s.io/apimachinery/pkg/util/wait"
cloudprovider "k8s.io/cloud-provider"
"k8s.io/cloud-provider/app/config"
"k8s.io/cloud-provider/options"
"k8s.io/component-base/cli/flag"
"k8s.io/component-base/logs"
)
func init() {
healthz.InstallHandler(http.DefaultServeMux)
}
func main() {
ccmOptions, err := options.NewCloudControllerManagerOptions()
if err != nil {
klog.Fatalf("unable to initialize command options: %v", err)
}
ccmOptions.KubeCloudShared.CloudProvider.Name = version.Program
ccmOptions.Authentication.SkipInClusterLookup = true
command := app.NewCloudControllerManagerCommand(ccmOptions, cloudInitializer, app.DefaultInitFuncConstructors, flag.NamedFlagSets{}, wait.NeverStop)
pflag.CommandLine.SetNormalizeFunc(flag.WordSepNormalizeFunc)
pflag.CommandLine.AddGoFlagSet(goflag.CommandLine)
defer logs.FlushLogs()
if err := command.Execute(); err != nil {
klog.Fatal(err)
}
}
func cloudInitializer(c *config.CompletedConfig) cloudprovider.Interface {
cloudConfig := c.ComponentConfig.KubeCloudShared.CloudProvider
cloud, err := cloudprovider.InitCloudProvider(version.Program, cloudConfig.CloudConfigFile)
if err != nil {
klog.Fatalf("Cloud provider could not be initialized: %v", err)
}
if cloud == nil {
klog.Fatalf("Cloud provider is nil")
}
return cloud
}