Functions — github.com/Musicminion/minik8s

hub / github.com/Musicminion/minik8s / functions

Functions814 in github.com/Musicminion/minik8s

⨍ Functions 814◇ Types & classes 166↳ Endpoints 4

↓ 1 callersMethodstopPodContainer

(pod *apiObject.PodStore, container *apiObject.Container)

pkg/kubelet/runtime/commonContainerUtil.go:146

↓ 1 callersMethodsyncLoopIteration

当管道发生变化时的处理函数

pkg/kubeproxy/app/proxy.go:151

↓ 1 callersMethodsyncLoopIteration

(podUpdates <-chan *entity.PodUpdate)

pkg/kubelet/kubelet/kubelet.go:137

↓ 1 callersMethodupdateNginxConfig

通知nginx Pod 更新Config

pkg/kubeproxy/app/proxy.go:72

↓ 1 callersMethodupdatePlegRecord

更新Pleg里面的缓存这里涉及到三者的关系，一个是运行时的状态，一个是缓存的Pod，一个是pleg里面的podRecord podRecord是一个和状态强相关的结构体，所以更新依据：runtimePodStatus-> podRecord 然后我们的比较逻辑是podRecord<->cacheP

pkg/kubelet/pleg/plegGenerator.go:20

MethodAddCallRecord

(funcName, funcNamespace string)

pkg/serveless/function/controller.go:161

MethodAddContainerNeedSyncEvent

(podID string)

pkg/kubelet/pleg/plegChanUtil.go:55

FunctionAddDns

创建Dns "/apis/v1/namespaces/:namespace/dns"

pkg/apiserver/app/handlers/dnsHandler.go:23

FunctionAddFunction

AddFunction

pkg/apiserver/app/handlers/funcHandler.go:105

FunctionAddHPA

POST 创建一个HPA "/apis/v1/namespaces/:namespace/hpa"

pkg/apiserver/app/handlers/hpaHandler.go:105

FunctionAddJob

创建Job "/apis/v1/namespaces/:namespace/jobs"

pkg/apiserver/app/handlers/jobHandler.go:117

FunctionAddJobFile

一定要注意选择性的更新JobFile JobFile包含了Job的Error、Output、用户上传的原文件 "/apis/v1/namespaces/:namespace/jobfiles"

pkg/apiserver/app/handlers/jobHandler.go:519

FunctionAddNode

添加新的Node

pkg/apiserver/app/handlers/nodeHandler.go:120

FunctionAddPod

POST "/api/v1/namespaces/:namespace/pods"

pkg/apiserver/app/handlers/podHandler.go:151

MethodAddPod

AddPod 添加pod

pkg/kubelet/worker/workerManager.go:70

MethodAddPodNeedStopEvent

(podID string)

pkg/kubelet/pleg/plegChanUtil.go:15

MethodAddPodNeedUpdateEvent

(podID string, podData *apiObject.PodStore)

pkg/kubelet/pleg/plegChanUtil.go:39

MethodAddPodToCache

************************************************************ 这里都是缓存的增删改查函数

pkg/kubelet/status/status.go:64

FunctionAddPodToEtcd

添加Pod到etcd中

util/testutil/testutil.go:95

FunctionAddReplicaSet

"/apis/v1/namespaces/:namespace/replicasets" POST

pkg/apiserver/app/handlers/replicaSetHandler.go:146

FunctionAddService

添加新的Service POST "/api/v1/namespaces/:namespace/services"

pkg/apiserver/app/handlers/serviceHandler.go:26

FunctionAddWorkFlow

AddWorkFlow POST /apis/v1/namespaces/:namespace/workflows

pkg/apiserver/app/handlers/workflowHandler.go:106

MethodAppendFile

(path string, content string)

pkg/gpu/sshclient/sshclient.go:82

MethodChangeDirectory

(path string)

pkg/gpu/sshclient/sshclient.go:56

FunctionCleanupTestNetwork

清理Docker虚拟网络

util/testutil/testutil.go:72

MethodClearIPTables

ClearIPTables 清除所有的 iptables 规则

pkg/kubeproxy/app/iptablesManager.go:313

FunctionClose

关闭文件

pkg/k8log/k8log.go:157

FunctionComvertTarToBytes

(source string)

util/zip/zip.go:49

FunctionConvertBytesToTar

(source []byte, target string)

util/zip/zip.go:60

MethodCreateNginxDns

()

pkg/controller/allcontollers/dnscontroller.go:225

