Functions — github.com/caoyingjunz/pixiu

hub / github.com/caoyingjunz/pixiu / functions

Functions1,262 in github.com/caoyingjunz/pixiu

⨍ Functions 1,262◇ Types & classes 331

↓ 232 callersFunctionSetFailed

SetFailed 设置错误返回值

api/server/httputils/httputils.go:83

↓ 114 callersFunctionNewResponse

NewResponse 构造 http 返回值 SetSuccess 时设置 code 为 200 并追加 success 的标识 SetFailed 时设置 code 为 400，也可以自定义设置错误码，并追加报错信息

api/server/httputils/httputils.go:71

↓ 107 callersFunctionSetSuccess

SetSuccess 设置成功返回值

api/server/httputils/httputils.go:76

↓ 64 callersMethodGet

(ctx context.Context, nodeId int64)

pkg/controller/node/node.go:40

↓ 55 callersMethodPlan

()

pkg/controller/plan/plan.go:40

↓ 47 callersFunctionShouldBindAny

(c *gin.Context, jsonObject interface{}, uriObject interface{}, queryObject interface{})

api/server/httputils/httputils.go:116

↓ 31 callersMethodError

(ctx context.Context, msg string, data ...interface{})

pkg/db/logger.go:53

↓ 31 callersMethodList

(ctx context.Context, opt types.ListOptions)

pkg/controller/node/node.go:41

↓ 26 callersMethodCluster

()

pkg/db/factory.go:24

↓ 25 callersMethodCluster

()

pkg/controller/cluster/cluster.go:55

↓ 25 callersMethodDelete

(ctx context.Context, nodeId int64)

pkg/controller/node/node.go:39

↓ 25 callersMethodMarshal

()

pkg/types/meta.go:418

↓ 22 callersMethodCreate

(ctx context.Context, req *types.CreateNodeRequest)

pkg/controller/node/node.go:37

↓ 22 callersMethodGet

(ctx context.Context, aid int64)

pkg/db/apis.go:33

↓ 22 callersMethodPlan

()

pkg/db/factory.go:30

↓ 20 callersMethodAPIResource

()

pkg/controller/apiresource/apiresource.go:33

↓ 20 callersFunctionIsRecordNotFound

(err error)

pkg/util/errors/errors.go:67

↓ 20 callersMethodSet

(planId int64, tasks []model.Task)

pkg/client/task.go:69

↓ 19 callersMethodClose

()

pkg/types/meta.go:212

↓ 17 callersMethodCreate

(ctx context.Context, object *model.API)

pkg/db/apis.go:30

↓ 16 callersMethodList

(ctx context.Context, opts ...Options)

pkg/db/apis.go:34

↓ 16 callersMethodUpdate

(ctx context.Context, nodeId int64, req *types.UpdateNodeRequest)

pkg/controller/node/node.go:38

↓ 15 callersMethodDelete

(ctx context.Context, aid int64)

pkg/db/apis.go:32

↓ 15 callersMethodDone

Done 标记关闭doneChan,关闭后触发退出终端

pkg/types/meta.go:153

↓ 15 callersMethodHelm

()

pkg/controller/helm/helm.go:32

↓ 15 callersMethodRegister

api/server/router/apiregistry/apiregistry.go:51

↓ 14 callersMethodAPI

()

pkg/db/factory.go:28

↓ 14 callersMethodGetClusterSetByName

GetClusterSetByName 获取 ClusterSet，缓存中不存在时，构建缓存再返回

pkg/controller/cluster/cluster.go:891

↓ 14 callersMethodUnmarshal

(s string)

pkg/types/meta.go:426

↓ 14 callersMethodUser

()

pkg/controller/user/user.go:49

↓ 14 callersMethodUser

()

pkg/db/factory.go:29

↓ 13 callersMethodCount

(ctx context.Context, opts ...Options)

pkg/db/apis.go:35

↓ 13 callersMethodRun

未开始，运行中，异常和完成

pkg/controller/plan/worker.go:38

↓ 12 callersMethodRunner

()

pkg/controller/runner/runner.go:36

↓ 12 callersFunctionWithLimit

(limit int)

pkg/db/options.go:59

↓ 12 callersFunctionWithOffset

(offset int)

pkg/db/options.go:41

↓ 11 callersMethodRole

()

pkg/controller/role/role.go:33

↓ 11 callersMethodUpdate

(ctx context.Context, aid int64, resourceVersion int64, updates map[string]interface{})

pkg/db/apis.go:31

↓ 11 callersFunctionregister

(model ...interface{})

pkg/db/model/model.go:21

↓ 10 callersMethodContains

(key interface{})

pkg/util/lru/lru.go:45

↓ 10 callersMethodDistribution

()

pkg/controller/distribution/distribution.go:33

↓ 10 callersMethodPermission

()

pkg/db/factory.go:35

↓ 10 callersMethodmakeFieldSelector

构造事件的 FieldSelector，如果参数为空则忽略

pkg/controller/cluster/cluster.go:975

↓ 9 callersMethodRunner

()

pkg/db/factory.go:37

↓ 9 callersMethodTenant

()

pkg/controller/tenant/tenant.go:32

↓ 9 callersFunctionWithNameLike

pkg/client/token_cache.go:60

↓ 8 callersMethodDatasource

()

pkg/controller/datasource/datasource.go:35

↓ 8 callersMethodRepository

()

pkg/db/factory.go:33

