MCPcopy Create free account

hub / github.com/Musicminion/minik8s / functions

Functions814 in github.com/Musicminion/minik8s

⨍ Functions 814◇ Types & classes 166↳ Endpoints 4
FunctionGetNodeStatus
************************************************************************************************* 节点状态的增删改查，放在这里 api/v1/nodes/:name/status
pkg/apiserver/app/handlers/nodeHandler.go:398
FunctionGetNodes
获取所有Node信息 某个特定的Node状态 对应的NodeSpecURL = "/api/v1/nodes
pkg/apiserver/app/handlers/nodeHandler.go:68
MethodGetObject
* // - 特别注意：这个函数的用法，可以参考测试代码里面的 // - 假设你自定义了一个类型type MyType struct {Name string Age int} // - 那么你可以这样调用GetObject函数： // ``` // var myType MyTyp
util/rediscache/redisClient.go:95
MethodGetObjectKind
以下函数用来是实现apiObject.Object接口
pkg/apiObject/workflow.go:124
MethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/replicaSet.go:75
MethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/function.go:18
MethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/pod.go:261
MethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/job.go:78
MethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/hpa.go:58
MethodGetObjectKind
以下函数用来实现apiObject.Object接口
pkg/apiObject/dns.go:58
MethodGetObjectKind
GetObjectName() string
pkg/apiObject/ApiObject.go:27
MethodGetObjectName
()
pkg/apiObject/workflow.go:128
MethodGetObjectName
()
pkg/apiObject/replicaSet.go:79
MethodGetObjectName
()
pkg/apiObject/function.go:22
MethodGetObjectName
()
pkg/apiObject/job.go:82
MethodGetObjectName
()
pkg/apiObject/hpa.go:62
MethodGetObjectName
()
pkg/apiObject/dns.go:62
MethodGetObjectNamespace
()
pkg/apiObject/workflow.go:132
MethodGetObjectNamespace
()
pkg/apiObject/replicaSet.go:83
MethodGetObjectNamespace
()
pkg/apiObject/function.go:26
MethodGetObjectNamespace
()
pkg/apiObject/node.go:69
MethodGetObjectNamespace
()
pkg/apiObject/hpa.go:66
FunctionGetPod
获取单个Pod的信息 "/api/v1/namespaces/:namespace/pods"
pkg/apiserver/app/handlers/podHandler.go:25
MethodGetPodFromCache
查找到不存在的Pod，只会返回nil，不会返回error
pkg/kubelet/status/status.go:70
MethodGetPodRecord
(podID string)
pkg/kubelet/pleg/plegManager.go:59
FunctionGetPodStatus
"/api/v1/namespaces/:namespace/pods/:name/status"
pkg/apiserver/app/handlers/podHandler.go:405
MethodGetPodUUID
()
pkg/apiObject/pod.go:256
MethodGetPodUUID
()
pkg/apiObject/endpoint.go:39
FunctionGetPods
获取所有的Pod的信息 API "/api/v1/namespaces/:namespace/pods"
pkg/apiserver/app/handlers/podHandler.go:83
MethodGetPodsBySvcName
(svcName string)
pkg/kubeproxy/app/iptablesManager.go:321
MethodGetPort
()
pkg/apiObject/endpoint.go:23
MethodGetPorts
()
pkg/apiObject/service.go:88
FunctionGetReplicaSet
"/apis/v1/namespaces/:namespace/replicasets/:name" GET
pkg/apiserver/app/handlers/replicaSetHandler.go:20
FunctionGetReplicaSetStatus
"/apis/v1/namespaces/:namespace/replicasets/:name/status" GET
pkg/apiserver/app/handlers/replicaSetHandler.go:276
FunctionGetReplicaSets
"/apis/v1/namespaces/:namespace/replicasets" GET
pkg/apiserver/app/handlers/replicaSetHandler.go:76
FunctionGetRequestByTarget
Get请求 GetRequest 从指定的uri获取数据，并将数据反序列化到target指向的对象中
util/netRequest/getRequest.go:13
MethodGetRuntimeNodeIP
()
pkg/kubelet/runtime/statusUtil.go:271
MethodGetRuntimeNodeName
()
pkg/kubelet/runtime/statusUtil.go:266
MethodGetRuntimeNodeStatus
获取运行时Node的状态信息
pkg/kubelet/runtime/statusUtil.go:15
FunctionGetService
获取单个Service信息 某个特定的Service状态 对应的ServiceSpecURL = "/api/v1/services/:name"
pkg/apiserver/app/handlers/serviceHandler.go:165
FunctionGetServices
获取所有Service信息
pkg/apiserver/app/handlers/serviceHandler.go:211
MethodGetStatusCondition
()
pkg/apiObject/node.go:168
MethodGetStatusCpuPercent
()
pkg/apiObject/node.go:172
MethodGetStatusHostname
()
pkg/apiObject/node.go:160
MethodGetStatusIp
()
pkg/apiObject/node.go:164
MethodGetStatusMemPercent
()
pkg/apiObject/node.go:176
MethodGetStatusNumPods
()
pkg/apiObject/node.go:180
MethodGetStatusUpdateTime
()
pkg/apiObject/node.go:184
MethodGetType
()
pkg/apiObject/service.go:84
MethodGetUUID
()
pkg/apiObject/node.go:144
MethodGetUUID
()
pkg/apiObject/endpoint.go:15
FunctionGetWorkFlow
GetWorkFlow GET /apis/v1/namespaces/:namespace/workflows/:workflow
pkg/apiserver/app/handlers/workflowHandler.go:21
FunctionGetWorkFlowStatus
GetWorkFlowStatus GET /apis/v1/namespaces/:namespace/workflows/:workflow/status
pkg/apiserver/app/handlers/workflowHandler.go:242
FunctionGetWorkFlows
GetWorkFlows GET /apis/v1/namespaces/:namespace/workflows
pkg/apiserver/app/handlers/workflowHandler.go:72
MethodHandleHostUpdate
监听到HostUpdate消息后, 并修改本机的host文件
pkg/kubeproxy/app/proxy.go:92
MethodHandlePodUpdate
(msg amqp.Delivery)
pkg/kubelet/kubelet/kubelet.go:121
MethodHandleServiceUpdate
监听到serviceUpdate消息后，解析并写入管道
pkg/kubeproxy/app/proxy.go:55
MethodInitCache
清空redis里面的所有的数据
util/rediscache/redisClient.go:35
MethodMakeDirectory
(path string)
pkg/gpu/sshclient/sshclient.go:66
MethodMsgHandler
调度器的消息处理函数,分发给不同的消息处理函数
pkg/scheduler/app/scheduler.go:192
MethodMsgHandler
(msg amqp.Delivery)
pkg/controller/allcontollers/jobcontroller.go:125
FunctionNew
(c *serverConfig.ServerConfig)
pkg/apiserver/app/server/apiserver.go:26
FunctionNewDockerClient
* * 创建一个docker client */
pkg/kubelet/dockerClient/dockerClient.go:8
FunctionNewJobServer
(conf *JobServerConfig)
pkg/gpu/jobserver/jobserver.go:26
FunctionNewScheduler
创建一个调度器
pkg/scheduler/app/scheduler.go:47
FunctionNewServer
()
pkg/serveless/server/server.go:33
FunctionParseJsonMessageFromStr
将Message转换为Json格式的Message（从string转换）
pkg/message/message.go:35
FunctionPostRequestByTarget
Post请求
util/netRequest/postRequest.go:11
FunctionPostString
(uri string, str string)
util/netRequest/postRequest.go:33
MethodPrefixGetWithExcude
这个函数用来排除一些前缀的key 可以把要排除的目录放到excude里面
pkg/etcd/etcd.go:189
MethodPrefixWatch
(key string)
pkg/etcd/etcd.go:143
FunctionProductionKubeletConfig
()
pkg/kubelet/kubeletconfig/kubletConfig.go:37
FunctionPublishUpdateEndpoints
(endpointUpdate *entity.EndpointUpdate)
pkg/message/msgPublish.go:84
FunctionPullImageFromRegistry
从镜像管理中心拉取镜像
pkg/serveless/dockerregistry/registry.go:81
MethodPut
值得注意的是，多次Put一个相同的key，会覆盖之前的值！
pkg/etcd/etcd.go:92
MethodPut
增删改查的接口操作
util/rediscache/redisClient.go:44
FunctionPutRequestByTarget
Put请求
util/netRequest/putRequest.go:10
MethodReadFile
(path string)
pkg/gpu/sshclient/sshclient.go:71
MethodRecreatePodContainer
(pod *apiObject.PodStore)
pkg/kubelet/worker/workerManager.go:20
MethodRecreatePodContainer
重建pod的容器
pkg/kubelet/worker/workerManager.go:248
MethodRecreatePodContainer
重启pod中的缺失的容器（Pause容器除外）
pkg/kubelet/runtime/runtime.go:208
MethodRegisterNode
RegisterNode 和 UnRegisterNode 两个函数用来注册和注销Node到APIServer 注册的时候会检查是否已经注册，如果已经注册，则不需要再注册 反注册的时候，会告诉APIServer节点下线。这个函数需要在Kubelet生命周期结束的时候调用 这个函数用于注册Node到A
pkg/kubelet/status/apiserverUtil.go:243
MethodRemoveDirectory
(path string)
pkg/gpu/sshclient/sshclient.go:61
MethodRemoveFile
(path string)
pkg/gpu/sshclient/sshclient.go:88
MethodRemoveImage
删除镜像,没有错误就返回nil
pkg/kubelet/runtime/image/image.go:116
MethodResetCache
()
pkg/kubelet/status/status.go:109
MethodRestartPod
RestartPod 重启pod
pkg/kubelet/worker/workerManager.go:192
MethodRestartPod
RestartPod 重启pod
pkg/kubelet/runtime/runtime.go:146
MethodRestoreIPTables
RestoreIPTables从一个文件中恢复iptables规则
pkg/kubeproxy/app/iptablesManager.go:281
MethodRoutine
()
pkg/controller/allcontollers/hpacontroller.go:172
MethodRun
(stopCh <-chan struct{})
pkg/controller/ctrlmanager/ctrlmanager.go:49
MethodRun
()
pkg/controller/allcontollers/hpacontroller.go:26
MethodRun
()
pkg/controller/allcontollers/hpacontroller.go:256
MethodRun
()
pkg/controller/allcontollers/dnscontroller.go:27
MethodRun
()
pkg/controller/allcontollers/dnscontroller.go:257
MethodRun
()
pkg/controller/allcontollers/jobcontroller.go:23
MethodRun
()
pkg/controller/allcontollers/jobcontroller.go:143
MethodRun
()
pkg/controller/allcontollers/replicacontroller.go:18
MethodRun
()
pkg/controller/allcontollers/replicacontroller.go:234
MethodRun
()
pkg/kubeproxy/app/dnsManager.go:18
← previousnext →501–600 of 814, ranked by callers