di

package
v0.0.23 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2026 License: MIT Imports: 64 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AsynqSet = wire.NewSet(
	InitAsynqClient,
	InitAsynqServer,
	InitScheduler,
)
View Source 
var CacheSet = wire.NewSet(cache.NewMonitorCache, cache.NewAlertManagerConfigCache, cache.NewAlertRuleConfigCache, cache.NewRecordRuleConfigCache, cache.NewPrometheusConfigCache, cache.NewBatchConfigManager)
View Source 
var ClientSet = wire.NewSet(client.NewK8sClient)
View Source 
var CronSet = wire.NewSet(cron.NewUnifiedCronManager, cron.NewBuiltinTaskManager, handler.NewCronHandlers, scheduler.NewCronScheduler)
View Source 
var DaoSet = wire.NewSet(alert.NewAlertManagerEventDAO, alert.NewAlertManagerOnDutyDAO, alert.NewAlertManagerPoolDAO, alert.NewAlertManagerRecordDAO, alert.NewAlertManagerRuleDAO, alert.NewAlertManagerSendDAO, scrape.NewScrapeJobDAO, scrape.NewScrapePoolDAO, config2.NewMonitorConfigDAO, dao.NewUserDAO, dao.NewRoleDAO, dao.NewApiDAO, dao.NewAuditDAO, dao2.NewClusterDAO, dao2.NewYamlTaskDAO, dao2.NewYamlTemplateDAO, dao3.NewWorkorderFormDesignDAO, dao3.NewTemplateDAO, dao3.NewWorkorderInstanceDAO, dao3.NewProcessDAO, dao3.NewWorkorderCategoryDAO, dao3.NewWorkorderInstanceCommentDAO, dao3.NewInstanceFlowDAO, dao3.NewInstanceTimeLineDAO, dao3.NewNotificationDAO, dao4.NewTreeNodeDAO, dao4.NewTreeLocalDAO, dao4.NewTreeCloudDAO, dao4.NewCloudAccountDAO, dao4.NewCloudAccountRegionDAO, dao5.NewCronJobDAO)
View Source 
var HandlerSet = wire.NewSet(api.NewRoleHandler, api.NewApiHandler, api.NewAuditHandler, api.NewSystemHandler, api.NewUserHandler, api2.NewNotAuthHandler, api3.NewK8sNodeHandler, api3.NewK8sClusterHandler, api3.NewK8sDeploymentHandler, api3.NewK8sNamespaceHandler, api3.NewK8sSvcHandler, api3.NewK8sYamlTaskHandler, api3.NewK8sYamlTemplateHandler, api3.NewK8sDaemonSetHandler, api3.NewK8sEventHandler, api3.NewK8sStatefulSetHandler, api3.NewK8sServiceAccountHandler, api3.NewK8sRoleHandler, api3.NewK8sClusterRoleHandler, api3.NewK8sRoleBindingHandler, api3.NewK8sClusterRoleBindingHandler, api3.NewK8sRBACHandler, api3.NewK8sIngressHandler, api3.NewK8sPodHandler, api3.NewK8sConfigMapHandler, api3.NewK8sSecretHandler, api3.NewK8sPVHandler, api3.NewK8sPVCHandler, api4.NewAlertPoolHandler, api4.NewMonitorConfigHandler, api4.NewOnDutyGroupHandler, api4.NewRecordRuleHandler, api4.NewAlertRuleHandler, api4.NewSendGroupHandler, api4.NewScrapeJobHandler, api4.NewScrapePoolHandler, api4.NewAlertEventHandler, api5.NewFormDesignHandler, api5.NewInstanceHandler, api5.NewInstanceFlowHandler, api5.NewInstanceCommentHandler, api5.NewInstanceTimeLineHandler, api5.NewTemplateHandler, api5.NewWorkorderProcessHandler, api5.NewCategoryGroupHandler, api5.NewNotificationHandler, api6.NewTreeNodeHandler, api6.NewTreeLocalHandler, api6.NewTreeCloudHandler, api6.NewCloudAccountHandler, api6.NewCloudAccountRegionHandler, terminal.NewTerminalHandler, api7.NewCronJobHandler)
View Source 
var Injector = wire.NewSet(
	InitMiddlewares,
	InitGinServer,
	InitLogger,
	InitRedis,
	ProvideRedisCmdable,
	InitDB,
	CronSet,
)
View Source 
var JobSet = wire.NewSet(startup.NewApplicationBootstrap)
View Source 
var ManagerSet = wire.NewSet(manager.NewClusterManager, manager.NewDeploymentManager, manager.NewNamespaceManager, manager.NewServiceManager, manager.NewNodeManager, manager.NewEventManager, manager.NewStatefulSetManager, manager.NewDaemonSetManager, manager.NewServiceAccountManager, manager.NewTaintManager, manager.NewYamlManager, manager.NewConfigMapManager, manager.NewSecretManager, manager.NewPVManager, manager.NewPVCManager, manager.NewClusterRoleManager, manager.NewClusterRoleBindingManager, manager.NewRoleManager, manager.NewRoleBindingManager, manager.NewIngressManager, manager.NewPodManager)
View Source 
var NotificationSet = wire.NewSet(
	InitNotificationConfig,
	InitNotificationManager,
)
View Source 
var SSHSet = wire.NewSet(ssh.NewClient)
View Source 
var ServiceSet = wire.NewSet(service3.NewClusterService, service3.NewDeploymentService, service3.NewNamespaceService, service3.NewSvcService, service3.NewNodeService, service3.NewTaintService, service3.NewYamlTaskService, service3.NewYamlTemplateService, service3.NewDaemonSetService, service3.NewEventService, service3.NewStatefulSetService, service3.NewServiceAccountService, service3.NewRoleService, service3.NewClusterRoleService, service3.NewRoleBindingService, service3.NewClusterRoleBindingService, service3.NewRBACService, service3.NewIngressService, service3.NewPodService, service3.NewConfigMapService, service3.NewSecretService, service3.NewPVService, service3.NewPVCService, service.NewUserService, service.NewApiService, service.NewRoleService, service.NewAuditService, service.NewSystemService, alert2.NewAlertManagerEventService, alert2.NewAlertManagerOnDutyService, alert2.NewAlertManagerPoolService, alert2.NewAlertManagerRecordService, alert2.NewAlertManagerRuleService, alert2.NewAlertManagerSendService, scrape2.NewPrometheusScrapeService, scrape2.NewPrometheusPoolService, config3.NewMonitorConfigService, service2.NewNotAuthService, service4.NewFormDesignService, service4.NewInstanceService, service4.NewInstanceFlowService, service4.NewInstanceCommentService, service4.NewWorkorderInstanceTimeLineService, service4.NewWorkorderTemplateService, service4.NewWorkorderProcessService, service4.NewCategoryGroupService, service4.NewWorkorderNotificationService, service5.NewTreeNodeService, service5.NewTreeLocalService, service5.NewTreeCloudService, service5.NewCloudAccountService, service5.NewCloudAccountRegionService, service6.NewCronService)
View Source 
var UtilSet = wire.NewSet(
	InitJWTConfig,
	InitWebSocketUpgrader, jwt.NewJWTHandler, sse.NewHandler,
)