↓ 7 callersFunctionAbortFailedWithCode

AbortFailedWithCode 设置错误，code 返回值并终止请求

api/server/httputils/httputils.go:108

↓ 7 callersMethodAdd

(key, value interface{})

pkg/util/lru/lru.go:50

↓ 7 callersMethodCreate

(ctx context.Context, object *model.Plan, opts ...CreatePlanOption)

pkg/db/plan.go:31

↓ 7 callersMethodDelete

(ctx context.Context, pid int64)

pkg/db/plan.go:33

↓ 7 callersMethodDistribution

()

pkg/db/factory.go:31

↓ 7 callersMethodGetPlanId

()

pkg/controller/plan/worker.go:33

↓ 7 callersMethodRelease

(cluster, namespace string)

pkg/controller/helm/helm.go:36

↓ 7 callersMethodRole

()

pkg/db/factory.go:26

↓ 7 callersMethodSetDefaultPageOption

()

pkg/types/types.go:369

↓ 7 callersFunctionWithUser

(userId int64)

pkg/db/options.go:196

↓ 7 callersMethodlistObjects

(objects []metav1.Object, namespace string, listOption types.ListOptions)

pkg/controller/cluster/util.go:72

↓ 6 callersMethodAgent

()

pkg/controller/agent/agent.go:32

↓ 6 callersMethodDatasource

()

pkg/db/factory.go:36

↓ 6 callersMethodGetConfigByPlan

(ctx context.Context, planId int64)

pkg/db/plan.go:61

↓ 6 callersMethodRepository

()

pkg/controller/helm/repository.go:39

↓ 6 callersFunctionWithOrderByDesc

()

pkg/db/options.go:35

↓ 5 callersMethodAgent

()

pkg/db/factory.go:34

↓ 5 callersMethodInfo

(ctx context.Context, msg string, data ...interface{})

pkg/db/logger.go:49

↓ 5 callersMethodListNodes

(ctx context.Context, pid int64)

pkg/controller/plan/plan.go:63

↓ 5 callersMethodListTasks

(ctx context.Context, planId int64)

pkg/controller/plan/plan.go:74

↓ 5 callersMethodName

Name returns the job name

pkg/jobmanager/manager.go:27

↓ 5 callersFunctionNewClusterSet

(cfg string)

pkg/client/client.go:53

↓ 5 callersFunctionNewContainer

(action string, planId int64, dir string)

pkg/util/container/container.go:43

↓ 5 callersMethodNode

()

pkg/controller/node/node.go:33

↓ 5 callersMethodString

()

pkg/db/model/audit.go:65

↓ 5 callersMethodTenant

()

pkg/db/factory.go:25

↓ 5 callersFunctionWithModifyOrderByDesc

()

pkg/db/options.go:53

↓ 5 callersMethodWrite

(p []byte)

pkg/types/meta.go:202

↓ 4 callersMethodAudit

()

pkg/db/factory.go:32

↓ 4 callersMethodClose

()

pkg/util/container/container.go:89

↓ 4 callersMethodDo

Do is the job handler

pkg/jobmanager/manager.go:37

↓ 4 callersMethodGetKubeObjectByLabel

GetKubeObjectByLabel TODO: 并发优化

pkg/controller/cluster/cluster.go:836

↓ 4 callersMethodGetPods

()

pkg/types/meta.go:71

↓ 4 callersMethodInternalUpdate

InternalUpdate 内部更新，不校验、不递增 resource_version

pkg/db/runner.go:39

↓ 4 callersFunctionIsEmptyS

pkg/util/lru/lru.go:83

↓ 4 callersFunctionNewClient

()

pkg/util/docker/client.go:21

↓ 4 callersMethodSetMessageWithCode

(m interface{}, c int)

api/server/httputils/httputils.go:53

↓ 4 callersMethodStartAndWaitForContainer

StartAndWaitForContainer 创建，启动容器，并等待容器退出

pkg/util/container/container.go:58

↓ 4 callersMethodString

()

api/server/httputils/httputils.go:62

↓ 4 callersMethodUnmarshal

(s string)

pkg/types/meta.go:325

↓ 4 callersMethodUnmarshal

(s string)

pkg/types/meta.go:340

↓ 4 callersMethodUpgrade

(ctx context.Context, form *types.Release)

pkg/controller/helm/releases.go:43

↓ 4 callersFunctioncontextBind

(c *gin.Context)

api/server/httputils/httputils.go:214

↓ 4 callersMethodupdateStatus

更新 runner 状态

pkg/controller/runner/runner.go:229

↓ 4 callersMethodwithResponseCode

withResponseCode puts the response code into the HTTP context.

api/server/httputils/httputils.go:219

↓ 3 callersMethodAudit

()

pkg/controller/audit/audit.go:33

↓ 3 callersMethodClean

Clean 移除不必要的配置，防止持久化的时候存储多余配置

pkg/types/meta.go:449

↓ 3 callersMethodCreateNode

(ctx context.Context, pid int64, req *types.CreatePlanNodeRequest)

pkg/controller/plan/plan.go:59

↓ 3 callersMethodDeletePermission

DeletePermission 1. 删除数据库记录 2. 移除 k8s 的资源 3. 删除已授权的集群记录

pkg/controller/cluster/permission.go:293

↓ 3 callersMethodGet

(ctx context.Context, pid int64)

pkg/controller/plan/plan.go:285

next →1–100 of 1,262, ranked by callers