Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/alipay/container-observability-service
/ functions
Functions
1,310 in github.com/alipay/container-observability-service
⨍
Functions
1,310
◇
Types & classes
341
Function
GetCreatedAndStartedContainerName
从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
Method
GetExtraPropertyNames
()
pkg/spans/config.go:493
Method
GetExtraPropertyNames
()
pkg/trace/config.go:567
Function
GetImageName
获取镜像名称
pkg/reason/utils/utils.go:25
Function
GetJobPodFinishedTime
GetJobPodFinishedTime use the max container terminated time as job finish time
pkg/metas/utils.go:376
Function
GetKilledContainerName
从Killed message 获取container name
pkg/reason/utils/utils.go:104
Function
GetOwnerType
(pod *corev1.Pod)
pkg/metas/utils.go:397
Function
GetPodPatch
(oldPod, newPod *corev1.Pod)
pkg/metas/utils.go:130
Function
GetPodReadyTime
(pod *corev1.Pod)
pkg/metas/utils.go:366
Function
GetPostStartHookElapsed
获取poststarthook耗时时间
pkg/reason/utils/utils.go:177
Function
GetPostStartHookTimeout
获取poststarthook超时时间
pkg/reason/utils/utils.go:165
Method
GetProcessed
get total processed item
pkg/slo/utils.go:160
Method
GetProcessed
()
pkg/slo/utils.go:342
Method
GetResponseOrRequestObj
()
pkg/shares/event_data.go:48
Function
GetSloPodInfoIndexByDocID
查询一个 PodInfo 所属于的 Index 由于 slo_pod_info 是天级别的索引,需要先找到这个 docID 对应的索引名称,然后再写入
pkg/xsearch/xsearch_slo_pod_info.go:257
Function
GetTkpReqUrl
(key string)
pkg/tkp_provider/config.go:39
Method
Handle
(err error)
pkg/trace/jaeger.go:113
Function
HandleCrash
()
pkg/utils/utils.go:379
Function
ImageReason
(auditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/pods/image_module.go:22
Function
IncreaseFailedTraceCount
IncreaseFailedTraceCount increase counter for failed traces
pkg/metrics/metrics.go:299
Function
IncreaseSucceedTraceCount
IncreaseSucceedTraceCount increase counter for succeed traces
pkg/metrics/metrics.go:305
Function
InitApi
(endPoint string, username string, password string)
pkg/api/init.go:9
Function
InitTkpReqConfig
(cfgFile string)
pkg/tkp_provider/config.go:13
Method
Initial
(object runtime.Object, uid string, properties utils.ConcurrentMap)
pkg/spans/config.go:417
Method
Initial
(object runtime.Object, globalSpans utils.ConcurrentMap, properties utils.ConcurrentMap)
pkg/trace/config.go:496
Function
IsDeleteImmediately
(pod *corev1.Pod)
pkg/metas/utils.go:349
Method
IsEmpty
IsEmpty checks if map is empty.
pkg/utils/concurrent_map.go:157
Function
IsPodFinishedNormally
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
Function
IsPodReady
判断pod是否ready
pkg/reason/utils/utils.go:199
Function
IsPodScheduled
(pod *corev1.Pod)
pkg/metas/utils.go:201
Function
IsPodSchedulingFailed
(pod *corev1.Pod)
pkg/metas/utils.go:189
Function
IsPodSucceed
判断pod是否ready
pkg/reason/utils/utils.go:217
Function
IsSidecarContainer
(container *corev1.Container)
pkg/metas/utils.go:388
Method
Iter
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
Method
IterCb
Callback based iterator, cheapest way to read all elements in a map.
pkg/utils/concurrent_map.go:258
Method
Keys
Keys returns all keys as []string
pkg/utils/concurrent_map.go:289
Function
KubeletDelayReason
(auditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/pods/kubeletdelay_module.go:20
Method
Len
()
pkg/slo/pod_create_slo_span.go:19
Method
Less
(i, j int)
pkg/slo/pod_create_slo_span.go:14
Method
Less
(i, j int)
pkg/slo/pod_create_slo_span.go:20
Function
Loader
(L *lua.LState)
pkg/spans/lua_helper.go:13
Function
LunettesLatencyFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/latency_handler.go:60
Method
MSet
(data map[string]interface{})
pkg/utils/concurrent_map.go:34
Function
Marshal
Marshal Marshal object to string of the error message if failed
pkg/utils/utils.go:79
Method
MarshalJSON
Reviles ConcurrentMap "private" variables to json marshal.
pkg/utils/concurrent_map.go:320
Function
MergeMaps
(mapTo, mapFrom map[string]string)
pkg/utils/utils.go:180
Function
MicroTime2Time
(t metav1.MicroTime)
pkg/metas/utils.go:345
Method
MockElasticSearchClient
()
pkg/mocks/clients_mock.go:60
Method
MockHttpClient
()
pkg/mocks/clients_mock.go:70
Method
MockHttpClient
()
pkg/dal/storage-client/mocks/elasticsearch_mock.go:70
Method
Name
()
pkg/reason/modules/module.go:48
Function
NetworkReason
(auditEvents []*shares.AuditEvent, beginTime *time.Time, endTime *time.Time)
pkg/reason/modules/pods/network_module.go:22
Function
NewAPIServer
NewAPIServer create new API server
pkg/api/server.go:134
Function
NewESReader
()
pkg/slo/utils.go:163
Method
NewIDs
NewIDs returns a non-zero trace ID and a non-zero span ID from a randomly-chosen sequence.
pkg/trace/jaeger.go:173
Function
NewMock
()
pkg/mocks/clients_mock.go:75
Method
NewSpanID
NewSpanID returns a non-zero span ID from a randomly-chosen sequence.
pkg/trace/jaeger.go:156
Function
Node
* 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
Function
NodeArray
(label, val, isLast)
statics/jsonTree.js:670
Function
NodeBoolean
(label, val, isLast)
statics/jsonTree.js:340
Function
NodeGraphParamsFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/node_graph_handler.go:92
Function
NodeNull
(label, val, isLast)
statics/jsonTree.js:399
Function
NodeNumber
(label, val, isLast)
statics/jsonTree.js:360
Function
NodeObject
(label, val, isLast)
statics/jsonTree.js:649
Function
NodeString
(label, val, isLast)
statics/jsonTree.js:380
Function
ObserveTraceDuration
ObserveTraceDuration observe for trace durations
pkg/metrics/metrics.go:311
Method
OnMessage
(v interface{})
pkg/metas/watch.go:73
Method
OnMessage
(v interface{})
pkg/pubsub/pubsub_test.go:19
Function
OwnerPodMapFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/owner_podmap_handler.go:149
Method
ParseRequest
()
pkg/api/debugpodyaml_handler.go:30
Method
ParseRequest
()
pkg/api/handler.go:38
Method
ParseRequest
()
pkg/api/raw_data_handler.go:26
Method
ParseRequest
()
pkg/api/debugnodeyaml_handler.go:28
Method
ParseRequest
()
pkg/api/debugpod_handler.go:55
Method
ParseRequest
()
pkg/api/slodebug_handler.go:36
Method
ParseRequest
()
internal/grafanadi/handler/vtkp_status_handler.go:32
Method
ParseRequest
()
internal/grafanadi/handler/podphase_handler.go:32
Method
ParseRequest
()
internal/grafanadi/handler/pod_delivery_handler.go:34
Method
ParseRequest
()
internal/grafanadi/handler/containerevents.go:61
Method
ParseRequest
()
internal/grafanadi/handler/querypodlist.go:33
Method
ParseRequest
()
internal/grafanadi/handler/biz_info_handler.go:32
Method
ParseRequest
()
internal/grafanadi/handler/vtkp_detail_handler.go:32
Method
ParseRequest
()
internal/grafanadi/handler/containerstatus.go:66
Method
ParseRequest
()
internal/grafanadi/handler/podlist.go:29
Method
ParseRequest
()
internal/grafanadi/handler/containerlifecycle.go:65
Method
ParseRequest
()
internal/grafanadi/handler/rawdata_handler.go:56
Method
ParseRequest
()
internal/grafanadi/handler/tkp_handler.go:40
Method
ParseRequest
()
internal/grafanadi/handler/node_graph_handler.go:31
Method
ParseRequest
()
internal/grafanadi/handler/owner_podmap_handler.go:126
Method
ParseRequest
()
internal/grafanadi/handler/root.go:24
Method
ParseRequest
()
internal/grafanadi/handler/pod_delivery_upgrade.go:32
Method
ParseRequest
()
internal/grafanadi/handler/yaml_handler.go:66
Method
ParseRequest
()
internal/grafanadi/handler/latency_handler.go:27
Method
ParseRequest
()
internal/grafanadi/handler/trace_handler.go:31
Method
ParseRequest
()
internal/grafanadi/handler/pod_status_handler.go:32
Method
ParseRequest
()
internal/grafanadi/handler/pod_info_handler.go:32
Method
ParseRequest
()
internal/grafanadi/handler/debugslo_handler.go:32
Function
ParseTags
trace param parse
pkg/utils/utils.go:475
Function
PodConditionExists
PodConditionExists() whether the condition is exists.
pkg/reason/utils/utils.go:15
Function
PodDeliveryFactory
(w http.ResponseWriter, r *http.Request, storage data_access.StorageInterface)
internal/grafanadi/handler/pod_delivery_handler.go:103
← previous
next →
701–800 of 1,310, ranked by callers