MCPcopy Create free account

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

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

⨍ Functions 1,310◇ Types & classes 341
↓ 1 callersFunctionConverPodCreate2Frame
(sloTraces []*storagemodel.SloTraceData)
internal/grafanadi/service/poddelivery.go:11
↓ 1 callersFunctionConverSpan2Frame
(spans []*storagemodel.Span)
internal/grafanadi/service/span.go:11
↓ 1 callersFunctionConvertBizInfo2Frame
(podInfos []*storagemodel.PodInfo)
internal/grafanadi/service/bizinfo.go:8
↓ 1 callersFunctionConvertClusterDistribute2Frame
(result map[string]int)
internal/grafanadi/service/debugslo.go:9
↓ 1 callersFunctionConvertLifePhase2State
(lifephases []*storagemodel.LifePhase, slolist []*storagemodel.SloTraceData)
internal/grafanadi/service/containerlifecycle.go:23
↓ 1 callersFunctionConvertMeta2Frame
(eavesdroppingMeta []*lunettes_model.LunettesMeta)
internal/grafanadi/service/mata.go:11
↓ 1 callersFunctionConvertNameSpaceDistribute2Frame
(result map[string]int)
internal/grafanadi/service/debugslo.go:21
↓ 1 callersFunctionConvertNil
(value string)
pkg/utils/expiringmap.go:8
↓ 1 callersFunctionConvertNodeDistribute2Frame
(result map[string]int)
internal/grafanadi/service/debugslo.go:33
↓ 1 callersFunctionConvertNodeYaml2Frame
(nodeYamls []*storagemodel.NodeYaml)
internal/grafanadi/service/bizinfo.go:40
↓ 1 callersFunctionConvertPodDelete2Frame
(sloTraces []*storagemodel.SloTraceData)
internal/grafanadi/service/poddelivery.go:36
↓ 1 callersFunctionConvertPodInfo2Frame
(podInfo storagemodel.PodInfo, podYamls storagemodel.PodYaml)
internal/grafanadi/service/podinfo.go:8
↓ 1 callersFunctionConvertPodList2Frame
(result []map[string]string)
internal/grafanadi/service/debugslo.go:57
↓ 1 callersFunctionConvertPodPhase2Frame
(podPhases []*storagemodel.LifePhase)
internal/grafanadi/service/podphase.go:40
↓ 1 callersFunctionConvertPodStatus2Frame
(podInfo storagemodel.PodInfo, podYaml storagemodel.PodYaml)
internal/grafanadi/service/podstatus.go:10
↓ 1 callersFunctionConvertPodUpgrade2Frame
(sloLists []*storagemodel.SloTraceData)
internal/grafanadi/service/poddelivery.go:53
↓ 1 callersFunctionConvertPodYaml2Frame
(podYamls []*storagemodel.PodYaml)
internal/grafanadi/service/bizinfo.go:20
↓ 1 callersFunctionConvertPodYamlGraphEdges2Frame
(edges []model.PodYamlGraphEdges)
internal/grafanadi/service/nodegraph.go:169
↓ 1 callersFunctionConvertPodYamlGraphNodes2Frame
(nodes []model.PodYamlGraphNodes)
internal/grafanadi/service/nodegraph.go:127
↓ 1 callersFunctionConvertPodphase2Frame
(lifePhase []*storagemodel.LifePhase)
internal/grafanadi/service/bizinfo.go:56
↓ 1 callersFunctionConvertPodyamls2Table
(podyamls []*storagemodel.PodYaml)
internal/grafanadi/service/querypodlist.go:11
↓ 1 callersFunctionConvertSloDataTrace2Graph
(sdts []model.SloTraceData)
internal/grafanadi/service/esgrafana.go:32
↓ 1 callersFunctionConvertSloDistribute2Frame
(result map[string]int)
internal/grafanadi/service/debugslo.go:45
↓ 1 callersMethodDecideFlow
(desire float64)
pkg/utils/flow_control.go:60
↓ 1 callersMethodDecode
Decode decodes with json.Unmarshal from the Go standard library.
pkg/utils/decoder.go:10
↓ 1 callersFunctionDeduplicateAndTopK
(slice []*storagemodel.PodYaml, topK int)
internal/grafanadi/service/querypodlist.go:53
↓ 1 callersFunctionDefineSpanStatistic
redefine SpansConsumingStatistic if extra-properties chanes
pkg/metrics/spans.go:66
↓ 1 callersMethodDelete
(key string)
pkg/utils/expiringmap.go:59
↓ 1 callersFunctionDeleteAllPodDeleteMilestone
删除所有 podDeleteMileStone
pkg/xsearch/xsearch_pod_delete_milestone.go:161
↓ 1 callersFunctionDeliveryTimeCalcNew
(podSpans SpanSlicePtr, currentTime time.Time, uid types.UID)
pkg/slo/pod_create_slo_span.go:146
↓ 1 callersMethodDoClear
()
pkg/xsearch/types.go:20
↓ 1 callersMethodEmptry
()
pkg/spans/span.go:44
↓ 1 callersMethodEmpty
()
pkg/trace/span.go:52
↓ 1 callersFunctionEnsurePipeline
(client *elastic.Client, index, mapping string)
pkg/xsearch/xsearch.go:45
↓ 1 callersMethodErrorChan
()
pkg/metas/watch.go:90
↓ 1 callersMethodEsTableName
()
pkg/utils/utils.go:502
↓ 1 callersFunctionExtractQuotaResource
从msg中提取quota不足的资源
pkg/reason/utils/utils.go:272
↓ 1 callersMethodFinishProcess
()
pkg/reason/modules/module.go:105
↓ 1 callersFunctionFirstUpper
首字母大写
pkg/reason/utils/utils.go:283
↓ 1 callersFunctionGeneratePodCreateDAG
用于构建pod创建链路DAG
pkg/reason/analyzers/pod_create_analyzer.go:18
↓ 1 callersFunctionGeneratePodFromEvent
GeneratePodFromEvent generate pod info from event. first pars from responseObject and then requestObject and last from event.objectRef
pkg/metas/utils.go:32
↓ 1 callersFunctionGeneratePodUpgradeDAG
GeneratePodUpgradeDAG 用于构建pod升级链路DAG
pkg/reason/analyzers/pod_upgrade_analyzer.go:23
↓ 1 callersFunctionGetAllPodDeleteMilestoneByScroll
获取所有 PodDeleteMilestone
pkg/xsearch/xsearch_pod_delete_milestone.go:105
↓ 1 callersMethodGetConfigByRef
(ref *audit.ObjectReference)
pkg/spans/config.go:480
↓ 1 callersMethodGetConfigByRef
(ref *audit.ObjectReference)
pkg/trace/config.go:554
↓ 1 callersMethodGetContainerEventsData
(key, value string)
internal/grafanadi/handler/containerevents.go:24
↓ 1 callersMethodGetContainerLifecycleData
(key, value string)
internal/grafanadi/handler/containerlifecycle.go:25
↓ 1 callersMethodGetContainerStatusData
(key, value string)
internal/grafanadi/handler/containerstatus.go:25
↓ 1 callersMethodGetDuration
(event *shares.AuditEvent)
pkg/spans/config.go:176
↓ 1 callersMethodGetDuration
(event *shares.AuditEvent)
pkg/trace/config.go:170
↓ 1 callersMethodGetExtraPropertyNames
()
pkg/trace/config.go:533
↓ 1 callersFunctionGetJsonFromRuntimeUnknown
(un *runtime.Unknown)
pkg/metas/utils.go:325
↓ 1 callersMethodGetOwnerPodMap
(debugfrom, key, value string)
internal/grafanadi/handler/owner_podmap_handler.go:26
↓ 1 callersFunctionGetPersistentVolumeClaimNamesFromPod
获取pod中所有pvc的资源名列表
pkg/utils/pod_utils.go:8
↓ 1 callersMethodGetPodYaml
(podYamls []*model.PodYaml, key string, value string)
internal/grafanadi/utils/utils.go:46
↓ 1 callersFunctionGetPulledImageFromEventMessage
GetPulledImageFromEventMessage get image name from pulled event
pkg/utils/utils.go:159
↓ 1 callersFunctionGetPullingImageFromEventMessage
GetPullingImageFromEventMessage get image name from pulling event
pkg/utils/utils.go:149
↓ 1 callersFunctionGetXSearchClient
()
pkg/xsearch/xsearch_client.go:5
↓ 1 callersMethodGetYamls
(params *YamlParams)
internal/grafanadi/handler/yaml_handler.go:29
↓ 1 callersMethodHandle
(err error)
pkg/spans/jaeger.go:99
↓ 1 callersMethodHas
Looks up an item under specified key
pkg/utils/concurrent_map.go:106
↓ 1 callersFunctionInAnnotations
(annotations map[string]string, k string)
pkg/utils/pod_utils.go:34
↓ 1 callersFunctionInFinalizers
(finalizers []string, k string)
pkg/utils/pod_utils.go:20
↓ 1 callersFunctionIncResponseStatusCode
(code int)
pkg/api_metrics/metrics.go:37
↓ 1 callersFunctionInitAuditProcessADG
()
pkg/shares/event_data.go:254
↓ 1 callersFunctionInitKube
(kubeConfig string)
pkg/kube/init.go:13
↓ 1 callersFunctionInitKubeSpanWatcher
actually cluster is not necessary
pkg/spans/watcher.go:21
↓ 1 callersFunctionInitKubeTraceWatcher
(cluster string, otlpAddr string)
pkg/trace/watcher.go:16
↓ 1 callersFunctionInitSloPodInfo
查询 SLO Pod
pkg/xsearch/xsearch_slo_pod_info.go:331
↓ 1 callersFunctionInitZsearch
(zsearchEndPoint, username, password string, extraInfo interface{})
pkg/xsearch/xsearch.go:659
↓ 1 callersMethodIsFinishToTrack
(ev *shares.AuditEvent)
pkg/spans/config.go:410
↓ 1 callersMethodIsFinishToTrack
(ev *shares.AuditEvent)
pkg/trace/config.go:489
↓ 1 callersFunctionIsJobPodFailed
(pod *corev1.Pod)
pkg/metas/utils.go:185
↓ 1 callersFunctionIsJobPodFinished
(pod *corev1.Pod)
pkg/metas/utils.go:173
↓ 1 callersFunctionIsJobPodRunning
(pod *corev1.Pod)
pkg/metas/utils.go:181
↓ 1 callersFunctionIsJobPodSucceeded
(pod *corev1.Pod)
pkg/metas/utils.go:177
↓ 1 callersMethodIsParentsReady
()
pkg/reason/modules/module.go:96
↓ 1 callersMethodIsParentsReady
()
pkg/shares/event_data.go:245
↓ 1 callersFunctionIsPodReady
(pod *corev1.Pod)
pkg/metas/utils.go:154
↓ 1 callersMethodIsStartToTrack
(ev *shares.AuditEvent)
pkg/spans/config.go:401
↓ 1 callersMethodIsStartToTrack
(ev *shares.AuditEvent)
pkg/trace/config.go:481
↓ 1 callersMethodIterCbConcurrent
Callback based iterator, cheapest way to read all elements in a map.
pkg/utils/concurrent_map.go:271
↓ 1 callersFunctionNewAPIServer
NewAPIServer create new API server
internal/grafanadi/server/server.go:33
↓ 1 callersFunctionNewAggregator
(options *AggregatorOptions)
pkg/aggregator/aggregator.go:79
↓ 1 callersFunctionNewAuditEvent
(event *k8s_audit.Event)
pkg/shares/event_data.go:39
↓ 1 callersFunctionNewAuditProcessor
NewAuditProcessor create new audit log processor
pkg/replayer/audit_processor.go:29
↓ 1 callersFunctionNewBaseProcessor
()
pkg/shares/processor.go:27
↓ 1 callersFunctionNewExpiringMap
(timeout time.Duration)
pkg/utils/expiringmap.go:28
↓ 1 callersFunctionNewFlowControl
(wms int, fbt int, fbf float64, srf float64, mfs float64)
pkg/utils/flow_control.go:17
↓ 1 callersFunctionNewHitEvent
()
pkg/shares/event_data.go:157
↓ 1 callersFunctionNewHitEventSlice
(capacity int)
pkg/shares/event_data.go:182
↓ 1 callersFunctionNewMilestoneExtractor
()
pkg/shares/processor.go:58
↓ 1 callersFunctionNewSpanMeta
(config *ResourceSpanConfig, cluster string, createTime time.Time, event *shares.AuditEvent)
pkg/spans/span.go:83
↓ 1 callersFunctionNewSpanMeta
(config *ResourceSpanConfig, cluster string, event *shares.AuditEvent)
pkg/trace/span.go:217
↓ 1 callersFunctionNewSpanProcessor
(cluster string)
pkg/spans/consumer.go:219
↓ 1 callersFunctionNewSpanProcessor
(cluster string)
pkg/trace/consumer.go:204
↓ 1 callersFunctionNewWatcher
(name string, w http.ResponseWriter, r *http.Request)
pkg/metas/watch.go:50
↓ 1 callersFunctionNewXSearchWriter
()
pkg/spans/writer.go:28
↓ 1 callersMethodOnMessage
receive message from publisher
pkg/pubsub/pubsub.go:17
↓ 1 callersFunctionParse
(gates string)
pkg/featuregates/feature_gates.go:18
← previousnext →301–400 of 1,310, ranked by callers