MethodCreatePod

(pod *apiObject.PodStore)

pkg/kubelet/runtime/runtime.go:15

MethodCreatePod

************************************************************ 这里写RunTimeManager的函数 CreatePod 创建pod

pkg/kubelet/runtime/runtime.go:56

FunctionDecompressTar

(source, target string)

util/zip/zip.go:45

MethodDel

(key string)

pkg/entity/endpoints.go:20

MethodDelPodByPodID

(podUUID string)

pkg/kubelet/worker/workerManager.go:19

MethodDelPodByPodID

根据pod的UUID删除pod，用来处理pleg的删除事件

pkg/kubelet/worker/workerManager.go:218

MethodDelPodByPodID

DelPodByID 通过pod的UUID删除pod

pkg/kubelet/runtime/runtime.go:167

FunctionDelRequest

对于指定的端点发送一个DELETE请求

util/netRequest/delRequest.go:8

FunctionDelay

waitTime: 等待时间，将一个函数延迟执行

util/executor/executor.go:41

MethodDelete

(key string)

util/rediscache/redisClient.go:63

FunctionDeleteDns

删除Dns "/apis/v1/namespaces/:namespace/dns/:name"

pkg/apiserver/app/handlers/dnsHandler.go:152

FunctionDeleteFunction

DeleteFunction

pkg/apiserver/app/handlers/funcHandler.go:304

FunctionDeleteHPA

DELETE 删除一个HPA "/apis/v1/namespaces/:namespace/hpa/:name"

pkg/apiserver/app/handlers/hpaHandler.go:196

FunctionDeleteImageFromRegistry

从镜像管理中心删除镜像

pkg/serveless/dockerregistry/registry.go:137

FunctionDeleteJob

"/apis/v1/namespaces/:namespace/jobs/:name"

pkg/apiserver/app/handlers/jobHandler.go:233

FunctionDeleteNode

删除Node信息

pkg/apiserver/app/handlers/nodeHandler.go:90

FunctionDeletePod

删除的时候直接删除etcd中的数据即可目前来说暂时不检查是否已经存在 "/api/v1/namespaces/:namespace/pods/:name"

pkg/apiserver/app/handlers/podHandler.go:253

MethodDeletePod

DeletePod 删除pod

pkg/kubelet/worker/workerManager.go:106

MethodDeletePod

(pod *apiObject.PodStore)

pkg/kubelet/runtime/runtime.go:16

MethodDeletePod

DeletePod 删除pod

pkg/kubelet/runtime/runtime.go:80

MethodDeletePodRecord

(podID string)

pkg/kubelet/pleg/plegManager.go:67

MethodDeletePrefix

(table, chain, prefix string)

pkg/kubeproxy/app/iptablesManager.go:291

FunctionDeleteReplicaSet

"/apis/v1/namespaces/:namespace/replicasets/:name" DELETE

pkg/apiserver/app/handlers/replicaSetHandler.go:234

FunctionDeleteService

删除Service信息

pkg/apiserver/app/handlers/serviceHandler.go:237

FunctionDeleteWorkFlow

DeleteWorkFlow DELETE /apis/v1/namespaces/:namespace/workflows/:workflow

pkg/apiserver/app/handlers/workflowHandler.go:196

MethodDnsUpdatehandler

(msg amqp.Delivery)

pkg/controller/allcontollers/dnscontroller.go:139

MethodDownloadFile

(remotePath string, localPath string)

pkg/gpu/sshclient/sshclient.go:104

MethodExecPodContainer

(pod *apiObject.PodStore, cmd []string)

pkg/kubelet/worker/workerManager.go:21

MethodExecPodContainer

(pod *apiObject.PodStore, cmd []string)

pkg/kubelet/worker/workerManager.go:273

MethodExecPodContainer

根据pod的UUID筛选container，在容器中执行命令

pkg/kubelet/runtime/runtime.go:240

MethodGet

修复了一下逻辑，通过返回的时候创建一个切片，而不是直接组装

pkg/etcd/etcd.go:63

MethodGet

(key string)

pkg/entity/endpoints.go:13

MethodGet

(key string)

util/rediscache/redisClient.go:71

MethodGetAPIVersion

()

pkg/apiObject/node.go:136

MethodGetAPIVersion

()

pkg/apiObject/service.go:76

FunctionGetAllNodesName

()

pkg/controller/allcontollers/common.go:48

MethodGetAllObject

