MCPcopy Create free account

hub / github.com/Musicminion/minik8s / functions

Functions814 in github.com/Musicminion/minik8s

⨍ Functions 814◇ Types & classes 166↳ Endpoints 4
↓ 1 callersMethodScaleUp
【TODO】
pkg/serveless/function/controller.go:217
↓ 1 callersFunctionServiceUpdateWithNode
(node string)
pkg/message/msgConfig.go:62
↓ 1 callersMethodSetupJob
运行Job开始之前的准备工作
pkg/gpu/jobserver/jobserver.go:111
↓ 1 callersMethodSpin
自旋等待
pkg/gpu/jobserver/jobserver.go:253
↓ 1 callersMethodStartPod
(pod *apiObject.PodStore)
pkg/kubelet/worker/workerManager.go:16
↓ 1 callersMethodStartPod
(pod *apiObject.PodStore)
pkg/kubelet/runtime/runtime.go:17
↓ 1 callersMethodStopPod
(pod *apiObject.PodStore)
pkg/kubelet/runtime/runtime.go:18
↓ 1 callersMethodSubmitJob
返回任务的ID
pkg/gpu/jobserver/jobserver.go:154
↓ 1 callersMethodSyncLoopIterationWrap
()
pkg/kubelet/kubelet/kubelet.go:197
↓ 1 callersMethodToDnsStore
()
pkg/apiObject/dns.go:43
↓ 1 callersMethodToHPAStore
定义hpa到hpaStore的转换函数
pkg/apiObject/hpa.go:41
↓ 1 callersMethodToJobStore
()
pkg/apiObject/job.go:51
↓ 1 callersMethodToNode
定义NodeStore到Node的转换函数
pkg/apiObject/node.go:124
↓ 1 callersMethodToNodeStore
定义Node转化为NodeStore的函数
pkg/apiObject/node.go:75
↓ 1 callersMethodToReplicaSetStore
定义ReplicaSet转化为ReplicaSetStore的函数
pkg/apiObject/replicaSet.go:56
↓ 1 callersMethodToServiceStore
定义Service到ServiceStore的转换器
pkg/apiObject/service.go:48
↓ 1 callersMethodUnRegisterNode
()
pkg/kubelet/kubelet/kubelet.go:85
↓ 1 callersMethodUnRegisterNode
注销节点
pkg/kubelet/status/status.go:39
↓ 1 callersMethodUnSubscribe
关闭链接并且关闭通道，这时候
pkg/message/subscriber.go:174
↓ 1 callersMethodUpdateFunction
对于函数的更新，就是删除旧的函数，然后创建新的函数
pkg/serveless/function/operation.go:46
↓ 1 callersMethodUpdateHpaStatus
将更新过的hpa存入到etcd中
pkg/controller/allcontollers/hpacontroller.go:55
↓ 1 callersMethodUpdateJobFiles
(filePaths []string)
pkg/gpu/jobserver/jobserver.go:61
↓ 1 callersMethodUpdateNginxSvcIP
()
pkg/controller/allcontollers/dnscontroller.go:202
↓ 1 callersMethodUpdatePodToCache
UpdatePodToCache 更新缓存中的Pod的存储对象
pkg/kubelet/status/status.go:27
↓ 1 callersMethodUpdatePulledPodsToCache
(remotePodsMap map[string]*apiObject.PodStore)
pkg/kubelet/status/apiserverUtil.go:157
↓ 1 callersMethodUpdateReplicaSetStatus
(meetRequirePods []apiObject.PodStore, replicaset *apiObject.ReplicaSetStore)
pkg/controller/allcontollers/replicacontroller.go:189
↓ 1 callersMethodUpdateService
(serviceUpdate *entity.ServiceUpdate)
pkg/kubeproxy/app/iptablesManager.go:32
↓ 1 callersMethodUploadFile
上传文件
pkg/gpu/sshclient/sshclient.go:29
↓ 1 callersMethodUploadResult
const config.JobFileSpecURL untyped string = "/apis/v1/namespaces/:namespace/jobfiles/:name"
pkg/gpu/jobserver/jobserver.go:303
↓ 1 callersMethodWatch
(key string)
pkg/etcd/etcd.go:127
↓ 1 callersMethodWatchQueue_NoBlock
WatchQueue_NoBlock 非阻塞的方式监听队列，一旦有消息就会调用handleFunc 函数立刻返回，返回一个函数，调用这个函数可以取消监听
pkg/listwatcher/listwatcher.go:37
↓ 1 callersFunctionWeaveAttach
(containerID string)
util/weave/weave.go:10
↓ 1 callersFunctionWeaveFindIpByContainerID
(containerID string)
util/weave/weave.go:23
↓ 1 callersFunctionapplyDnsHandler
========================================================= 处理Dns的Apply 测试用例 go run ./main/ apply ./kubectlutil/testFile/dns.yaml ===================
pkg/kubectl/cmd/apply.go:338
↓ 1 callersFunctionapplyFuncHandler
============================================== # Apply Func go run ./main/ apply func ./ ==============================================
pkg/kubectl/cmd/apply.go:431
↓ 1 callersFunctionapplyHpaHandler
========================================================= 处理Hpa的Apply 测试用例 go run ./main/ apply ./kubectlutil/testFile/hpa.yaml ===================
pkg/kubectl/cmd/apply.go:508
↓ 1 callersFunctionapplyJobHandler
========================================================= 处理Job的Apply 测试用例 go run ./main/ apply ./kubectlutil/testFile/job-with-pwd.yaml ==========
pkg/kubectl/cmd/apply.go:217
↓ 1 callersFunctionapplyPodHandler
========================================================= 处理Pod的Apply =========================================================
pkg/kubectl/cmd/apply.go:113
↓ 1 callersFunctionapplyRepliacasetHandler
========================================================= 处理ReplicaSet的Apply 测试用例 go run ./main/ apply ./kubectlutil/testFile/replica.yaml ========
pkg/kubectl/cmd/apply.go:385
↓ 1 callersFunctionapplyServiceHandler
========================================================= 处理Service的Apply =========================================================
pkg/kubectl/cmd/apply.go:161
↓ 1 callersFunctionapplyWorkflowHandler
============================================== 处理Workflow的Apply ==============================================
pkg/kubectl/cmd/apply.go:555
↓ 1 callersMethodbind
()
pkg/apiserver/app/server/apiserver.go:62
↓ 1 callersMethodcheckAllPod
()
pkg/kubelet/pleg/plegManager.go:72
↓ 1 callersMethodcheckWorkflowNode
检查当前的workflow的每个func node是否都存在pod实例，若不存在则创建并返回false
pkg/serveless/workflow/workflow.go:174
↓ 1 callersFunctionconsumeHigherCpu
(ctx context.Context)
util/autoScale/main.go:15
↓ 1 callersFunctionconsumeHigherMemory
(ctx context.Context)
util/autoScale/main.go:29
↓ 1 callersFunctioncontains
判断当前的container是否在给定的containers中
pkg/kubelet/runtime/runtime.go:197
↓ 1 callersMethodcreatePauseContainer
Pause容器的命名规则目前是 pause-[Pod UUID]
pkg/kubelet/runtime/pauseContainerUtil.go:150
↓ 1 callersMethodcreatePodAllContainer
********************************************************************************** 一组容器的操作放在下面 *******************************************************
pkg/kubelet/runtime/commonContainerUtil.go:17
↓ 1 callersFunctiondescribeNamespaceObjects
(kind, namespace string)
pkg/kubectl/cmd/describe.go:73
↓ 1 callersFunctiondescribeSpecificObject
(kind, namespace, name string)
pkg/kubectl/cmd/describe.go:108
↓ 1 callersMethodexecuteWorkflow
(workflow apiObject.WorkflowStore)
pkg/serveless/workflow/workflow.go:73
↓ 1 callersMethodgetAllFunc
()
pkg/serveless/function/controller.go:48
↓ 1 callersFunctiongetJobFileFromAPIServer
下载1个任务的文件，存贮在本地，并且解压
pkg/gpu/main/main.go:55
↓ 1 callersFunctiongetJobFromAPIServer
通过API Server获取任务的配置信息 通过API Server获取任务的配置信息
pkg/gpu/main/main.go:34
↓ 1 callersFunctiongetNodes
()
pkg/kubectl/cmd/get.go:179
↓ 1 callersMethodgetPauseContainerConfig
获取pause容器的创建配置信息
pkg/kubelet/runtime/pauseContainerUtil.go:62
↓ 1 callersMethodgetPodContainerConfig
创建一个Pod里面的Contianer需要的配置，通过这个函数返回
pkg/kubelet/runtime/commonContainerUtil.go:324
↓ 1 callersMethodhandleMsgs
(msgs <-chan amqp.Delivery, handleFunc func(amqp.Delivery))
pkg/message/subscriber.go:79
↓ 1 callersMethodparseVolumeBinds
****************************************************************** 以下是一些辅助函数 ******************************************************************
pkg/kubelet/runtime/commonContainerUtil.go:280
↓ 1 callersMethodplegGenerator
RuntimePodStatusMap 是PodID到运行时的Pod状态的映射 CachePodsMap 是PodID到缓存的Pod的映射 1. pleg产生之前，首先我们根据运行时的状态，更新plegRecord 2. 然后我们比较plegRecord和cachePods，生成pleg事件，具体说
pkg/kubelet/pleg/plegGenerator.go:56
↓ 1 callersFunctionprepareJobConfig
准备任务的配置信息
pkg/gpu/main/main.go:137
↓ 1 callersFunctionprintAServicePortInfo
(service *apiObject.ServiceStore, t table.Writer)
pkg/kubectl/cmd/get.go:674
↓ 1 callersFunctionprintDnsResult
(dns *apiObject.HpaStore, t table.Writer)
pkg/kubectl/cmd/get.go:797
↓ 1 callersFunctionprintFunctionResult
(function *apiObject.Function, t table.Writer)
pkg/kubectl/cmd/get.go:894
↓ 1 callersFunctionprintHpaResult
(hpa *apiObject.HPAStore, t table.Writer)
pkg/kubectl/cmd/get.go:839
↓ 1 callersFunctionprintJobOutPutResult
(jobfile *apiObject.JobFile, t table.Writer)
pkg/kubectl/cmd/get.go:768
↓ 1 callersFunctionprintJobOutPutResults
(jobfiles []apiObject.JobFile)
pkg/kubectl/cmd/get.go:755
↓ 1 callersFunctionprintJobResult
(job *apiObject.JobStore, t table.Writer)
pkg/kubectl/cmd/get.go:708
↓ 1 callersFunctionprintNodeResult
(node *apiObject.NodeStore, t table.Writer)
pkg/kubectl/cmd/get.go:945
↓ 1 callersFunctionprintNodesResult
(nodes []apiObject.NodeStore)
pkg/kubectl/cmd/get.go:932
↓ 1 callersFunctionprintPodResult
(pod *apiObject.PodStore, t table.Writer)
pkg/kubectl/cmd/get.go:593
↓ 1 callersFunctionprintReplicasetResult
(replicaset *apiObject.ReplicaSetStore, t table.Writer)
pkg/kubectl/cmd/get.go:869
↓ 1 callersFunctionprintServiceResult
(service *apiObject.ServiceStore, t table.Writer)
pkg/kubectl/cmd/get.go:649
↓ 1 callersFunctionprintServicesPortInfo
(service []apiObject.ServiceStore)
pkg/kubectl/cmd/get.go:661
↓ 1 callersFunctionprintWorkflowResult
(workflow *apiObject.WorkflowStore, t table.Writer)
pkg/kubectl/cmd/get.go:919
↓ 1 callersMethodremovePauseContainer
************************************************************
pkg/kubelet/runtime/pauseContainerUtil.go:17
↓ 1 callersMethodremovePodContainer
(pod *apiObject.PodStore, container *apiObject.Container)
pkg/kubelet/runtime/commonContainerUtil.go:216
↓ 1 callersMethodrestartPauseContainer
restartPauseContainer
pkg/kubelet/runtime/pauseContainerUtil.go:274
↓ 1 callersMethodrestartPodAllContainer
尝试重启所有的容器，如果遇到某个容器重启失败，则会继续重启其他容器，最后返回错误信息
pkg/kubelet/runtime/commonContainerUtil.go:95
↓ 1 callersMethodrestartPodContainer
restartPodContainer 重启Pod里面的一个Container
pkg/kubelet/runtime/commonContainerUtil.go:247
↓ 1 callersFunctionschRandom
(nodes []apiObject.NodeStore)
pkg/scheduler/app/scheduler.go:84
↓ 1 callersFunctionschRoundRobin
* 根据具体的调度策略选择一个节点 */ *********************************************************************/ **********************************************************
pkg/scheduler/app/scheduler.go:72
↓ 1 callersFunctionselectiveUpdateFlowStatus
(oldStatus *apiObject.WorkflowStore, newStatus *apiObject.WorkflowStatus)
pkg/apiserver/app/handlers/workflowHandler.go:426
↓ 1 callersFunctionselectiveUpdateFunction
selectiveUpdateFunction
pkg/apiserver/app/handlers/funcHandler.go:294
↓ 1 callersFunctionselectiveUpdateJobFile
为了简单处理，只更新 UserUploadFile、OutputFile、ErrorFile
pkg/apiserver/app/handlers/jobHandler.go:707
↓ 1 callersFunctionselectiveUpdateJobStatus
(oldJob *apiObject.JobStore, newJob *apiObject.JobStatus)
pkg/apiserver/app/handlers/jobHandler.go:429
↓ 1 callersFunctionselectiveUpdateNode
选择性更新Node的字段，不是所有的字段都可以更新
pkg/apiserver/app/handlers/nodeHandler.go:285
↓ 1 callersFunctionselectiveUpdateNodeStatus
(oldNode *apiObject.NodeStore, putNodeStatus *apiObject.NodeStatus)
pkg/apiserver/app/handlers/nodeHandler.go:536
↓ 1 callersFunctionselectiveUpdatePService
选择性的更新Pod
pkg/apiserver/app/handlers/serviceHandler.go:423
↓ 1 callersFunctionselectiveUpdatePod
(oldPod *apiObject.PodStore, putPod *apiObject.PodStore)
pkg/apiserver/app/handlers/podHandler.go:616
↓ 1 callersFunctionselectiveUpdateReplicaSet
选择性的更新replicaSet
pkg/apiserver/app/handlers/replicaSetHandler.go:532
↓ 1 callersFunctionselectiveUpdateReplicaStatus
更新replicaSet的状态的时候，请务必完整的传递replicaSet的状态，不然会导致状态丢失
pkg/apiserver/app/handlers/replicaSetHandler.go:421
↓ 1 callersFunctionselectiveUpdateServiceStatus
选择性的更新ServiceStatus
pkg/apiserver/app/handlers/serviceHandler.go:453
↓ 1 callersMethodsetIPTablesClusterIp
** * @Description: 为每个服务创建 iptables 规则 * @Param: serviceName 服务名称 * @Param: clusterIP 服务的集群 IP * @Param: port 服务的端口 * @Param: protocol 服务的协议 * @
pkg/kubeproxy/app/iptablesManager.go:156
↓ 1 callersMethodstartPauseContainer
启动一个
pkg/kubelet/runtime/pauseContainerUtil.go:206
↓ 1 callersMethodstartPodAllContainer
会尝试启动所有的容器，如果遇到某个容器启动失败，则会继续启动其他容器，最后返回错误信息
pkg/kubelet/runtime/commonContainerUtil.go:75
↓ 1 callersMethodstartPodContainer
********************************************************************************** 单个容器的操作放在下面 *******************************************************
pkg/kubelet/runtime/commonContainerUtil.go:118
↓ 1 callersMethodstopPauseContainer
stopPauseContainer
pkg/kubelet/runtime/pauseContainerUtil.go:244
↓ 1 callersMethodstopPodAllContainer
会尝试停止所有的容器，如果遇到某个容器停止失败，则会继续停止其他容器，最后返回错误信息
pkg/kubelet/runtime/commonContainerUtil.go:55
← previousnext →301–400 of 814, ranked by callers