MCPcopy Create free account

hub / github.com/caoyingjunz/pixiu / functions

Functions1,262 in github.com/caoyingjunz/pixiu

↓ 3 callersMethodGet
(ctx context.Context, name string)
pkg/controller/helm/releases.go:40
↓ 3 callersMethodGetBy
(ctx context.Context, opts ...Options)
pkg/db/runner.go:37
↓ 3 callersMethodGetByMethodAndPath
(ctx context.Context, method, path string)
pkg/db/apis.go:37
↓ 3 callersMethodGetRoot
(ctx context.Context)
pkg/db/user.go:34
↓ 3 callersFunctionGetUserFromRequest
(ctx context.Context)
api/server/httputils/httputils.go:138
↓ 3 callersMethodInit
Init sets the log format only once.
pkg/util/log/log.go:76
↓ 3 callersMethodName
kubez-ansible {实际执行命名,比如 deploy,}
pkg/controller/plan/worker.go:36
↓ 3 callersFunctionNewError
(err error, code int)
api/server/errors/errors.go:34
↓ 3 callersFunctionNewRandName
(length int)
pkg/util/uuid/uuid.go:33
↓ 3 callersMethodNext
Next 获取web端是否resize,以及是否退出终端
pkg/types/meta.go:163
↓ 3 callersMethodOffset
(total int)
pkg/types/meta.go:404
↓ 3 callersFunctionParseKubeConfigBytes
(cfg string)
pkg/client/client.go:26
↓ 3 callersMethodStart
Start 启动部署任务
pkg/controller/plan/plan.go:53
↓ 3 callersMethodStop
Stop 终止部署任务
pkg/controller/plan/plan.go:55
↓ 3 callersMethodUnmarshal
(s string)
pkg/types/meta.go:370
↓ 3 callersMethodUpdateByPlan
(ctx context.Context, planId int64, updates map[string]interface{})
pkg/db/cluster.go:41
↓ 3 callersMethodUpdateTask
(ctx context.Context, pid int64, name string, updates map[string]interface{})
pkg/db/plan.go:64
↓ 3 callersMethodbuildNodeFromRequest
(planId int64, req *types.CreatePlanNodeRequest)
pkg/controller/plan/plan_node.go:114
↓ 3 callersMethoddoRender
(name string, text string, data interface{})
pkg/controller/plan/render.go:70
↓ 3 callersMethodmodel2Type
(o *model.Plan)
pkg/controller/plan/plan.go:500
↓ 3 callersMethodmodelTask2Type
(o *model.Task)
pkg/controller/plan/plan_task.go:139
↓ 3 callersFunctionrepairFirstBase64LineOfPEM
repairFirstBase64LineOfPEM 若 PEM 首段 base64 行前带有非 PEM 字符(如误插入的 "1"),去掉直至合法 base64 字母。
pkg/util/ssh/pem_normalize.go:66
↓ 3 callersFunctionrepairLeadingDigitBeforeMII
repairLeadingDigitBeforeMII 修复首行 base64 前误插入的单个数字(如 "1MII...",1 属 base64 字母集,不会被 repairFirstBase64LineOfPEM 去掉)。
pkg/util/ssh/pem_normalize.go:99
↓ 3 callersMethodwithRawError
withRawError puts the raw error into the HTTP context.
api/server/httputils/httputils.go:225
↓ 2 callersMethodCount
(ctx context.Context, opts ...Options)
pkg/db/plan.go:36
↓ 2 callersMethodCreateDistribution
(ctx context.Context, object *model.Distribution)
pkg/db/distribution.go:30
↓ 2 callersMethodDelete
(ctx context.Context, cid int64, skipCheck bool)
pkg/controller/cluster/cluster.go:296
↓ 2 callersMethodDeleteNode
(ctx context.Context, pid int64, nodeId int64)
pkg/controller/plan/plan.go:61
↓ 2 callersFunctionEncryptUserPassword
EncryptUserPassword 生成加密密码 前端传的密码为明文,需要加密存储 TODO: 后续确认是否有必要在前端加密
pkg/util/util.go:37
↓ 2 callersFunctionEnsureDirectoryExists
(path string)
pkg/util/util.go:114
↓ 2 callersMethodExists
(prefix string, path string)
pkg/static/static.go:28
↓ 2 callersMethodGetClusterByName
(ctx context.Context, name string)
pkg/db/cluster.go:40
↓ 2 callersMethodGetConfig
(ctx context.Context, pid int64)
pkg/controller/plan/plan_config.go:135
↓ 2 callersMethodGetDistribution
(ctx context.Context, id int64)
pkg/controller/distribution/distribution.go:40
↓ 2 callersMethodGetDistributionByFamilyName
(ctx context.Context, family, name string)
pkg/db/distribution.go:35
↓ 2 callersMethodGetNode
(ctx context.Context, pid int64, nodeId int64)
pkg/controller/plan/plan.go:62
↓ 2 callersFunctionGetResponseCode
GetResponseCode gets the response code from the HTTP context.
api/server/httputils/httputils.go:231
↓ 2 callersMethodGetRoleByTenantAndName
(ctx context.Context, tenantId int64, name string)
pkg/db/role.go:37
↓ 2 callersMethodGetRunner
(ctx context.Context, osImage string)
pkg/controller/plan/worker.go:206
↓ 2 callersMethodGetUserByName
(ctx context.Context, userName string)
pkg/db/user.go:39
↓ 2 callersMethodInDebug
()
cmd/app/config/config.go:31
↓ 2 callersMethodInstall
(ctx context.Context, req types.InstallRunnerRequest)
pkg/controller/runner/runner.go:46
↓ 2 callersFunctionIsUniqueConstraintError
(err error)
pkg/util/errors/errors.go:75
↓ 2 callersMethodListDistributions
(ctx context.Context, opts ...Options)
pkg/db/distribution.go:36
↓ 2 callersMethodListNodes
(ctx context.Context, pid int64)
pkg/controller/plan/plan_node.go:164
↓ 2 callersFunctionLocalFile
(root string, indexes bool)
pkg/static/localfile.go:33
↓ 2 callersMethodRoleAPI
()
pkg/db/factory.go:27
↓ 2 callersFunctionServe
Serve returns a middleware handler that serves static files in the given directory.
pkg/static/static.go:36
↓ 2 callersMethodSetByTask
(planId int64, task model.Task)
pkg/client/task.go:85
↓ 2 callersFunctionSetUserToContext
(c *gin.Context, user *model.User)
api/server/httputils/httputils.go:159
↓ 2 callersMethodStep
检查项名称
pkg/controller/plan/worker.go:37
↓ 2 callersMethodTaskIsRunning
TaskIsRunning 校验是否有任务正在运行
pkg/controller/plan/plan.go:462
↓ 2 callersMethodUnmarshal
(s string)
pkg/types/meta.go:355
↓ 2 callersMethodUnmarshal
(s string)
pkg/types/meta.go:385
↓ 2 callersMethodUpdateNode
(ctx context.Context, pid int64, nodeId int64, req *types.UpdatePlanNodeRequest)
pkg/controller/plan/plan.go:60
↓ 2 callersMethodValid
()
cmd/app/config/config.go:103
↓ 2 callersFunctionValidateStrongPassword
ValidateStrongPassword validates the password is strong enough.
pkg/util/util.go:52
↓ 2 callersFunctionValidateUserPassword
ValidateUserPassword 验证用户的密码是否正确
pkg/util/util.go:47
↓ 2 callersMethodWaitForCacheSync
WaitForCacheSync 判断缓存中是否已经存在,如果不存在则先写入
pkg/client/task.go:124
↓ 2 callersFunctionWithClusterName
(clusterName string)
pkg/db/options.go:266
↓ 2 callersFunctionWithCreatedBefore
(t time.Time)
pkg/db/options.go:47
↓ 2 callersFunctionWithDatasourceType
(datasourceType model.DatasourceType)
pkg/db/options.go:275
↓ 2 callersMethodWithLogFields
(fields map[string]interface{})
pkg/util/log/log.go:117
↓ 2 callersFunctionWithOwnerCluster
(clusterId int64)
pkg/db/options.go:248
↓ 2 callersFunctionWriteToFile
(filename string, data []byte)
pkg/util/util.go:124
↓ 2 callersMethodaddKubernetesRule
(ctx context.Context, req *types.CreatePermissionRequest, clusterSet client.ClusterSet)
pkg/controller/cluster/permission.go:311
↓ 2 callersFunctionallowCustomRequest
允许特定请求不经过验证
api/server/middleware/middleware.go:35
↓ 2 callersMethodbuildAndCleanKubernetesConfig
(ks types.KubernetesSpec)
pkg/controller/plan/plan_config.go:145
↓ 2 callersMethodbuildPlanConfig
(ctx context.Context, req *types.CreatePlanConfigRequest)
pkg/controller/plan/plan_config.go:158
↓ 2 callersMethodcreateNode
(ctx context.Context, planId int64, req *types.CreatePlanNodeRequest)
pkg/controller/plan/plan_node.go:131
↓ 2 callersFunctiondecodeStringSlice
(raw string)
pkg/controller/cluster/permission.go:455
↓ 2 callersMethoddeleteKubernetesRule
(ctx context.Context, object *model.Permission)
pkg/controller/cluster/permission.go:352
↓ 2 callersFunctiondistributionModel2Type
(o *model.Distribution)
pkg/controller/distribution/distribution.go:201
↓ 2 callersFunctionencodeRules
(rules []rbacv1.PolicyRule)
pkg/controller/cluster/permission.go:422
↓ 2 callersFunctionencodeStringSlice
(items []string)
pkg/controller/cluster/permission.go:433
↓ 2 callersMethodfetch
(_ context.Context, entry *repo.Entry)
pkg/controller/helm/repository.go:170
↓ 2 callersFunctiongetObjectFromRequest
getObjectFromRequest cuts and returns the object from the request path. e.g. /pixiu/clusters/1 -> "clusters" "1" true
api/server/httputils/httputils.go:169
↓ 2 callersMethodgetTag
()
api/server/validator/validator.go:28
↓ 2 callersMethodlocateChart
(pathOpts action.ChartPathOptions, chart string, settings *cli.EnvSettings)
pkg/controller/helm/releases.go:137
↓ 2 callersFunctionmodel2Node
(o *model.Node)
pkg/controller/node/node.go:177
↓ 2 callersFunctionmodel2Type
(o *model.Runner)
pkg/controller/runner/runner.go:276
↓ 2 callersFunctionmodel2Type
将 model user 转换成 types(不含 Password,避免通过 API 泄露哈希)
pkg/controller/user/user.go:452
↓ 2 callersFunctionmodel2Type
(o *model.Agent)
pkg/controller/agent/agent.go:167
↓ 2 callersMethodmodel2Type
(o *model.API)
pkg/controller/apiresource/apiresource.go:232
↓ 2 callersMethodmodel2Type
(o *model.Audit)
pkg/controller/audit/audit.go:131
↓ 2 callersMethodmodel2Type
(o *model.Tenant)
pkg/controller/tenant/tenant.go:162
↓ 2 callersMethodmodel2Type
(o *model.Role)
pkg/controller/role/role.go:207
↓ 2 callersMethodmodel2Type
(o *model.Cluster)
pkg/controller/cluster/cluster.go:1047
↓ 2 callersMethodmodelNode2Type
(o *model.Node)
pkg/controller/plan/plan_node.go:209
↓ 2 callersFunctionmodelToType
(object *model.Datasource)
pkg/controller/datasource/datasource.go:252
↓ 2 callersFunctionparseFloat64FromString
parseFloat64FromString 从字符串中解析出包含的数字,并以 float64 返回。 无法解析时,返回 0 仅解析最先遇到的数字,效果: "666ddd" -> 666 "666ddd888" -> 666 "" 或者 "ddd"- > 0
pkg/controller/cluster/cluster.go:1033
↓ 2 callersMethodpermissionModel2Type
(o *model.Permission)
pkg/controller/cluster/permission.go:396
↓ 2 callersMethodpreCreateConfig
(ctx context.Context, planId int64, req *types.CreatePlanConfigRequest)
pkg/controller/plan/plan_config.go:30
↓ 2 callersFunctionsetFailedWithCode
SetFailedWithCode 设置错误返回值
api/server/httputils/httputils.go:95
↓ 2 callersMethodupdateStatus
(ctx context.Context, runnerId int64, status model.RunnerStatus)
pkg/controller/plan/runner.go:93
↓ 2 callersMethodwrite
(record *model.Audit)
api/server/middleware/audit.go:71
↓ 1 callersFunctionAdmission
Admission 准入控制
api/server/middleware/admission.go:22
↓ 1 callersMethodAggregateEvents
AggregateEvents 聚合指定资源的 events
pkg/controller/cluster/cluster.go:78
↓ 1 callersFunctionAudit
(o *options.Options)
api/server/middleware/audit.go:90
↓ 1 callersFunctionAuthentication
Authentication 身份认证
api/server/middleware/authentication.go:32
← previousnext →101–200 of 1,262, ranked by callers