MCPcopy Create free account

hub / github.com/Musicminion/minik8s / functions

Functions814 in github.com/Musicminion/minik8s

⨍ Functions 814◇ Types & classes 166↳ Endpoints 4
↓ 260 callersFunctionErrorLog
错误日志
pkg/k8log/k8log.go:73
↓ 129 callersFunctionInfoLog
基本的日志信息
pkg/k8log/k8log.go:57
↓ 114 callersFunctionReplace
replace 将 URL 中的 toChangeStr 替换为newStr
util/stringutil/stringutil.go:23
↓ 113 callersFunctionDebugLog
Debug日志
pkg/k8log/k8log.go:111
↓ 70 callersFunctionGetAPIServerURLPrefix
如果时localhost模式，返回的是 "http://127.0.0.1:8090"
pkg/config/ipConfig.go:28
↓ 55 callersFunctionprintApplyResult
============================================== 打印Apply的结果和报错信息，尽可能对用户友好 ============================================== Colorful Print Functions ===
pkg/kubectl/cmd/apply.go:604
↓ 48 callersMethodGet
(key string)
util/rediscache/redisClient.go:19
↓ 43 callersMethodClose
回收的时候执行关闭函数
pkg/message/publisher.go:87
↓ 42 callersMethodPut
增删改查的接口操作
util/rediscache/redisClient.go:17
↓ 27 callersMethodPrefixGet
之前写的是直接赋值ret[i],这样会寄!,应该调用append
pkg/etcd/etcd.go:159
↓ 20 callersMethodGetPodName
工具函数，用来获取Pod的名字
pkg/apiObject/pod.go:248
↓ 17 callersFunctionNewUUID
这个对应的是Google V4的UUID，和K8s保持一致
util/uuid/uuid.go:9
↓ 17 callersMethodRun
()
pkg/serveless/server/server.go:16
↓ 17 callersFunctionStringSliceToJsonArray
(data []string)
util/stringutil/stringutil.go:27
↓ 14 callersFunctionGenerateRandomStr
GenerateRandomStr 生成给定长度的随机字符串
util/stringutil/stringutil.go:11
↓ 13 callersMethodDel
删除指定的Key
pkg/etcd/etcd.go:98
↓ 13 callersMethodGetName
()
pkg/apiObject/node.go:148
↓ 13 callersFunctionReadFile
(filePath string)
util/file/file.go:8
↓ 12 callersMethodGetPodUUID
()
pkg/apiObject/pod.go:243
↓ 12 callersMethodListContainersWithOpt
按照条件查询容器列表，返回容器的列表和错误
pkg/kubelet/runtime/container/container.go:201
↓ 11 callersFunctionFatalLog
Fatal日志
pkg/k8log/k8log.go:135
↓ 11 callersMethodGetObjectNamespace
()
pkg/apiObject/pod.go:269
↓ 11 callersFunctionParseAPIObjectFromYamlfileContent
需要给定一个OBJ对象，然后根据这个玩野
pkg/kubectl/kubectlutil/apiObjectUtil.go:30
↓ 10 callersFunctionDefaultListwatcherConfig
()
pkg/listwatcher/listwatcherConfig.go:9
↓ 10 callersMethodGetObjectName
()
pkg/apiObject/ApiObject.go:28
↓ 10 callersFunctionPeriod
waitTime: 等待时间的数组，如果你传入的数组是[1,2,3] 那么程序会等待1s,2s,3s之后再执行callback callback: 你需要执行的函数 ifLoop: 是否循环执行，如果为true，那么程序会一直执行callback, 还是上面的例子，如果ifLoop为true， 那么
util/executor/executor.go:16
↓ 10 callersFunctionprintApplyObjectInfo
(kind ApplyObject, name string, namespace string)
pkg/kubectl/cmd/apply.go:635
↓ 9 callersMethodGetNamespace
()
pkg/apiObject/service.go:96
↓ 9 callersFunctionPostAPIObjectToServer
用来解决发送API对象到服务器的问题
pkg/kubectl/kubectlutil/apiObjectUtil.go:40
↓ 9 callersMethodPrefixDel
(key string)
pkg/etcd/etcd.go:223
↓ 9 callersFunctionPublishMsg
发布消息的组件
pkg/message/msgPublish.go:30
↓ 8 callersMethodAddTask
Worker添加任务
pkg/kubelet/worker/worker.go:85
↓ 8 callersFunctionGetHostName
特别感谢下面的库，提供了很多系统信息的获取
util/host/host.go:15
↓ 8 callersMethodGetPodNamespace
()
pkg/apiObject/pod.go:252
↓ 8 callersFunctionNewListWatcher
(conf *ListwatcherConfig)
pkg/listwatcher/listwatcher.go:13
↓ 8 callersMethodToDns
()
pkg/apiObject/dns.go:50
↓ 7 callersMethodAdd
(key, value string)
pkg/entity/endpoints.go:5
↓ 7 callersFunctionDefaultMsgConfig
默认的配置是连接本地的RabbitMQ服务器，使用Guest账号
pkg/message/msgConfig.go:30
↓ 7 callersFunctionNewStatusManager
(apiserverURLPrefix string)
pkg/kubelet/status/status.go:54
↓ 7 callersMethodReadFile
File相关的操作
pkg/gpu/sshclient/sshclient.go:23
↓ 7 callersFunctionWarnLog
警告日志
pkg/k8log/k8log.go:92
↓ 7 callersMethodWatchQueue_Block
WatchQueue_Block 阻塞的方式监听队列，一旦有消息就会调用handleFunc 那么,只有当调用者主动关闭done的时候，才会退出
pkg/listwatcher/listwatcher.go:30
↓ 6 callersMethodDelete
(key string)
util/rediscache/redisClient.go:18
↓ 6 callersFunctionGetEndpoints
根据key和value获取所有的endpoints
pkg/apiserver/app/helper/manageEndpoint.go:21
↓ 6 callersMethodGetJobNamespace
()
pkg/apiObject/job.go:103
↓ 6 callersFunctionGetMasterIP
()
pkg/config/ipConfig.go:17
↓ 6 callersMethodGetObjectName
()
pkg/apiObject/pod.go:265
↓ 6 callersFunctionParseJsonMessageFromBytes
将Message转换为Json格式的Message（从[]byte转换）
pkg/message/message.go:47
↓ 6 callersFunctionPublishUpdateService
(serviceUpdate *entity.ServiceUpdate)
pkg/message/msgPublish.go:59
↓ 6 callersMethodPullImageWithPolicy
PullImageWithPolicy从镜像仓库拉取镜像 如果镜像已经存在，那么根据策略决定是否重新拉取 如果镜像不存在，那么就拉取镜像 如果镜像不存在，且策略是ImagePullPolicyNever，那么就返回错误
pkg/kubelet/runtime/image/image.go:25
↓ 6 callersMethodStartContainer
启动一个容器，返回容器的ID和错误
pkg/kubelet/runtime/container/container.go:90
↓ 6 callersMethodfindLocalImageIDsByImageRef
通过ImageRef查找本地镜像,返回镜像ID的切片
pkg/kubelet/runtime/image/image.go:148
↓ 5 callersFunctionCompressToZip
压缩文件或文件夹为ZIP格式 压缩文件夹 /path/to/your/folder， 建议不要写作 /path/to/your/folder/，否则会出问题
util/zip/zip.go:11
↓ 5 callersFunctionDecompressZip
(source, target string)
util/zip/zip.go:15
↓ 5 callersMethodGetObjectName
()
pkg/apiObject/service.go:105
↓ 5 callersMethodGetObjectNamespace
()
pkg/apiObject/ApiObject.go:29
↓ 5 callersMethodRemoveContainer
删除一个容器，返回容器的ID和错误
pkg/kubelet/runtime/container/container.go:125
↓ 5 callersMethodRun
(stopCh <-chan struct{})
pkg/controller/ctrlmanager/ctrlmanager.go:9
↓ 5 callersMethodRun
Run 运行状态管理器，函数不会阻塞
pkg/kubelet/status/status.go:44
↓ 5 callersMethodScaleUp
(funcName, funcNamespace string, num int)
pkg/serveless/function/controller.go:32
↓ 5 callersMethodWriteFile
(path string, content string)
pkg/gpu/sshclient/sshclient.go:24
↓ 4 callersMethodAddPod
(pod *apiObject.PodStore)
pkg/kubelet/worker/workerManager.go:14
↓ 4 callersFunctionDeleteConf
(dns apiObject.Dns)
util/nginx/nginx.go:80
↓ 4 callersFunctionFormatConf
(dns apiObject.Dns)
util/nginx/nginx.go:16
↓ 4 callersFunctionGetAPIObjectTypeFromYamlFile
把一个API文件对象从文件的数据流里面读取出来kind字段 返回的可能是Pod, Service, Deployment, Namespace, ConfigMap, Secret
pkg/kubectl/kubectlutil/apiObjectUtil.go:14
↓ 4 callersMethodGetJobName
()
pkg/apiObject/job.go:99
↓ 4 callersMethodGetRuntimeNodeName
GetRuntimePodStatus 获取运行时Node的名字
pkg/kubelet/runtime/runtime.go:31
↓ 4 callersFunctionWriteConf
(dns apiObject.Dns, conf string)
util/nginx/nginx.go:34
↓ 4 callersFunctionparseNameAndNamespace
args: [podNamespace]/[podName] 返回值: podNamespace, podName, error
pkg/kubectl/cmd/get.go:961
↓ 3 callersMethodAddPodNeedRestartEvent
(podID string)
pkg/kubelet/pleg/plegChanUtil.go:47
↓ 3 callersMethodAddPodToCache
AddPodToCache 将Pod的存储对象添加到缓存中
pkg/kubelet/status/status.go:18
↓ 3 callersFunctionContainsString
(list []string, target string)
util/stringutil/stringutil.go:32
↓ 3 callersFunctionConvertBytesToZip
(source []byte, target string)
util/zip/zip.go:30
↓ 3 callersMethodDelAll
删除所有的key
pkg/etcd/etcd.go:104
↓ 3 callersMethodDelPodByPodID
(podUUID string)
pkg/kubelet/runtime/runtime.go:20
↓ 3 callersMethodGetAllPodFromCache
GetAllPodFromCache 从缓存中获取所有Pod的存储对象
pkg/kubelet/status/status.go:22
↓ 3 callersFunctionGetHostIp
()
util/host/host.go:23
↓ 3 callersMethodGetObject
(key string, valueType interface{})
util/rediscache/redisClient.go:20
↓ 3 callersMethodGetObjectName
()
pkg/apiObject/node.go:65
↓ 3 callersMethodGetObjectNamespace
()
pkg/apiObject/job.go:86
↓ 3 callersMethodGetPodFromCache
GetPodFromCache 从缓存中获取Pod的存储对象
pkg/kubelet/status/status.go:20
↓ 3 callersMethodGetRuntimeAllPodStatus
GetRuntimeAllPodStatus 获取运行时Pod的状态信息
pkg/kubelet/runtime/runtime.go:28
↓ 3 callersFunctionGetServelessServerURLPrefix
()
pkg/config/ipConfig.go:32
↓ 3 callersMethodListContainers
列出所有的k8s的容器，包括已经停止的，返回容器的列表和错误
pkg/kubelet/runtime/container/container.go:155
↓ 3 callersFunctionNewIptableManager
()
pkg/kubeproxy/app/iptablesManager.go:49
↓ 3 callersFunctionNewPublisher
(conf *MsgConfig)
pkg/message/publisher.go:21
↓ 3 callersFunctionNewSSHClient
(username, password string)
pkg/gpu/sshclient/sshclient.go:42
↓ 3 callersFunctionPodUpdateWithNode
根据node来路由消息到不同的队列
pkg/message/msgConfig.go:53
↓ 3 callersMethodReduceOneHpaPod
(pod apiObject.PodStore)
pkg/controller/allcontollers/hpacontroller.go:103
↓ 3 callersMethodRemoveDirectory
(path string)
pkg/gpu/sshclient/sshclient.go:19
↓ 3 callersMethodRun
()
pkg/apiserver/app/server/apiserver.go:15
↓ 3 callersMethodRunCmd
执行命令
pkg/gpu/sshclient/sshclient.go:13
↓ 3 callersMethodStopContainer
停止一个容器，返回容器的ID和错误 注意：如果多次调用这个方法，重复停止一个容器，不会报错
pkg/kubelet/runtime/container/container.go:108
↓ 3 callersMethodSubscribe
调用者主动关闭这个通道，否则程序阻塞在里面运行 传递处理函数，然后在子线程里面会一直监听新来的消息，一旦有消息就会调用处理函数
pkg/message/subscriber.go:90
↓ 3 callersFunctionUpdateEndPoints
(pod apiObject.PodStore)
pkg/apiserver/app/helper/manageEndpoint.go:46
↓ 3 callersFunctiondelUnusedJob
============================================== Other Util Functions ==============================================
pkg/kubectl/cmd/apply.go:656
↓ 2 callersMethodAddCallRecord
(funcName, funcNamespace string)
pkg/serveless/function/controller.go:30
↓ 2 callersMethodAddOneHpaPod
(hpa apiObject.HPAStore, podTemplate apiObject.Pod)
pkg/controller/allcontollers/hpacontroller.go:72
↓ 2 callersMethodChangeDirectory
切换目录
pkg/gpu/sshclient/sshclient.go:18
↓ 2 callersFunctionCheckIfPodMeetRequirement
(pod *apiObject.PodStore, selectors map[string]string)
pkg/controller/allcontollers/common.go:29
next →1–100 of 814, ranked by callers