MCPcopy Create free account

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

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

↓ 1 callersFunctionParseJsonAndProtoTag
获取字段的tag,支持json和protobuf两种tag设置
pkg/spans/utils.go:199
↓ 1 callersFunctionParseJsonAndProtoTag
获取字段的tag,支持json和protobuf两种tag设置
pkg/trace/utils.go:193
↓ 1 callersMethodParseRequest
()
pkg/api/handler.go:11
↓ 1 callersMethodProcess
()
pkg/shares/event_data.go:76
↓ 1 callersMethodProcess
()
pkg/api/handler.go:13
↓ 1 callersMethodProcessEvent
this function should be thread safe
pkg/spans/consumer.go:69
↓ 1 callersMethodProcessEvent
this function should be thread safe
pkg/trace/consumer.go:67
↓ 1 callersFunctionProvideSqlStorate
4. 提供一个 ProvideSqlStorate 方法, 传入一个 MysqlOptions, 返回一个 StorageInterface 和 error
pkg/dal/storage-client/data_access/mysql.go:28
↓ 1 callersMethodQueryAuditWithAuditId
(data interface{}, auditid string)
pkg/dal/storage-client/data_access/ealsticsearch.go:1114
↓ 1 callersMethodQueryBizInfoWithPodUid
(key, value string)
internal/grafanadi/handler/biz_info_handler.go:49
↓ 1 callersMethodQueryCreateSloWithResult
(data interface{}, requestParams *model.SloOptions)
pkg/dal/storage-client/data_access/mysql.go:461
↓ 1 callersMethodQueryDebuggingWithType
(debugparams model.SloOptions)
internal/grafanadi/handler/podlist.go:53
↓ 1 callersMethodQueryDebuggingWithType
(debugparams model.SloOptions)
internal/grafanadi/handler/debugslo_handler.go:52
↓ 1 callersMethodQueryEventNodeWithPodUid
(data interface{}, PodUid string)
pkg/dal/storage-client/data_access/ealsticsearch.go:1193
↓ 1 callersMethodQueryEventPodsWithPodUid
(data interface{}, PodUid string)
pkg/dal/storage-client/data_access/ealsticsearch.go:1152
↓ 1 callersMethodQueryEventWithTimeRange
(data interface{}, from, to time.Time)
pkg/dal/storage-client/data_access/ealsticsearch.go:1234
↓ 1 callersMethodQueryLunettesLatency
(data interface{}, opts ...model.OptionFunc)
pkg/dal/storage-client/data_access/storage_interface.go:76
↓ 1 callersMethodQueryLunettesLatency
()
internal/grafanadi/handler/latency_handler.go:36
↓ 1 callersMethodQueryNodeYamlsWithNodeName
(data interface{}, name string)
pkg/dal/storage-client/data_access/storage_interface.go:31
↓ 1 callersMethodQueryPodDeliveryUpgradeWithPodUid
(key, value string)
internal/grafanadi/handler/pod_delivery_upgrade.go:49
↓ 1 callersMethodQueryPodDeliveryWithPodUid
(key, value string)
internal/grafanadi/handler/pod_delivery_handler.go:52
↓ 1 callersMethodQueryPodDeliveryWithPodUid
(key, value string)
internal/grafanadi/handler/node_graph_handler.go:49
↓ 1 callersMethodQueryPodInfoWithPodUid
(key, value string)
internal/grafanadi/handler/pod_info_handler.go:49
↓ 1 callersMethodQueryPodLifePhaseByID
(data interface{}, uid string)
pkg/dal/storage-client/data_access/storage_interface.go:52
↓ 1 callersMethodQueryPodListWithParams
(params *QueryPodListParams)
internal/grafanadi/handler/querypodlist.go:59
↓ 1 callersMethodQueryPodPhaseWithPodUid
(key, value string)
internal/grafanadi/handler/podphase_handler.go:49
↓ 1 callersMethodQueryPodStatusWithPodUid
(key, value string)
internal/grafanadi/handler/pod_status_handler.go:49
↓ 1 callersMethodQueryPodYamlsWithNodeIP
(data interface{}, nodeIp string)
pkg/dal/storage-client/data_access/mysql.go:336
↓ 1 callersFunctionQuerySloPodInfo
(podUID string)
pkg/api/zsearch.go:681
↓ 1 callersMethodQuerySloTraceDataWithOwnerId
(data interface{}, ownerid string, opts ...model.OptionFunc)
pkg/dal/storage-client/data_access/storage_interface.go:46
↓ 1 callersMethodQuerySpanWithPodUid
(data interface{}, uid string)
pkg/dal/storage-client/data_access/storage_interface.go:56
↓ 1 callersMethodQueryTraceWithPodUid
(key, value string)
internal/grafanadi/handler/trace_handler.go:49
↓ 1 callersFunctionRandString
RandString generate n-length random string
pkg/utils/utils.go:34
↓ 1 callersFunctionRecordAPIDuration
(path string, code int, start time.Time)
pkg/api_metrics/metrics.go:41
↓ 1 callersMethodRecordPod
(ms *xsearch.PodDeleteMileStone, tm time.Time)
pkg/slo/pod_delete_slo.go:64
↓ 1 callersMethodRefreshConfig
()
pkg/spans/consumer.go:176
↓ 1 callersMethodRefreshConfig
()
pkg/trace/consumer.go:160
↓ 1 callersFunctionRegisterPublisher
(name string)
pkg/metas/watch.go:22
↓ 1 callersFunctionReorgSpans
(podSpans SpanSlice)
pkg/slo/pod_create_slo_span.go:23
↓ 1 callersFunctionReorgSpansNew
(podSpans SpanSlicePtr, currentTime time.Time)
pkg/slo/pod_create_slo_span.go:77
↓ 1 callersMethodRoot
()
internal/grafanadi/handler/root.go:32
↓ 1 callersMethodRun
(stopCh <-chan struct{})
pkg/aggregator/aggregator.go:133
↓ 1 callersFunctionSaveDeleteSloMilestoneMapToZsearch
(podDeleteMileStoneMap *utils.SafeMap)
pkg/xsearch/xsearch_pod_delete_milestone.go:51
↓ 1 callersFunctionSaveNodeYaml
(cluster string, node *corev1.Node, t time.Time, auditID string)
pkg/xsearch/xsearch.go:1036
↓ 1 callersFunctionSavePodYaml
(cluster string, pod *corev1.Pod, t time.Time, auditID string, isBeginDelete, isDeleted bool)
pkg/xsearch/xsearch.go:838
↓ 1 callersFunctionSaveSloData
(cluster string, namespace string, podName string, podUID string, sloType string, sloData []byte)
pkg/xsearch/xsearch.go:910
↓ 1 callersMethodSeenPod
true if pod has processed, false if pod is the first time seen
pkg/slo/pod_delete_slo.go:55
↓ 1 callersMethodSortByTimeStamp
(ascending bool)
pkg/shares/event_data.go:205
↓ 1 callersMethodSpanConfig
()
pkg/spans/span.go:139
↓ 1 callersMethodStartAnalysis
()
pkg/reason/analyzers/analyzer.go:91
↓ 1 callersMethodStop
Stop stops all consumers, as well as the length reporter if started, and releases the items channel. It blocks until all consumers have stopped.
pkg/queue/queue.go:122
↓ 1 callersMethodTableName
()
pkg/utils/utils.go:498
↓ 1 callersMethodTackSpan
(event *shares.AuditEvent)
pkg/trace/span.go:248
↓ 1 callersFunctionTimeSinceInMinutes
TimeSinceInMinutes return minutes since start
pkg/utils/utils.go:51
↓ 1 callersMethodTkp
(params *TkpParams)
internal/grafanadi/handler/tkp_handler.go:75
↓ 1 callersMethodTrackSpan
(event *shares.AuditEvent)
pkg/spans/span.go:101
↓ 1 callersMethodTypeName
()
pkg/utils/utils.go:506
↓ 1 callersMethodUnmarshalToEvent
(hit *json.RawMessage)
pkg/shares/event_data.go:164
↓ 1 callersFunctionUnsafeGuessResourceToKind
(resource string)
pkg/metas/utils.go:416
↓ 1 callersMethodUpdate
(event *shares.AuditEvent, span *Span)
pkg/spans/config.go:246
↓ 1 callersMethodUpdate
(event *shares.AuditEvent)
pkg/trace/span.go:56
↓ 1 callersMethodUpsert
Insert or Update - updates existing element or inserts a new one using UpsertCb
pkg/utils/concurrent_map.go:59
↓ 1 callersMethodVTkpDetail
(params *VTkpDetailParams)
internal/grafanadi/handler/vtkp_detail_handler.go:82
↓ 1 callersMethodVTkpStatus
(params *VTkpStatusParams)
internal/grafanadi/handler/vtkp_status_handler.go:62
↓ 1 callersMethodValidRequest
()
pkg/api/handler.go:12
↓ 1 callersFunctionWithFrom
(from time.Time)
pkg/dal/storage-client/model/type.go:55
↓ 1 callersFunctionWithTo
(to time.Time)
pkg/dal/storage-client/model/type.go:60
↓ 1 callersFunction_sortConditiosByTime
(conditions []v1.PodCondition, left int, right int)
pkg/slo/pod_create_failreason.go:449
↓ 1 callersFunctionaddLine
()
grafana_plugin/filter_panel/src/components/FilterOptionEditort.tsx:12
↓ 1 callersFunctionaddLine
()
grafana_plugin/filter_panel/src/components/FilterConfigEditort.tsx:11
↓ 1 callersFunctionaddLine
(name: string)
grafana_plugin/custom_log_panel/src/components/SimpleEditor.tsx:28
↓ 1 callersFunctionaddToTraceMap
return true for pod that in podDeleteMileStoneMap, otherwise, return false
pkg/slo/pod_delete_slo.go:402
↓ 1 callersFunctionanalysisApiFailed
分析api_failed原因
pkg/slo/pod_create_failreason.go:515
↓ 1 callersFunctionanalysisContainerKill
(c *v1.Container, auditEvents []*shares.AuditEvent, endTime *time.Time)
pkg/reason/modules/pods/container_kill_module.go:36
↓ 1 callersFunctionanalysisContainerReadiness
(auditEvents []*shares.AuditEvent, endTime *time.Time)
pkg/reason/modules/pods/container_readiness_module.go:73
↓ 1 callersFunctionbackupApiServerPodYaml
back up apiserver pod yaml
cmd/audit_init/main.go:87
↓ 1 callersMethodbuildSpan
(ctx context.Context, span *Span, attrs []attribute.KeyValue, latestTime time.Time)
pkg/spans/writer.go:345
↓ 1 callersFunctioncalculateCustomCost
(customSpans, k8sSpans SpanSlicePtr, uid types.UID)
pkg/slo/pod_create_slo_span.go:191
↓ 1 callersFunctionchangeOptionsOpenState
(index: number, state: boolean)
grafana_plugin/filter_panel/src/components/FilterOptionEditort.tsx:21
↓ 1 callersFunctionchangeValue
()
grafana_plugin/custom_log_panel/src/components/SimpleEditor.tsx:38
↓ 1 callersFunctioncheckPVCCreateTimeout
()
pkg/slo/pvc_create_slo.go:110
↓ 1 callersFunctioncheckTimeout
()
pkg/slo/pod_delete_slo.go:135
↓ 1 callersFunctioncheckUpgradeTimeout
(auditTime *time.Time)
pkg/slo/pod_upgrade_slo.go:133
↓ 1 callersMethodcleanMaps
()
pkg/spans/consumer.go:36
↓ 1 callersMethodcleanMaps
()
pkg/trace/consumer.go:34
↓ 1 callersMethodcleanup
()
pkg/utils/expiringmap.go:77
↓ 1 callersMethodclear
()
pkg/utils/utils.go:265
↓ 1 callersFunctionclearSLOMetric
clear the metric data of request resource info periodically
pkg/metrics/slo.go:225
↓ 1 callersFunctionclearSpanMetric
clear the metric data of request resource info periodically
pkg/metrics/spans.go:113
↓ 1 callersFunctioncollectPodAuditLog
(auditEvent *shares.AuditEvent)
pkg/slo/pod_create_slo.go:902
↓ 1 callersFunctioncollectPodEvents
todo 收集 pod event 事件
pkg/slo/pod_create_slo.go:847
↓ 1 callersFunctioncollectPodUpgradeAuditLog
(auditEvent *shares.AuditEvent)
pkg/slo/pod_upgrade_slo.go:451
↓ 1 callersMethodcompact
remove entries elder than 30 min (auditMaxLatency) periodically
pkg/slo/pod_delete_slo.go:76
↓ 1 callersMethodconStruct
(cluster string, pod *corev1.Pod, t time.Time, auditID string, isBeginDelete, isDeleted bool)
pkg/xsearch/xsearch.go:804
↓ 1 callersFunctionconcatDocIdForMeta
(p *SpanMeta)
pkg/spans/writer.go:50
↓ 1 callersFunctionconcatDocIdForSpan
(pm *SpanMeta, span *Span)
pkg/spans/writer.go:57
↓ 1 callersFunctionconfigApiServerAudit
add audit config
cmd/audit_init/main.go:116
↓ 1 callersFunctionconsumePodOpStruct
(auditEvent *shares.AuditEvent)
pkg/podyaml/watcher.go:88
↓ 1 callersFunctionconvertAttributes
*func (x *XSearchWriter) buildSpanSnapshot(cluster string, objectRef *audit.ObjectReference, span *Span, attrs []attribute.KeyValue, actionType string
pkg/spans/writer.go:257
↓ 1 callersFunctionconvertTkpForGData
(v *VTkpDetailResp)
internal/grafanadi/handler/vtkp_detail_handler.go:141
← previousnext →401–500 of 1,310, ranked by callers