Functions

func CheckDBHealth 

func CheckDBHealth(db *gorm.DB) error

func InitAsynqClient 

func InitAsynqClient(cfg *config.Config) *asynq.Client

func InitAsynqServer 

func InitAsynqServer(cfg *config.Config) *asynq.Server

func InitDB 

func InitDB(cfg *config.Config, logger *zap.Logger) (*gorm.DB, error)

func InitGinServer 

func InitGinServer(
	m []gin.HandlerFunc,
	userHdl *systemApi.UserHandler,
	authApiHdl *systemApi.ApiHandler,
	authRoleHdl *systemApi.RoleHandler,
	systemHdl *systemApi.SystemHandler,
	notAuthHdl *notAuthHandler.NotAuthHandler,
	k8sClusterHdl *k8sApi.K8sClusterHandler,
	k8sDeploymentHdl *k8sApi.K8sDeploymentHandler,
	k8sNamespaceHdl *k8sApi.K8sNamespaceHandler,
	k8sNodeHdl *k8sApi.K8sNodeHandler,
	k8sSvcHdl *k8sApi.K8sSvcHandler,
	k8sYamlTaskHdl *k8sApi.K8sYamlTaskHandler,
	k8sYamlTemplateHdl *k8sApi.K8sYamlTemplateHandler,
	k8sDaemonSetHdl *k8sApi.K8sDaemonSetHandler,
	k8sEventHdl *k8sApi.K8sEventHandler,
	k8sStatefulSetHdl *k8sApi.K8sStatefulSetHandler,
	k8sServiceAccountHdl *k8sApi.K8sServiceAccountHandler,
	roleHdl *k8sApi.K8sRoleHandler,
	clusterRoleHdl *k8sApi.K8sClusterRoleHandler,
	roleBindingHdl *k8sApi.K8sRoleBindingHandler,
	clusterRoleBindingHdl *k8sApi.K8sClusterRoleBindingHandler,
	k8sConfigMapHdl *k8sApi.K8sConfigMapHandler,
	k8sSecretHdl *k8sApi.K8sSecretHandler,
	alertEventHdl *prometheusApi.AlertEventHandler,
	alertPoolHdl *prometheusApi.AlertPoolHandler,
	alertRuleHdl *prometheusApi.AlertRuleHandler,
	monitorConfigHdl *prometheusApi.MonitorConfigHandler,
	onDutyGroupHdl *prometheusApi.OnDutyGroupHandler,
	recordRuleHdl *prometheusApi.RecordRuleHandler,
	scrapePoolHdl *prometheusApi.ScrapePoolHandler,
	scrapeJobHdl *prometheusApi.ScrapeJobHandler,
	sendGroupHdl *prometheusApi.SendGroupHandler,
	auditHdl *systemApi.AuditHandler,
	formDesignHdl *workorderApi.FormDesignHandler,
	processHdl *workorderApi.WorkorderProcessHandler,
	templateHdl *workorderApi.TemplateHandler,
	instanceHdl *workorderApi.InstanceHandler,
	instanceFlowHdl *workorderApi.InstanceFlowHandler,
	instanceCommentHdl *workorderApi.InstanceCommentHandler,
	categoryHdl *workorderApi.CategoryGroupHandler,
	instanceTimeLineHdl *workorderApi.InstanceTimeLineHandler,
	treeNodeHdl *resourceApi.TreeNodeHandler,
	treeLocalHdl *resourceApi.TreeLocalHandler,
	treeCloudHdl *resourceApi.TreeCloudHandler,
	cloudAccountHdl *resourceApi.CloudAccountHandler,
	cloudAccountRegionHdl *resourceApi.CloudAccountRegionHandler,
	notificationHdl *workorderApi.NotificationHandler,
	ingressHdl *k8sApi.K8sIngressHandler,
	k8sPodHdl *k8sApi.K8sPodHandler,
	k8sPVHdl *k8sApi.K8sPVHandler,
	k8sPVCHdl *k8sApi.K8sPVCHandler,
	cronJobHdl *cronApi.CronJobHandler,
) *gin.Engine

