MCPcopy Create free account

hub / github.com/alipay/container-observability-service / functions

Functions1,310 in github.com/alipay/container-observability-service

FunctionGetCreatedAndStartedContainerName
从Created reason 获取container name msg:"Created container task, elapsedTime 65.729783ms" msg: "Started container task, elapsedTime 261.205298ms" msg: ""
pkg/reason/utils/utils.go:71
MethodGetExtraPropertyNames
()
pkg/spans/config.go:493
MethodGetExtraPropertyNames
()
pkg/trace/config.go:567
FunctionGetImageName
获取镜像名称
pkg/reason/utils/utils.go:25
FunctionGetJobPodFinishedTime
GetJobPodFinishedTime use the max container terminated time as job finish time
pkg/metas/utils.go:376
FunctionGetKilledContainerName
从Killed message 获取container name
pkg/reason/utils/utils.go:104
FunctionGetOwnerType
(pod *corev1.Pod)
pkg/metas/utils.go:397
FunctionGetPodPatch
(oldPod, newPod *corev1.Pod)
pkg/metas/utils.go:130
FunctionGetPodReadyTime
(pod *corev1.Pod)
pkg/metas/utils.go:366
FunctionGetPostStartHookElapsed
获取poststarthook耗时时间
pkg/reason/utils/utils.go:177
FunctionGetPostStartHookTimeout
获取poststarthook超时时间
pkg/reason/utils/utils.go:165
MethodGetProcessed
get total processed item
pkg/slo/utils.go:160
MethodGetProcessed
()
pkg/slo/utils.go:342
MethodGetResponseOrRequestObj
()
pkg/shares/event_data.go:48
FunctionGetSloPodInfoIndexByDocID
查询一个 PodInfo 所属于的 Index 由于 slo_pod_info 是天级别的索引,需要先找到这个 docID 对应的索引名称,然后再写入
pkg/xsearch/xsearch_slo_pod_info.go:257
FunctionGetTkpReqUrl
(key string)
pkg/tkp_provider/config.go:39
MethodHandle
(err error)
pkg/trace/jaeger.go:113
FunctionHandleCrash
()
pkg/utils/utils.go:379
FunctionImageReason
(auditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/pods/image_module.go:22
FunctionIncreaseFailedTraceCount
IncreaseFailedTraceCount increase counter for failed traces
pkg/metrics/metrics.go:299
FunctionIncreaseSucceedTraceCount
IncreaseSucceedTraceCount increase counter for succeed traces
pkg/metrics/metrics.go:305
FunctionInitApi
(endPoint string, username string, password string)
pkg/api/init.go:9
FunctionInitTkpReqConfig
(cfgFile string)
pkg/tkp_provider/config.go:13
MethodInitial
(object runtime.Object, uid string, properties utils.ConcurrentMap)
pkg/spans/config.go:417
MethodInitial
(object runtime.Object, globalSpans utils.ConcurrentMap, properties utils.ConcurrentMap)
pkg/trace/config.go:496
FunctionIsDeleteImmediately
(pod *corev1.Pod)
pkg/metas/utils.go:349
MethodIsEmpty
IsEmpty checks if map is empty.
pkg/utils/concurrent_map.go:157
FunctionIsPodFinishedNormally
IsPodFinishedNormally judge if a pod is in a `finished` state. For a job pod, the pod should be Failed/Succeed/Running For a non-job pod, the pod shou
pkg/metas/utils.go:166
FunctionIsPodReady
判断pod是否ready
pkg/reason/utils/utils.go:199
FunctionIsPodScheduled
(pod *corev1.Pod)
pkg/metas/utils.go:201
FunctionIsPodSchedulingFailed
(pod *corev1.Pod)
pkg/metas/utils.go:189
FunctionIsPodSucceed
判断pod是否ready
pkg/reason/utils/utils.go:217
FunctionIsSidecarContainer
(container *corev1.Container)
pkg/metas/utils.go:388
MethodIter
Iter returns an iterator which could be used in a for range loop. Deprecated: using IterBuffered() will get a better performence
pkg/utils/concurrent_map.go:170
MethodIterCb
Callback based iterator, cheapest way to read all elements in a map.
pkg/utils/concurrent_map.go:258
MethodKeys
Keys returns all keys as []string
pkg/utils/concurrent_map.go:289
FunctionKubeletDelayReason
(auditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/pods/kubeletdelay_module.go:20
MethodLen
()
pkg/slo/pod_create_slo_span.go:19
MethodLess
(i, j int)
pkg/slo/pod_create_slo_span.go:14
MethodLess
(i, j int)
pkg/slo/pod_create_slo_span.go:20
FunctionLoader
(L *lua.LState)
pkg/spans/lua_helper.go:13
FunctionLunettesLatencyFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/latency_handler.go:60
MethodMSet
(data map[string]interface{})
pkg/utils/concurrent_map.go:34
FunctionMarshal
Marshal Marshal object to string of the error message if failed
pkg/utils/utils.go:79
MethodMarshalJSON
Reviles ConcurrentMap "private" variables to json marshal.
pkg/utils/concurrent_map.go:320
FunctionMergeMaps
(mapTo, mapFrom map[string]string)
pkg/utils/utils.go:180
FunctionMicroTime2Time
(t metav1.MicroTime)
pkg/metas/utils.go:345
MethodMockElasticSearchClient
()
pkg/mocks/clients_mock.go:60
MethodMockHttpClient
()
pkg/mocks/clients_mock.go:70
MethodMockHttpClient
()
pkg/dal/storage-client/mocks/elasticsearch_mock.go:70
MethodName
()
pkg/reason/modules/module.go:48
FunctionNetworkReason
(auditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/pods/network_module.go:22
FunctionNewAPIServer
NewAPIServer create new API server
pkg/api/server.go:134
FunctionNewESReader
()
pkg/slo/utils.go:163
MethodNewIDs
NewIDs returns a non-zero trace ID and a non-zero span ID from a randomly-chosen sequence.
pkg/trace/jaeger.go:173
FunctionNewMock
()
pkg/mocks/clients_mock.go:75
MethodNewSpanID
NewSpanID returns a non-zero span ID from a randomly-chosen sequence.
pkg/trace/jaeger.go:156
FunctionNode
* The factory for creating nodes of defined type. * * ~~~ Node ~~~ is a structure element of an onject or an array * with own label (a
statics/jsonTree.js:173
FunctionNodeArray
(label, val, isLast)
statics/jsonTree.js:670
FunctionNodeBoolean
(label, val, isLast)
statics/jsonTree.js:340
FunctionNodeGraphParamsFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/node_graph_handler.go:92
FunctionNodeNull
(label, val, isLast)
statics/jsonTree.js:399
FunctionNodeNumber
(label, val, isLast)
statics/jsonTree.js:360
FunctionNodeObject
(label, val, isLast)
statics/jsonTree.js:649
FunctionNodeString
(label, val, isLast)
statics/jsonTree.js:380
FunctionObserveTraceDuration
ObserveTraceDuration observe for trace durations
pkg/metrics/metrics.go:311
MethodOnMessage
(v interface{})
pkg/metas/watch.go:73
MethodOnMessage
(v interface{})
pkg/pubsub/pubsub_test.go:19
FunctionOwnerPodMapFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/owner_podmap_handler.go:149
MethodParseRequest
()
pkg/api/debugpodyaml_handler.go:30
MethodParseRequest
()
pkg/api/handler.go:38
MethodParseRequest
()
pkg/api/raw_data_handler.go:26
MethodParseRequest
()
pkg/api/debugnodeyaml_handler.go:28
MethodParseRequest
()
pkg/api/debugpod_handler.go:55
MethodParseRequest
()
pkg/api/slodebug_handler.go:36
MethodParseRequest
()
internal/grafanadi/handler/vtkp_status_handler.go:32
MethodParseRequest
()
internal/grafanadi/handler/podphase_handler.go:32
MethodParseRequest
()
internal/grafanadi/handler/pod_delivery_handler.go:34
MethodParseRequest
()
internal/grafanadi/handler/containerevents.go:61
MethodParseRequest
()
internal/grafanadi/handler/querypodlist.go:33
MethodParseRequest
()
internal/grafanadi/handler/biz_info_handler.go:32
MethodParseRequest
()
internal/grafanadi/handler/vtkp_detail_handler.go:32
MethodParseRequest
()
internal/grafanadi/handler/containerstatus.go:66
MethodParseRequest
()
internal/grafanadi/handler/podlist.go:29
MethodParseRequest
()
internal/grafanadi/handler/containerlifecycle.go:65
MethodParseRequest
()
internal/grafanadi/handler/rawdata_handler.go:56
MethodParseRequest
()
internal/grafanadi/handler/tkp_handler.go:40
MethodParseRequest
()
internal/grafanadi/handler/node_graph_handler.go:31
MethodParseRequest
()
internal/grafanadi/handler/owner_podmap_handler.go:126
MethodParseRequest
()
internal/grafanadi/handler/root.go:24
MethodParseRequest
()
internal/grafanadi/handler/pod_delivery_upgrade.go:32
MethodParseRequest
()
internal/grafanadi/handler/yaml_handler.go:66
MethodParseRequest
()
internal/grafanadi/handler/latency_handler.go:27
MethodParseRequest
()
internal/grafanadi/handler/trace_handler.go:31
MethodParseRequest
()
internal/grafanadi/handler/pod_status_handler.go:32
MethodParseRequest
()
internal/grafanadi/handler/pod_info_handler.go:32
MethodParseRequest
()
internal/grafanadi/handler/debugslo_handler.go:32
FunctionParseTags
trace param parse
pkg/utils/utils.go:475
FunctionPodConditionExists
PodConditionExists() whether the condition is exists.
pkg/reason/utils/utils.go:15
FunctionPodDeliveryFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/pod_delivery_handler.go:103
← previousnext →701–800 of 1,310, ranked by callers