每个程序都需要一个 main 入口

emptymain-cn.go

Apache License

Licensed under the Apache License, Version 2.0 (the “License”); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an “AS IS” BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

我们的 main.go 文件最开始会 import 一些基础的 package。例如：

比较核心的库： controller-runtime
controller-runtime 的默认日志库：Zap（稍后会详细介绍）

package main

import (
	"flag"
	"fmt"
	"os"

	"k8s.io/apimachinery/pkg/runtime"
	_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
	ctrl "sigs.k8s.io/controller-runtime"
	"sigs.k8s.io/controller-runtime/pkg/cache"
	"sigs.k8s.io/controller-runtime/pkg/log/zap"
	// +kubebuilder:scaffold:imports
)

每组 controller 都需要一个 Scheme， Scheme 会提供 Kinds 与 Go types 之间的映射关系(现在你只需要记住这一点)。在编写 API 定义时，我们将会进一步讨论 Kinds。

var (
	scheme   = runtime.NewScheme()
	setupLog = ctrl.Log.WithName("setup")
)

func init() {

	// +kubebuilder:scaffold:scheme
}

此时，我们 main.go 的功能相对来说比较简单：

为 metrics 绑定一些基本的 flags。
实例化一个 manager，用于跟踪我们运行的所有 controllers，并设置 shared caches 和可以连接到 API server 的 k8s clients 实例，并将 Scheme 配置传入 manager。
运行我们的 manager, 而 manager 又运行所有的 controllers 和 webhook。 manager 会一直处于运行状态，直到收到正常关闭信号为止。这样，当我们的 operator 运行在 Kubernetes 上时，我们可以通过优雅的方式终止这个 Pod。

虽然目前我们还没有什么可以运行，但是请记住 +kubebuilder:scaffold:builder 注释的位置 -- 很快那里就会变得有趣。

func main() {
	var metricsAddr string
	flag.StringVar(&metricsAddr, "metrics-addr", ":8080", "The address the metric endpoint binds to.")
	flag.Parse()

	ctrl.SetLogger(zap.New(zap.UseDevMode(true)))

	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{Scheme: scheme, MetricsBindAddress: metricsAddr})
	if err != nil {
		setupLog.Error(err, "unable to start manager")
		os.Exit(1)
	}

请注意：下面代码如果指定了 Namespace 字段, controllers 仍然可以 watch cluster 级别的资源(例如Node), 但是对于 namespace 级别的资源，cache 将仅可以缓存指定 namespace 中的资源。

	mgr, err = ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
		Scheme:             scheme,
		Namespace:          namespace,
		MetricsBindAddress: metricsAddr,
	})

上面的示例将 operator 应用的获取资源范围限制在了单个 namespace。在这种情况下，建议将默认的 ClusterRole 和 ClusterRoleBinding 分别替换为 Role 和 RoleBinding 来将授权限制于此名称空间。有关更多信息，请参见如何使用 RBAC Authorization。

除此之外，你也可以使用 MultiNamespacedCacheBuilder 来监视一组特定的 namespaces：

	var namespaces []string // List of Namespaces

	mgr, err = ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
		Scheme:             scheme,
		NewCache:           cache.MultiNamespacedCacheBuilder(namespaces),
		MetricsBindAddress: fmt.Sprintf("%s:%d", metricsHost, metricsPort),
	})

有关更多信息，请参见 MultiNamespacedCacheBuilder

	// +kubebuilder:scaffold:builder

	setupLog.Info("starting manager")
	if err := mgr.Start(ctrl.SetupSignalHandler()); err != nil {
		setupLog.Error(err, "problem running manager")
		os.Exit(1)
	}
}

有了这些，我们就可以继续创建我们的API！

Kubebuilder 中文文档

每个程序都需要一个 main 入口