MCPcopy Index your code

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

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

⨍ Functions 1,310◇ Types & classes 341
↓ 128 callersMethodGet
(key string)
pkg/utils/cache.go:38
↓ 85 callersFunctionIgnorePanic
(desc string)
pkg/utils/utils.go:215
↓ 82 callersMethodDo
(AuditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/module.go:10
↓ 75 callersMethodSet
(key string, data interface{})
pkg/utils/safe_map.go:15
↓ 75 callersMethodSize
()
pkg/utils/safe_map.go:33
↓ 61 callersMethodRun
starts to read audit events from es
pkg/slo/utils.go:156
↓ 57 callersFunctionTimeSinceInMilliSeconds
(start time.Time)
pkg/utils/utils.go:42
↓ 31 callersFunctionGetMetaName
获取数据的 SqlTableName EsTableName TypeName
pkg/utils/utils.go:510
↓ 28 callersMethodMockElasticSearchClient
()
pkg/dal/storage-client/mocks/elasticsearch_mock.go:60
↓ 28 callersFunctionNewMock
()
pkg/dal/storage-client/mocks/elasticsearch_mock.go:75
↓ 28 callersFunctionhandlerWrapper
(h handler.HandlerFunc, storage data_access.StorageInterface)
internal/grafanadi/server/server.go:108
↓ 25 callersMethodWait
()
pkg/shares/event_data.go:189
↓ 25 callersFunctionsetSP
(values url.Values, name string, f *string)
pkg/api/types.go:86
↓ 21 callersMethodClose
Close closes PubSub. To inspect unbsubscribing for another subscruber, you must create message structure to notify them. After publish notifycations,
pkg/pubsub/pubsub.go:80
↓ 21 callersFunctionObserveQueryMethodDuration
(method string, begin time.Time)
pkg/metrics/metrics.go:316
↓ 21 callersMethodReset
()
pkg/spans/span.go:48
↓ 20 callersMethodGetModuleByName
(moduleName string)
pkg/reason/modules/module_factory.go:15
↓ 20 callersFunctionconvertNil
(value string)
internal/grafanadi/service/poddelivery.go:29
↓ 18 callersMethodSetChildren
([]DeliveryModule)
pkg/reason/modules/module.go:14
↓ 18 callersMethodSetParents
([]DeliveryModule)
pkg/reason/modules/module.go:13
↓ 17 callersMethodProduce
Produce is used by the producer to submit new item to the queue. Returns false in case of queue overflow.
pkg/queue/queue.go:86
↓ 17 callersFunctionparseTime
(timeStr string)
pkg/slo/pod_create_failreason_test.go:15
↓ 16 callersFunctionSavePodLifePhase
(clusterName string, namespace string, podUID string, podName string, operationName string, hasErr bool, star
pkg/xsearch/xsearch.go:729
↓ 16 callersMethodWrite
(p *SpanMeta)
pkg/spans/writer.go:22
↓ 15 callersMethodDelete
(key string)
pkg/utils/safe_map.go:26
↓ 15 callersFunctiongenPodKey
(clusterName, podNamespace, podName string)
pkg/slo/utils.go:65
↓ 14 callersMethodGetConfig
()
pkg/spans/span.go:28
↓ 14 callersMethodStartConsumers
StartConsumers starts a given number of goroutines consuming items from the queue and passing them into the consumer callback.
pkg/queue/queue.go:59
↓ 14 callersMethodStop
()
pkg/aggregator/aggregator.go:62
↓ 13 callersFunctionNewBoundedQueue
NewBoundedQueue constructs the new queue of specified capacity, and with an optional callback for dropped items (e.g. useful to emit metrics).
pkg/queue/queue.go:45
↓ 13 callersFunctionNewDAGDeliveryModule
(name string, analysisFunc func(AuditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time) (
pkg/reason/modules/module.go:35
↓ 13 callersFunctionNewSafeMap
()
pkg/utils/safe_map.go:8
↓ 13 callersMethodRegister
(moduleName string, generator func() DeliveryModule)
pkg/reason/modules/module_factory.go:11
↓ 13 callersFunctionTimeDiffInSeconds
TimeDiffInSeconds get time difference in unit second.
pkg/utils/utils.go:63
↓ 12 callersFunctionIsEnabled
(f string)
pkg/featuregates/feature_gates.go:28
↓ 12 callersMethodStartLengthReporting
StartLengthReporting starts a timer-based gorouting that periodically reports current queue length to a given metrics gauge.
pkg/queue/queue.go:141
↓ 12 callersFunctiongetTime
(str string)
internal/grafanadi/handler/debugslo_handler.go:302
↓ 11 callersMethodGetUid
(podYamls []*model.PodYaml, key string, value *string)
internal/grafanadi/utils/utils.go:22
↓ 11 callersFunctionReTry
ReTry try to call a function until success.
pkg/utils/utils.go:128
↓ 11 callersMethodupdateLatencyMetrics
(milestone string, end time.Time)
pkg/slo/pod_create_slo.go:574
↓ 10 callersFunctionTimeDiffInMilliSeconds
(start, end time.Time)
pkg/utils/utils.go:55
↓ 10 callersMethodadd
add node to head
pkg/utils/cache.go:80
↓ 9 callersMethodGetShard
GetShard returns shard under given key
pkg/utils/concurrent_map.go:30
↓ 9 callersMethodPut
(key string, value interface{})
pkg/utils/cache.go:39
↓ 8 callersMethodAddCleanWork
(w func())
pkg/xsearch/types.go:17
↓ 8 callersMethodCount
Count returns the number of elements within the map.
pkg/utils/concurrent_map.go:94
↓ 8 callersFunctionDumps
Dumps dump interface as indented json object
pkg/utils/utils.go:88
↓ 8 callersFunctionEnsureIndex
EnsureIndex to check if an index exists, create it if not exists.
pkg/xsearch/xsearch.go:21
↓ 8 callersFunctionIsJobPod
(pod *corev1.Pod)
pkg/metas/utils.go:408
↓ 8 callersMethodRegister
(name string, p Processor)
pkg/shares/processor.go:49
↓ 8 callersFunctionsetTPLayout
(values url.Values, name string, f *time.Time)
internal/grafanadi/handler/debugslo_handler.go:220
↓ 7 callersMethodDoClearData
()
pkg/utils/utils.go:327
↓ 7 callersFunctionGlobalLunettesConfig
()
pkg/config/config.go:42
↓ 7 callersMethodMatch
(event *shares.AuditEvent, spanName *string)
pkg/trace/config.go:93
↓ 7 callersFunctionNewBufferUtils
(name string, bufferSize int, clearPeriod time.Duration, sequential bool, saveFunc func(map[string]interface{}
pkg/utils/utils.go:291
↓ 7 callersMethodSaveData
(id string, data interface{})
pkg/utils/utils.go:308
↓ 7 callersMethodSetElapsed
(d time.Duration)
pkg/spans/span.go:36
↓ 7 callersMethodTryGetPodFromEvent
()
pkg/shares/event_data.go:58
↓ 7 callersFunctionchangeInputValue
(inputValue: string, index: number, key: string)
grafana_plugin/filter_panel/src/components/FilterConfigEditort.tsx:21
↓ 6 callersFunctionGetObjectFromRuntimeUnknown
(un *runtime.Unknown, gvk *schema.GroupVersionKind)
pkg/metas/utils.go:283
↓ 6 callersMethodGetObjectUID
()
pkg/shares/event_data.go:113
↓ 6 callersFunctionGetPodSLOByDeliveryPath
(pod *v1.Pod)
pkg/metas/bizinfo.go:44
↓ 6 callersFunctionIsTypicalPodNew
< 3 container, <= 8C16G, no user readiness-gate, no FlexVolume
pkg/metas/bizinfo.go:17
↓ 6 callersMethodLen
()
pkg/slo/pod_create_slo_span.go:13
↓ 6 callersMethodMatch
(event *shares.AuditEvent, spanName *string)
pkg/spans/config.go:99
↓ 6 callersFunctiongetPodInfoCacheForDocID
()
pkg/xsearch/xsearch_slo_pod_info.go:116
↓ 6 callersFunctionhandlerWrapper
(s *Server, h handlerFunc)
pkg/api/server.go:177
↓ 6 callersFunctionopenNotificationWithIcon
(key: number, type: NotificationType, message: string, description: string)
grafana_plugin/tkp_table_panel/src/components/SimplePanel.tsx:71
↓ 6 callersMethodremove
remove node
pkg/utils/cache.go:97
↓ 5 callersMethodGetFieldValue
(obj interface{})
pkg/spans/utils.go:165
↓ 5 callersFunctionInsertTimeStamp
(ts time.Time, timeAry []time.Time)
internal/grafanadi/service/esgrafana.go:11
↓ 5 callersMethodIterateWithFunc
IterateWithFunc iterate map
pkg/utils/safe_map.go:38
↓ 5 callersFunctionNew
Creates a new concurrent map.
pkg/utils/concurrent_map.go:21
↓ 5 callersFunctionNewFieldRef
(fieldSelector string, pathDelimiter string)
pkg/spans/utils.go:68
↓ 5 callersMethodProcess
(event *AuditEvent)
pkg/shares/processor.go:19
↓ 5 callersMethodQueryPodYamlsWithPodUID
(data interface{}, uid string)
pkg/dal/storage-client/data_access/storage_interface.go:17
↓ 5 callersMethodStart
(stopCh <-chan struct{})
pkg/aggregator/aggregator.go:61
↓ 5 callersMethodanalyzeFailedReason
分析失败原因
pkg/slo/pod_create_failreason.go:25
↓ 5 callersFunctioncorsHeader
(r *http.Request, w http.ResponseWriter)
internal/grafanadi/server/server.go:98
↓ 5 callersFunctiondebugApiCalledCounter
(handleName string, request *http.Request)
pkg/api/prometheus_metrics.go:24
↓ 4 callersMethodCanProcess
(event *AuditEvent)
pkg/shares/processor.go:18
↓ 4 callersFunctionInitConfig
(cfgFile string)
pkg/common/config.go:11
↓ 4 callersMethodIsComplete
IsComplete returns true is data is complete (ready to be included in the metric) and if it haven't been included in the metric yet.
pkg/slo/pod_create_slo.go:593
↓ 4 callersFunctionNewDBClient
(opts *common.DBOptions)
pkg/dal/storage-client/data_access/init.go:16
↓ 4 callersMethodPop
Pop removes an element from the map and returns it
pkg/utils/concurrent_map.go:146
↓ 4 callersMethodPublish
Publish will publish message to subscribers
pkg/pubsub/pubsub.go:71
↓ 4 callersMethodQueryLifePhaseWithPodUid
(data interface{}, uid string)
pkg/dal/storage-client/data_access/storage_interface.go:51
↓ 4 callersMethodQueryPodYamlWithParams
(data interface{}, opts *model.PodParams)
pkg/dal/storage-client/data_access/storage_interface.go:26
↓ 4 callersMethodQuerySloTraceDataWithPodUID
(data interface{}, uid string)
pkg/dal/storage-client/data_access/storage_interface.go:43
↓ 4 callersMethodQuerySloTraceDataWithPodUID
(data interface{}, podUid string)
pkg/dal/storage-client/data_access/ealsticsearch.go:793
↓ 4 callersFunctionSavePodInfoToZSearch
(cluster string, pod *corev1.Pod, deliveryStatus string, currentTime time.Time, auditID string, deliveryProgre
pkg/xsearch/xsearch_slo_pod_info.go:154
↓ 4 callersFunctionSaveSloTraceData
(cluster string, namespace string, name string, uid string, sloType string, sloData []byte)
pkg/xsearch/xsearch.go:968
↓ 4 callersMethodSubscribe
Subscribe subscribe to the PubSub.
pkg/pubsub/pubsub.go:53
↓ 4 callersMethodSubscriberName
should be unique to used as a map key
pkg/pubsub/pubsub.go:15
↓ 4 callersFunctioncalculateImagePullTime
计算镜像拉取时间
pkg/slo/pod_create_failreason.go:325
↓ 4 callersFunctioncancel
()
grafana_plugin/tkp_table_panel/src/components/SimplePanel.tsx:111
↓ 4 callersFunctionchangeTagKey
(tag: string)
grafana_plugin/filter_panel/src/components/FilterComponent.tsx:146
↓ 4 callersFunctiongetEsConfItemFromEnv
(name string)
pkg/slo/utils.go:169
↓ 4 callersFunctiongetSchedulingStrategyAndCores
(pod *v1.Pod)
pkg/slo/utils.go:69
↓ 4 callersFunctionnewBasePod
()
pkg/metas/utils_test.go:361
next →1–100 of 1,310, ranked by callers