InitGinServer 初始化web服务

func InitJWTConfig added in v0.0.23 

func InitJWTConfig(cfg *config.Config) jwt.Config

InitJWTConfig 初始化 JWT 相关配置

func InitLogger 

func InitLogger(cfg *config.Config) (*zap.Logger, error)

InitLogger 将日志输出到./logs/cloudops-{日期}.log，并同时输出到控制台

func InitMiddlewares 

func InitMiddlewares(ih ijwt.Handler, l *zap.Logger, roleSvc service.RoleService, auditSvc service.AuditService) []gin.HandlerFunc

func InitNotificationConfig 

func InitNotificationConfig(cfg *config.Config) (notification.NotificationConfig, error)

func InitNotificationManager 

func InitNotificationManager(config notification.NotificationConfig, asynqClient *asynq.Client, logger *zap.Logger) (*notification.Manager, error)

func InitRedis 

func InitRedis(cfg *config.Config, logger *zap.Logger) (*redis.Client, error)

func InitScheduler 

func InitScheduler(cfg *config.Config) *asynq.Scheduler

func InitTables 

func InitTables(db *gorm.DB) error

func InitTrans 

func InitTrans() error

func InitWebSocketUpgrader added in v0.0.23 

func InitWebSocketUpgrader() *websocket.Upgrader

InitWebSocketUpgrader 初始化WebSocket升级器 说明： 1. 升级逻辑属于传输层能力，必须通过依赖注入提供，避免全局单例 2. Error回调返回通用错误，避免暴露内部细节

func IsDBAvailable 

func IsDBAvailable(db *gorm.DB) bool

func ProvideApp added in v0.0.23 

func ProvideApp(cfg *config.Config) (*app.App, error)

func ProvideRedisCmdable added in v0.0.23 

func ProvideRedisCmdable(client *redis.Client) redis.Cmdable

ProvideRedisCmdable 用于将具体实现提升为接口依赖，便于 Wire 进行类型匹配。

Types

type NotificationConfigAdapter 

type NotificationConfigAdapter struct {
	// contains filtered or unexported fields
}

func (*NotificationConfigAdapter) GetEmail 

func (a *NotificationConfigAdapter) GetEmail() notification.EmailConfig

func (*NotificationConfigAdapter) GetFeishu 

func (a *NotificationConfigAdapter) GetFeishu() notification.FeishuConfig

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.