mgr.Add函数用法:在mgr启动的时候会一起把这个对象也启动了

字数统计: 293阅读时长: 1 min

 2021/12/28   Share

package k8sconfig

import (
	v1 "github.com/haojianxun/dbcore/pkg/apis/dbconfig/v1"
	"github.com/haojianxun/dbcore/pkg/controllers"
	"github.com/haojianxun/dbcore/pkg/dashboard"
	appsv1 "k8s.io/api/apps/v1"
	"os"
	"sigs.k8s.io/controller-runtime/pkg/builder"
	"sigs.k8s.io/controller-runtime/pkg/handler"
	"sigs.k8s.io/controller-runtime/pkg/log/zap"
	logf "sigs.k8s.io/controller-runtime/pkg/log"
	"sigs.k8s.io/controller-runtime/pkg/manager"
	"sigs.k8s.io/controller-runtime/pkg/manager/signals"
	"sigs.k8s.io/controller-runtime/pkg/source"
)

func InitManager() {
	logf.SetLogger(zap.New())
	mgr ,err:= manager.New(K8sRestConfig(),manager.Options{
		Logger: logf.Log.WithName("dbcore"),
	})
	if err != nil {
		mgr.GetLogger().Error(err,"could not create manager")
		os.Exit(1)
	}
	if err = v1.SchemeBuilder.AddToScheme(mgr.GetScheme());err!=nil {
		mgr.GetLogger().Error(err,"unable to schme")
		os.Exit(1)
	}
	dbConfigController:=controllers.NewDbConfigController()
	if err = builder.ControllerManagedBy(mgr).
		For(&v1.DbConfig{}).
		Watches(&source.Kind{Type: &appsv1.Deployment{}},
			handler.Funcs{
			DeleteFunc: dbConfigController.OnDelete,
			UpdateFunc: dbConfigController.OnUpdate},).
		Complete(controllers.NewDbConfigController());err!=nil{
			mgr.GetLogger().Error(err,"unable to create manager")
			os.Exit(1)
	}

	if err:=mgr.Add(dashboard.NewAdmiUi());err!=nil{
		mgr.GetLogger().Error(err,"unable to create dashboard")
		os.Exit(1)
	}
	if err= mgr.Start(signals.SetupSignalHandler());err!= nil {
		mgr.GetLogger().Error(err,"unable to start manager")
	}

}

在上面中mgr.add会把里面那个类型的东西也启动了只要他实现了runable这个方法

也就是只要实现了

1	func Start(ctx context.Context) error

即可

一般用在搞一个内置的dashboard

原文作者：HAOJX

原文链接：haojianxun.github.io/2021/12/28/mgr.Add函数用法在mgr启动的时候会一起把这个对象也启动了/

发表日期：December 28th 2021, 12:00:00 am

更新日期：October 14th 2022, 1:09:21 am

Next Post

如何通过grk来找gvr,或者gvr找gvk
Previous Post

mgr中开启控制器选主

CATALOG



缺失模块。
1、请确保node版本大于6.2
2、在博客根目录（注意不是archer根目录）执行以下命令：
npm i hexo-generator-json-content --save
3、在根目录_config.yml里添加配置：

jsonContent:
  meta: false
  pages: false
  posts:
    title: true
    date: true
    path: true
    text: false
    raw: false
    content: false
    slug: false
    updated: false
    comments: false
    link: false
    permalink: false
    excerpt: false
    categories: true
    tags: true