获取所有的对象 - 特别注意：这个函数的用法,需要再valeType里面传递一组集合的类型，比如[]People, 就需要在valueType传递一个People的类型但是返回的时候，返回的是一个[]People类型的对象，所以需要慎重使用此外，如果json解析失败，会直接跳过这个对象，不会报错

util/rediscache/redisClient.go:121

MethodGetAllPodFromRuntime

************************************************************

pkg/kubelet/status/status.go:115

MethodGetAnnotations

()

pkg/apiObject/node.go:156

FunctionGetDns

获取单个Dns "/apis/v1/namespaces/:namespace/dns/:name"

pkg/apiserver/app/handlers/dnsHandler.go:230

FunctionGetDnsList

获取所有Dns "/apis/v1/namespaces/:namespace/dns"

pkg/apiserver/app/handlers/dnsHandler.go:287

MethodGetFuncRecord

(funcName, funcNamespace string)

pkg/serveless/function/controller.go:29

MethodGetFuncRecord

(funcName, funcNamespace string)

pkg/serveless/function/controller.go:157

FunctionGetFunction

GetFunction "/apis/v1/namespaces/:namespace/functions/:name"

pkg/apiserver/app/handlers/funcHandler.go:54

FunctionGetFunctions

GetFunctions "/apis/v1/namespaces/:namespace/functions"

pkg/apiserver/app/handlers/funcHandler.go:20

FunctionGetGlobalFunctions

GetGlobalFunctions

pkg/apiserver/app/handlers/funcHandler.go:343

FunctionGetGlobalHPAs

GET 获取全局的HPA "/apis/v1/hpa"

pkg/apiserver/app/handlers/hpaHandler.go:237

FunctionGetGlobalPods

获取系统中所有的Pod的信息

pkg/apiserver/app/handlers/podHandler.go:116

FunctionGetGlobalReplicaSets

"/apis/v1/replicasets" GET

pkg/apiserver/app/handlers/replicaSetHandler.go:122

FunctionGetGlobalWorkFlows

GET 获取全局的workflow GET /apis/v1/workflows

pkg/apiserver/app/handlers/workflowHandler.go:401

FunctionGetHPA

"/apis/v1/namespaces/:namespace/hpa/:name"

pkg/apiserver/app/handlers/hpaHandler.go:20

FunctionGetHPAs

GET 获取某个名字空间下的所有HPA "/apis/v1/namespaces/:namespace/hpa"

pkg/apiserver/app/handlers/hpaHandler.go:72

MethodGetIP

定义NodeStore的相关函数,便于获取NodeStore的相关信息

pkg/apiObject/node.go:132

MethodGetIP

()

pkg/apiObject/endpoint.go:19

FunctionGetJob

获取单个的Job @Summary 获取单个的Job "/apis/v1/namespaces/:namespace/jobs/:name"

pkg/apiserver/app/handlers/jobHandler.go:25

FunctionGetJobFile

"/apis/v1/namespaces/:namespace/jobs/:name/file"

pkg/apiserver/app/handlers/jobHandler.go:466

MethodGetJobName

()

pkg/apiObject/job.go:58

MethodGetJobNamespace

()

pkg/apiObject/job.go:62

FunctionGetJobStatus

获取Job的状态 "/apis/v1/namespaces/:namespace/jobs/:name/status"

pkg/apiserver/app/handlers/jobHandler.go:279

MethodGetJobUUID

()

pkg/apiObject/job.go:47

MethodGetJobUUID

()

pkg/apiObject/job.go:66

FunctionGetJobs

"/apis/v1/namespaces/:namespace/jobs"

pkg/apiserver/app/handlers/jobHandler.go:76

MethodGetKind

()

pkg/apiObject/node.go:140

MethodGetKind

()

pkg/apiObject/service.go:80

MethodGetLabels

()

pkg/apiObject/node.go:152

MethodGetName

定义获取name、namespace的函数

pkg/apiObject/workflow.go:115

MethodGetNamespace

()

pkg/apiObject/workflow.go:119

FunctionGetNode

获取单个Node信息某个特定的Node状态对应的NodeSpecURL = "/api/v1/nodes/:name"

pkg/apiserver/app/handlers/nodeHandler.go:21

MethodGetNodeName

()

pkg/kubelet/status/status.go:163

FunctionGetNodePods

获取Node所有的Pod NodeAllPodsURL = "/api/v1/nodes/:name/pods"

pkg/apiserver/app/handlers/nodeHandler.go:340

← previous next →401–500 of 814, ranked by callers