MCPcopy Create free account

hub / github.com/Musicminion/minik8s / functions

Functions814 in github.com/Musicminion/minik8s

⨍ Functions 814◇ Types & classes 166↳ Endpoints 4
↓ 1 callersMethodCompareCheck
(checkType apiObject.ChoiceCheckType, lastStepResult string, CompareValue string, varName string)
pkg/serveless/workflow/workflow.go:198
↓ 1 callersMethodCompileJobFiles
()
pkg/gpu/jobserver/jobserver.go:77
↓ 1 callersMethodComplareTwoFunc
比较两个function是否相同
pkg/serveless/function/controller.go:136
↓ 1 callersFunctionCompressToTar
(source, target string)
util/zip/zip.go:41
↓ 1 callersFunctionComvertZipToBytes
(source string)
util/zip/zip.go:19
↓ 1 callersFunctionConditionPeriod
条件执行，如果callback返回true，那么程序会立即返回，否则函数会一直执行，直到callback返回true 当然，如果你ifLoop为true，那么程序会一直执行callback，直到callback返回true 如果ifLoop为false，那么程序只会执行完一轮的waitTime数组，
util/executor/executor.go:49
↓ 1 callersMethodCreateFuncReplica
(f *apiObject.Function)
pkg/serveless/function/operation.go:185
↓ 1 callersMethodCreateHelperContainer
创建非标记为k8s的容器，返回容器的ID和错误
pkg/kubelet/runtime/container/container.go:324
↓ 1 callersMethodCreateNginxPod
()
pkg/kubeproxy/app/proxy.go:179
↓ 1 callersMethodCreateNginxService
()
pkg/controller/allcontollers/dnscontroller.go:168
↓ 1 callersMethodCreateService
(serviceUpdate *entity.ServiceUpdate)
pkg/kubeproxy/app/iptablesManager.go:30
↓ 1 callersMethodCreateService
(serviceUpdate *entity.ServiceUpdate)
pkg/kubeproxy/app/iptablesManager.go:62
↓ 1 callersFunctionDefaultEtcdConfig
()
pkg/apiserver/serverconfig/etcdConfig.go:54
↓ 1 callersFunctionDefaultKubeletConfig
()
pkg/kubelet/kubeletconfig/kubletConfig.go:20
↓ 1 callersFunctionDefaultSchedulerConfig
()
pkg/scheduler/app/schedulerConfig.go:12
↓ 1 callersFunctionDefaultServerConfig
()
pkg/apiserver/serverconfig/serverConfig.go:16
↓ 1 callersMethodDelPodFromCache
(podUUID string)
pkg/kubelet/status/status.go:84
↓ 1 callersFunctionDelToken
(token string)
pkg/apiserver/app/handlers/tokenHanlder.go:39
↓ 1 callersFunctionDeleteAPIObjectByKind
(kind string, yamlContent []byte)
pkg/kubectl/cmd/delete.go:36
↓ 1 callersFunctionDeleteEndpoints
(pod apiObject.PodStore)
pkg/apiserver/app/helper/manageEndpoint.go:150
↓ 1 callersMethodDeleteFuncReplica
(f *apiObject.Function)
pkg/serveless/function/operation.go:253
↓ 1 callersMethodDeleteNginxConf
(dns *apiObject.Dns)
pkg/controller/allcontollers/dnscontroller.go:158
↓ 1 callersMethodDeletePod
(pod *apiObject.PodStore)
pkg/kubelet/worker/workerManager.go:15
↓ 1 callersMethodDeleteService
(serviceUpdate *entity.ServiceUpdate)
pkg/kubeproxy/app/iptablesManager.go:90
↓ 1 callersMethodEqual
定义NodeStatus的比较函数，因为要处理Put请求的时候，需要比较两个NodeStatus是否相等
pkg/apiObject/node.go:190
↓ 1 callersMethodExecContainer
(containerID string, cmd []string)
pkg/kubelet/runtime/container/container.go:291
↓ 1 callersMethodExecPodContainer
(pod *apiObject.PodStore, cmd []string)
pkg/kubelet/runtime/runtime.go:22
↓ 1 callersFunctionExecute
()
pkg/kubectl/cmd/init.go:9
↓ 1 callersMethodFindJobFiles
()
pkg/gpu/jobserver/jobserver.go:38
↓ 1 callersFunctionGenerateToken
生成一个长度为64的随机字母和数字的组合的token
pkg/apiserver/app/handlers/tokenHanlder.go:13
↓ 1 callersMethodGetAllHpaFromAPIServer
()
pkg/controller/allcontollers/hpacontroller.go:36
↓ 1 callersMethodGetAllNodes
()
pkg/scheduler/app/schedulerUtil.go:12
↓ 1 callersFunctionGetAllPodFromAPIServer
()
pkg/serveless/server/helper.go:11
↓ 1 callersMethodGetAllPodFromCache
()
pkg/kubelet/status/status.go:93
↓ 1 callersMethodGetAllPodFromRuntime
获取运行时候的Pod的状态信息
pkg/kubelet/status/status.go:33
↓ 1 callersMethodGetAllReplicasetsFromAPIServer
()
pkg/controller/allcontollers/replicacontroller.go:28
↓ 1 callersFunctionGetAllWorkflowsFromAPIServer
()
pkg/serveless/workflow/workflow.go:28
↓ 1 callersFunctionGetAvailablePort
获取一个可以用的端口
util/netutil/netutil.go:11
↓ 1 callersMethodGetJobFileUUID
()
pkg/apiObject/job.go:107
↓ 1 callersMethodGetNodeName
获取节点名称
pkg/kubelet/status/status.go:41
↓ 1 callersMethodGetObjectNamespace
()
pkg/apiObject/service.go:109
↓ 1 callersMethodGetPodsBySvcName
(svcName string)
pkg/kubeproxy/app/iptablesManager.go:34
↓ 1 callersMethodGetReplicaSetName
()
pkg/apiObject/replicaSet.go:22
↓ 1 callersFunctionGetRequest
(uri string)
util/netRequest/getRequest.go:83
↓ 1 callersMethodGetRuntimeAllPodStatus
获取运行时Pod的状态信息 返回的参数是map[string]*RunTimePodStatus
pkg/kubelet/runtime/statusUtil.go:57
↓ 1 callersMethodGetRuntimeNodeIP
GetRuntimeNodeIp 获取运行时Node的IP
pkg/kubelet/runtime/runtime.go:34
↓ 1 callersMethodHandleHPAUpdate
(hpa apiObject.HPAStore, pods []apiObject.PodStore)
pkg/controller/allcontollers/hpacontroller.go:122
↓ 1 callersFunctionHostUpdateWithNode
(node string)
pkg/message/msgConfig.go:57
↓ 1 callersMethodInit_iptables
()
pkg/kubeproxy/app/iptablesManager.go:117
↓ 1 callersMethodJobCreateHandler
(parsedMsg *message.Message)
pkg/controller/allcontollers/jobcontroller.go:43
↓ 1 callersMethodJobDeleteHandler
(msg *message.Message)
pkg/controller/allcontollers/jobcontroller.go:121
↓ 1 callersFunctionJudgeServiceIPAddress
(cluserIP string)
pkg/apiserver/app/helper/manageService.go:68
↓ 1 callersMethodListLocalContainers
列出所有的容器，包括非k8s的容器，返回容器的列表和错误
pkg/kubelet/runtime/container/container.go:179
↓ 1 callersMethodListenChan
()
pkg/kubelet/kubelet/chanListen.go:8
↓ 1 callersFunctionNewCtrlManager
()
pkg/controller/ctrlmanager/ctrlmanager.go:19
↓ 1 callersFunctionNewDnsController
()
pkg/controller/allcontollers/dnscontroller.go:37
↓ 1 callersFunctionNewDnsManager
创建PlegManager的时候，必须要传递一个statusManager，以及PlegChannel
pkg/kubeproxy/app/dnsManager.go:13
↓ 1 callersFunctionNewFuncController
()
pkg/serveless/function/controller.go:41
↓ 1 callersFunctionNewHelperContainerManager
()
util/container/manager.go:16
↓ 1 callersFunctionNewHpaController
()
pkg/controller/allcontollers/hpacontroller.go:32
↓ 1 callersFunctionNewJobCompleteStatus
(data []string)
pkg/gpu/jobserver/jobserverConfig.go:94
↓ 1 callersFunctionNewJobController
()
pkg/controller/allcontollers/jobcontroller.go:30
↓ 1 callersFunctionNewJobServerConfig
()
pkg/gpu/jobserver/jobserverConfig.go:74
↓ 1 callersFunctionNewKubeProxy
(lsConfig *listwatcher.ListwatcherConfig)
pkg/kubeproxy/app/proxy.go:34
↓ 1 callersFunctionNewKubelet
(conf *kubeletconfig.KubeletConfig)
pkg/kubelet/kubelet/kubelet.go:40
↓ 1 callersFunctionNewPlegManager
创建PlegManager的时候，必须要传递一个statusManager，以及PlegChannel
pkg/kubelet/pleg/plegManager.go:26
↓ 1 callersFunctionNewReplicaController
()
pkg/controller/allcontollers/replicacontroller.go:24
↓ 1 callersFunctionNewWorkflowController
()
pkg/serveless/workflow/workflow.go:24
↓ 1 callersMethodParseInspectInfoToContainerState
(inspectInfo *types.ContainerJSON)
pkg/kubelet/runtime/statusUtil.go:243
↓ 1 callersMethodPlegPodContainerNeedRecreateHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:82
↓ 1 callersMethodPlegPodNeedCreateHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:35
↓ 1 callersMethodPlegPodNeedDeleteHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:66
↓ 1 callersMethodPlegPodNeedRestartHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:73
↓ 1 callersMethodPlegPodNeedStartHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:49
↓ 1 callersMethodPlegPodNeedStopHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:58
↓ 1 callersMethodPlegPodNeedUpdateHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:43
↓ 1 callersMethodPlegPodSyncHandler
(event *pleg.PodLifecycleEvent)
pkg/kubelet/kubelet/chanListen.go:89
↓ 1 callersMethodPodsArrayToMap
把一个Pod的数组转化为map[UUID]->Pod的映射
pkg/kubelet/status/apiserverUtil.go:146
↓ 1 callersFunctionPublishDeletePod
(pod *apiObject.PodStore)
pkg/message/msgPublish.go:135
↓ 1 callersFunctionPublishRequestNodeScheduleMsg
发布消息的组件函数
pkg/message/msgPublish.go:35
↓ 1 callersFunctionPublishUpdateJobFile
接受的消息是job的metadata 这里资源的URL是job的spec的URL，而不是文件的URL 但是最终处理的时候会检查两者都存在的时候才会创建Pod，去执行任务
pkg/message/msgPublish.go:164
↓ 1 callersMethodPullNodeAllPods
NodeAllPodsURL = "/api/v1/nodes/:name/pods"
pkg/kubelet/status/apiserverUtil.go:104
↓ 1 callersFunctionPushImageToRegistry
把镜像推送到本地的miniK8s的镜像管理中心
pkg/serveless/dockerregistry/registry.go:109
↓ 1 callersMethodPushNodePodStatus
PodSpecStatusURL = "/api/v1/namespaces/:namespace/pods/:name/status" 更新Pod的状态信息，发送给APIServer
pkg/kubelet/status/apiserverUtil.go:52
↓ 1 callersMethodPushNodeStatus
这个文件主要存放和APIServer打交道的函数 注意包含从APIServer Pull数据和Push数据的函数 NodeSpecStatusURL = "/api/v1/nodes/:name/status"
pkg/kubelet/status/apiserverUtil.go:19
↓ 1 callersMethodRecreatePodContainer
(pod *apiObject.PodStore)
pkg/kubelet/runtime/runtime.go:21
↓ 1 callersMethodRegisterNode
()
pkg/kubelet/kubelet/kubelet.go:62
↓ 1 callersMethodRemoveFile
(path string)
pkg/gpu/sshclient/sshclient.go:26
↓ 1 callersMethodRequestSchedule
处理调度请求的消息
pkg/scheduler/app/scheduler.go:117
↓ 1 callersMethodRestartPod
(pod *apiObject.PodStore)
pkg/kubelet/worker/workerManager.go:18
↓ 1 callersMethodRestartPod
(pod *apiObject.PodStore)
pkg/kubelet/runtime/runtime.go:19
↓ 1 callersMethodRun
()
pkg/gpu/jobserver/jobserver.go:258
↓ 1 callersMethodRun
()
pkg/kubeproxy/app/proxy.go:243
↓ 1 callersMethodRun
Run 运行plegManager
pkg/kubeproxy/app/dnsManager.go:5
↓ 1 callersMethodRun
Run 这是一个阻塞的函数，会一直运行 调用的时候需要放到goroutine中
pkg/kubelet/worker/worker.go:49
↓ 1 callersMethodRun
()
pkg/kubelet/kubelet/kubelet.go:94
↓ 1 callersMethodRunCmds
执行多条命令
pkg/gpu/sshclient/sshclient.go:15
↓ 1 callersMethodRunTask
(task WorkTask)
pkg/kubelet/worker/worker.go:60
↓ 1 callersMethodSaveIPTables
(path string)
pkg/kubeproxy/app/iptablesManager.go:33
↓ 1 callersMethodScaleDown
(funcName, funcNamespace string)
pkg/serveless/function/controller.go:178
← previousnext →201–300 of 814, ranked by callers