MCPcopy Create free account

hub / github.com/Musicminion/minik8s / functions

Functions814 in github.com/Musicminion/minik8s

⨍ Functions 814◇ Types & classes 166↳ Endpoints 4
↓ 2 callersMethodCompactJobScriptPath
()
pkg/gpu/jobserver/jobserver.go:105
↓ 2 callersMethodCreateContainer
创建容器的方法,返回容器的ID和错误
pkg/kubelet/runtime/container/container.go:25
↓ 2 callersMethodCreateFunction
新来一个函数，就创建一个函数
pkg/serveless/function/operation.go:25
↓ 2 callersFunctionDelAllToken
()
pkg/apiserver/app/handlers/tokenHanlder.go:49
↓ 2 callersMethodDelPodFromCache
DelPodFromCache 从缓存中删除Pod的存储对象
pkg/kubelet/status/status.go:25
↓ 2 callersFunctionDeleteAPIObjectToServer
发送删除API对象的请求到服务器
pkg/kubectl/kubectlutil/apiObjectUtil.go:58
↓ 2 callersMethodDeleteFunction
删除函数，就是删除函数的副本Replica
pkg/serveless/function/operation.go:64
↓ 2 callersMethodDeleteService
(serviceUpdate *entity.ServiceUpdate)
pkg/kubeproxy/app/iptablesManager.go:31
↓ 2 callersMethodDnsCreateHandler
(parsedMsg *message.Message)
pkg/controller/allcontollers/dnscontroller.go:51
↓ 2 callersMethodDnsDeleteHandler
(parsedMsg *message.Message)
pkg/controller/allcontollers/dnscontroller.go:91
↓ 2 callersMethodDownloadFile
(remotePath string, localPath string)
pkg/gpu/sshclient/sshclient.go:30
↓ 2 callersMethodGetAPIVersion
()
pkg/apiObject/node.go:44
↓ 2 callersMethodGetAPIVersion
()
pkg/apiObject/service.go:64
↓ 2 callersMethodGetAllObject
(valueType interface{})
util/rediscache/redisClient.go:21
↓ 2 callersFunctionGetAllPodFromAPIServer
()
pkg/controller/allcontollers/common.go:11
↓ 2 callersMethodGetAnnotations
()
pkg/apiObject/node.go:56
↓ 2 callersMethodGetContainerInspectInfo
获取容器Inspect的信息
pkg/kubelet/runtime/container/container.go:258
↓ 2 callersMethodGetContainerStats
获取某个容器的状态，返回容器的状态和错误 注意：Stats反应的是容器的实时运行状态，比如CPU、内存状态，而不是什么容器是否在运行的这些 要获取容器是否在运行之类的状态，需要使用client.ContainerInspect
pkg/kubelet/runtime/container/container.go:232
↓ 2 callersFunctionGetHostSystemCPUUsage
GetSystemCPUUsage 返回当前系统CPU使用率
util/host/host.go:81
↓ 2 callersFunctionGetHostSystemMemoryUsage
GetSystemMemoryUsage 返回当前系统内存使用率
util/host/host.go:56
↓ 2 callersMethodGetIP
()
pkg/apiObject/node.go:40
↓ 2 callersMethodGetLabels
()
pkg/apiObject/node.go:52
↓ 2 callersMethodGetName
()
pkg/apiObject/service.go:92
↓ 2 callersMethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/node.go:61
↓ 2 callersMethodGetObjectKind
以下函数用来是实现apiObject.Object接口
pkg/apiObject/service.go:101
↓ 2 callersMethodGetObjectNamespace
()
pkg/apiObject/dns.go:66
↓ 2 callersMethodGetPorts
()
pkg/apiObject/service.go:72
↓ 2 callersMethodGetReplicaSetNamespace
()
pkg/apiObject/replicaSet.go:26
↓ 2 callersMethodGetRuntimeNodeStatus
GetRuntimeNodeStatus 获取运行时Node的状态信息
pkg/kubelet/runtime/runtime.go:25
↓ 2 callersMethodGetType
()
pkg/apiObject/service.go:68
↓ 2 callersMethodGetUUID
()
pkg/apiObject/node.go:48
↓ 2 callersMethodInitCache
初始化删除所有的key
util/rediscache/redisClient.go:14
↓ 2 callersMethodMakeDirectory
(path string)
pkg/gpu/sshclient/sshclient.go:20
↓ 2 callersFunctionNewEtcdStore
创建一个新的Etcd客户端存储
pkg/etcd/etcd.go:43
↓ 2 callersFunctionNewPodWorker
NewPodWorker
pkg/kubelet/worker/worker.go:32
↓ 2 callersFunctionNewPodWorkerManager
()
pkg/kubelet/worker/workerManager.go:39
↓ 2 callersFunctionNewRedisCache
创建一个redis缓存的实例
util/rediscache/redisClient.go:195
↓ 2 callersFunctionNewRuntimeManager
NewRuntimeManager 创建一个RuntimeManager
pkg/kubelet/runtime/runtime.go:44
↓ 2 callersFunctionNewSubscriber
(conf *MsgConfig)
pkg/message/subscriber.go:22
↓ 2 callersFunctionPubelishUpdateHost
(hostUpdate *entity.HostUpdate)
pkg/message/msgPublish.go:219
↓ 2 callersMethodPublish
此外在发布消息的时候，也要检测对应的key绑定的队列是否存在，如果不存在，消息会丢失 key：你要发给谁，就把key设置成谁的名字 contentType：消息的类型，比如json、text等,参考下面的变量 const ContentTypeJson = "application/json" co
pkg/message/publisher.go:56
↓ 2 callersFunctionPublishUpdateDns
(dnsUpdate *entity.DnsUpdate)
pkg/message/msgPublish.go:191
↓ 2 callersFunctionPublishUpdatePod
(podUpdate *entity.PodUpdate)
pkg/message/msgPublish.go:109
↓ 2 callersMethodReduceReplicaPodsNums
(meetRequirePods []apiObject.PodStore, num int)
pkg/controller/allcontollers/replicacontroller.go:164
↓ 2 callersMethodRegisterNode
注册和反注册的功能 注册节点
pkg/kubelet/status/status.go:37
↓ 2 callersMethodResetCache
resetCache 重置缓存
pkg/kubelet/status/status.go:30
↓ 2 callersMethodRestartContainer
重启一个容器，返回容器的ID和错误
pkg/kubelet/runtime/container/container.go:275
↓ 2 callersMethodRun
()
pkg/scheduler/app/scheduler.go:203
↓ 2 callersMethodStop
()
pkg/kubelet/worker/worker.go:56
↓ 2 callersMethodToHPA
定义hpaStore到hpa的转换函数
pkg/apiObject/hpa.go:49
↓ 2 callersMethodToPod
定义PodStore到Pod的转换器
pkg/apiObject/pod.go:236
↓ 2 callersMethodToReplicaSet
定义ReplicaSetStore转化为ReplicaSet的函数
pkg/apiObject/replicaSet.go:66
↓ 2 callersMethodToStore
定义Pod到PodStore的转换器
pkg/apiObject/pod.go:227
↓ 2 callersMethodToWorkflow
定义WorkflowStore转化为Workflow的函数
pkg/apiObject/workflow.go:106
↓ 2 callersMethodToWorkflowStore
定义Workflow转化为WorkflowStore的函数
pkg/apiObject/workflow.go:96
↓ 2 callersMethodUpdate
(key string, value interface{})
util/rediscache/redisClient.go:22
↓ 2 callersMethodUpdatePodRecord
************************************************************ 这里都是podStatus的增删改查函数
pkg/kubelet/pleg/plegManager.go:36
↓ 2 callersMethodUpdatePodToCache
(pod *apiObject.PodStore)
pkg/kubelet/status/status.go:89
↓ 2 callersFunctionVerifyToken
(token string)
pkg/apiserver/app/handlers/tokenHanlder.go:57
↓ 2 callersMethodWriteBackResultToServer
(phase string, result string, namespace string, name string)
pkg/serveless/workflow/workflow.go:150
↓ 2 callersFunctioncalculateCPUPercentUnix
辅助函数，用来计算CPU使用率
pkg/kubelet/runtime/container/container.go:409
↓ 2 callersFunctioncalculateMemoryPercentUnix
辅助函数，用来计算内存使用率
pkg/kubelet/runtime/container/container.go:426
↓ 2 callersFunctionconvertEventToWatchRes
(event *etcd.Event)
pkg/etcd/etcd.go:109
↓ 2 callersMethodcreatePodContainer
创建Pod里面的单个容器， 返回容器的ID
pkg/kubelet/runtime/commonContainerUtil.go:175
↓ 2 callersFunctionparseImageRef
工具函数 解析镜像"docker.io/library/busybox:latest", 返回 "busybox:latest"
pkg/kubelet/runtime/image/image.go:183
↓ 2 callersFunctionprintDeleteResult
============================================== 打印Delete的结果和报错信息，尽可能对用户友好 ============================================== Colorful Print Functions ==
pkg/kubectl/cmd/delete.go:134
↓ 2 callersFunctionprintDnssResult
(dnss []apiObject.HpaStore)
pkg/kubectl/cmd/get.go:784
↓ 2 callersFunctionprintFunctionsResult
(functions []apiObject.Function)
pkg/kubectl/cmd/get.go:881
↓ 2 callersFunctionprintHpasResult
(hpas []apiObject.HPAStore)
pkg/kubectl/cmd/get.go:826
↓ 2 callersFunctionprintJobsResult
(jobs []apiObject.JobStore)
pkg/kubectl/cmd/get.go:695
↓ 2 callersFunctionprintPodsResult
============================================== 打印get的结果和报错信息，尽可能对用户友好 ============================================== Colorful Print Functions =====
pkg/kubectl/cmd/get.go:580
↓ 2 callersFunctionprintReplicasetsResult
(replicasets []apiObject.ReplicaSetStore)
pkg/kubectl/cmd/get.go:856
↓ 2 callersFunctionprintServicesResult
(service []apiObject.ServiceStore)
pkg/kubectl/cmd/get.go:636
↓ 2 callersFunctionprintWorkflowsResult
(workflows []apiObject.WorkflowStore)
pkg/kubectl/cmd/get.go:906
↓ 2 callersMethodremovePodAllContainer
会尝试删除所有的容器，如果遇到某个容器删除失败，则会继续删除其他容器，最后返回错误信息
pkg/kubelet/runtime/commonContainerUtil.go:33
↓ 2 callersFunctionselectiveUpdatePodStatus
选择性的更新Pod的状态
pkg/apiserver/app/handlers/podHandler.go:569
↓ 1 callersFunctionAddNewToken
返回一个新的令牌，并在屏幕上显示它
pkg/apiserver/app/handlers/tokenHanlder.go:25
↓ 1 callersMethodAddPodContainerNeedRecreateEvent
(podID string, podData *apiObject.PodStore)
pkg/kubelet/pleg/plegChanUtil.go:63
↓ 1 callersMethodAddPodNeedCreateEvent
(podID string, podData *apiObject.PodStore)
pkg/kubelet/pleg/plegChanUtil.go:31
↓ 1 callersMethodAddPodNeedDeleteEvent
(podID string)
pkg/kubelet/pleg/plegChanUtil.go:23
↓ 1 callersMethodAddPodNeedStartEvent
这个包里面主要提供一些工具函数，用来向plegChannel里面添加事件 不同的事件通过不同的函数添加。不要直接添加事件，注意传递的参数
pkg/kubelet/pleg/plegChanUtil.go:7
↓ 1 callersMethodAddReplicaPodsNums
增加或者减少pod的数量
pkg/controller/allcontollers/replicacontroller.go:110
↓ 1 callersFunctionAllocClusterIP
()
pkg/apiserver/app/helper/manageService.go:16
↓ 1 callersMethodAppendFile
(path string, content string)
pkg/gpu/sshclient/sshclient.go:25
↓ 1 callersMethodAutoReconnect
接受一个通道
pkg/message/publisher.go:93
↓ 1 callersMethodAutoReconnect
接受一个通道
pkg/message/subscriber.go:48
↓ 1 callersFunctionBindFinoutQueue
绑定node的相关queue到所有的fanout队列
pkg/message/init.go:54
↓ 1 callersMethodBuildFuncImage
构建函数的镜像
pkg/serveless/function/operation.go:76
↓ 1 callersMethodCalculateAverageCPUUsage
(pods []apiObject.PodStore)
pkg/controller/allcontollers/hpacontroller.go:219
↓ 1 callersMethodCalculateAverageMemoryUsage
(pods []apiObject.PodStore)
pkg/controller/allcontollers/hpacontroller.go:227
↓ 1 callersMethodCalculateContainerResource
(containerID string)
pkg/kubelet/runtime/container/container.go:388
↓ 1 callersMethodCalculateExpectedReplicas
(hpa apiObject.HPAStore, cpuUsage float64, memoryUsage float64)
pkg/controller/allcontollers/hpacontroller.go:235
↓ 1 callersMethodCalculatePodPhaseByContainerStatus
注意：没有容器的时候，Pod的状态是Pending
pkg/kubelet/runtime/statusUtil.go:193
↓ 1 callersMethodCheckAndUpdateJobStatus
更新任务的状态 返回1表示任务完成，返回0表示任务未完成，返回-1表示任务出错
pkg/gpu/jobserver/jobserver.go:208
↓ 1 callersMethodCheckIfRegisterd
这个函数用于向APIserver查询Node是否已经注册 const config.NodeSpecURL untyped string = "/api/v1/nodes/:name"
pkg/kubelet/status/apiserverUtil.go:209
↓ 1 callersFunctionCheckRegistry
初始化的时候检查，如果发现没有镜像管理中心的容器，则创建一个 创建一个docker image的镜像管理中心，用来管理用户上传的自定义的各种镜像
pkg/serveless/dockerregistry/registry.go:30
↓ 1 callersMethodCheckStatus
检查任务状态
pkg/gpu/jobserver/jobserver.go:180
↓ 1 callersMethodChooseFromNodes
*********************************************************************/ *********************************************************************/ 从所有的节点里面
pkg/scheduler/app/scheduler.go:101
↓ 1 callersMethodCompactJobFiles
()
pkg/gpu/jobserver/jobserver.go:89
↓ 1 callersMethodCompactRunCmd
()
pkg/gpu/jobserver/jobserver.go:81
← previousnext →101–200 of 814, ranked by callers